Invalid Utf chars

phpunit.xml

@@ -7,7 +7,7 @@
     convertNoticesToExceptions="true"
     convertWarningsToExceptions="true"
     processIsolation="false"
-    stopOnFailure="false">
+    stopOnFailure="true">
     <testsuites>
         <testsuite name="Application Test Suite">
             <directory>./tests/</directory>

src/Database/Adapter/Postgres.php

@@ -739,9 +739,9 @@ public function createDocument(string $collection, Document $document): Document
                 $stmtPermissions->execute();
             }
         } catch (Throwable $e) {
+            $this->getPDO()->rollBack();
             switch ($e->getCode()) {
                 case 23505:
-                    $this->getPDO()->rollBack();
                     throw new Duplicate('Duplicated document: ' . $e->getMessage());
 
                 default:

src/Database/Adapter/SQL.php

@@ -880,7 +880,7 @@ protected function getSQLTable(string $name): string
      * Returns the current PDO object
      * @return mixed
      */
-    protected function getPDO(): mixed
+    protected function getPDO(): PDO
     {
         return $this->pdo;
     }

tests/Database/Base.php

@@ -254,7 +254,6 @@ public function testQueryTimeoutUsingStaticTimeout(): void
         $this->expectNotToPerformAssertions();
     }
 
-
     /**
      * @depends testCreateExistsDelete
      */
@@ -1082,6 +1081,43 @@ public function testCreateDocumentDefaults(): void
         static::getDatabase()->deleteCollection('defaults');
     }
 
+    public function testInvalidUtfCharacters(): void
+    {
+        $collection = 'null_character';
+
+        static::getDatabase()->createCollection($collection);
+        static::getDatabase()->createAttribute($collection, 'str', Database::VAR_STRING, 128, true);
+
+        $str = "\x00";
+        $this->assertInstanceOf('Utopia\Database\Document', static::getDatabase()->createDocument($collection, new Document([
+            'str' => $str,
+        ])));
+
+        $str = "\u0000";
+        $this->assertInstanceOf('Utopia\Database\Document', static::getDatabase()->createDocument($collection, new Document([
+            'str' => $str,
+        ])));
+
+        $str = "\000";
+        $this->assertInstanceOf('Utopia\Database\Document', static::getDatabase()->createDocument($collection, new Document([
+            'str' => $str,
+        ])));
+
+        $str = "\xE2\x94";
+        try {
+            $this->assertInstanceOf('Utopia\Database\Document', static::getDatabase()->createDocument($collection, new Document([
+                'str' => $str,
+            ])));
+            $this->fail('Failed to throw Exception');
+        } catch (Exception $e) {
+            $this->assertTrue(true);
+        }
+
+        $this->assertInstanceOf('Utopia\Database\Document', static::getDatabase()->createDocument($collection, new Document([
+            'str' => mb_convert_encoding($str, 'UTF-8', 'UTF-8'),
+        ])));
+    }
+
     /**
      * @throws AuthorizationException|LimitException|DuplicateException|StructureException|Exception|Throwable
      */