Normalize timestamps in race-condition reconciliation for Postgres compatibility

Author: premtsd-code

src/Database/Adapter/SQL.php

@@ -2716,21 +2716,26 @@ public function createDocuments(Document $collection, array $documents, bool $ig
                 $rows = $verifyStmt->fetchAll();
                 $verifyStmt->closeCursor();
 
-                // Keep only docs whose _createdAt matches what we set (= ours, not racer's)
+                // Keep only docs whose _createdAt matches what we set (= ours, not racer's).
+                // Normalise timestamps before comparing — Postgres omits .000 for round seconds.
+                $normalizeTimestamp = fn (?string $ts): string => $ts !== null
+                    ? (new \DateTime($ts))->format('Y-m-d H:i:s.v')
+                    : '';
+
                 $actualTimestamps = [];
                 foreach ($rows as $row) {
                     $key = ($this->sharedTables && $this->tenantPerDocument)
                         ? $row['_tenant'] . ':' . $row['_uid']
                         : $row['_uid'];
-                    $actualTimestamps[$key] = $row['_createdAt'];
+                    $actualTimestamps[$key] = $normalizeTimestamp($row['_createdAt']);
                 }
 
                 $insertedDocs = [];
                 foreach ($documents as $doc) {
                     $key = ($this->sharedTables && $this->tenantPerDocument)
                         ? $doc->getTenant() . ':' . $doc->getId()
                         : $doc->getId();
-                    if (isset($actualTimestamps[$key]) && $actualTimestamps[$key] === $expectedTimestamps[$key]) {
+                    if (isset($actualTimestamps[$key]) && $actualTimestamps[$key] === $normalizeTimestamp($expectedTimestamps[$key] ?? null)) {
                         $insertedDocs[] = $doc;
                     }
                 }