transactions support

Author: shimonewman

bin/init-mongo-replica-set.sh

@@ -0,0 +1,32 @@
+#!/bin/sh
+
+set -e
+
+echo "Waiting for MongoDB to be ready..."
+until docker compose exec mongo mongosh --eval "print('MongoDB is ready')" > /dev/null 2>&1; do
+    sleep 1
+done
+
+echo "Initializing MongoDB replica set..."
+
+# First, initialize the replica set without authentication
+echo "Initializing replica set..."
+docker compose exec mongo mongosh --eval 'rs.initiate({_id: "rs0", members: [{_id: 0, host: "mongo:27017"}]})'
+
+# Wait for the replica set to be ready
+echo "Waiting for replica set to be ready..."
+until docker compose exec mongo mongosh --eval "rs.status().ok" | grep -q "1"; do
+    sleep 2
+done
+
+echo "Replica set initialized successfully!"
+
+# Now create the admin user and enable authentication
+echo "Creating admin user and enabling authentication..."
+docker compose exec mongo mongosh --eval 'use admin; db.createUser({user: "root", pwd: "password", roles: [{role: "root", db: "admin"}]})'
+
+# Test authentication
+echo "Testing authentication..."
+docker compose exec mongo mongosh admin -u root -p password --eval 'db.runCommand({ping: 1})'
+
+echo "MongoDB replica set is ready for transactions!" 

composer.json

@@ -39,7 +39,7 @@
         "utopia-php/framework": "0.33.*",
         "utopia-php/cache": "0.13.*",
         "utopia-php/pools": "0.8.*",
-        "utopia-php/mongo": "dev-feat-bulk-writes as 0.3.1"
+        "utopia-php/mongo": "dev-feat-mongo-transactions as 0.3.1"
     },
     "require-dev": {
         "fakerphp/faker": "1.23.*",

composer.lock

@@ -79,10 +79,19 @@ services:
       - database
     ports:
       - "9706:27017"
+    volumes:
+      - ./mongo-keyfile:/etc/mongo-keyfile:ro
+      - mongo-data:/data/db
     environment:
       MONGO_INITDB_DATABASE: utopia_testing
       MONGO_INITDB_ROOT_USERNAME: root
-      MONGO_INITDB_ROOT_PASSWORD: password
+      MONGO_INITDB_ROOT_PASSWORD: password   
+    command: >
+      mongod --replSet rs0
+             --auth
+             --keyFile /etc/mongo-keyfile
+# Manyally initate the replica set
+#docker compose exec mongo  mongosh admin -u root -p password --eval 'rs.initiate({_id: "rs0", members: [{_id: 0, host: "mongo:27017"}]})'
 
   mongo-express:
     image: mongo-express
@@ -146,5 +155,7 @@ services:
     networks:
       - database
 
+volumes:
+  mongo-data:
 networks:
   database:

docker-compose.yml

@@ -0,0 +1,16 @@
+ydIuYSvU/9QLt7fkH32IdXbP2z2+w+fzSEoolW8Q1Z8nLhRyrZF0Zq7a0KzeNI7K
+gPIl1ikI6ob6h0+RxYmGeOOUjjkcBlkvYrmABDKsRipTkTTp4z0fUBTIUJV0lVvs
+N9+VpM0/pLLIhI8jb38aa7pmsoufBQ3uiNR68ZFykPqzZQ4d5VfMqfZk7z3dpFlh
+DURPOOG0HAFe68MLXVFYdaHGW4yomuTPrpzWSiUhFAPFEBYg4elARQc4CaiinFds
+SQi/SrUsYMGODPr+on9/lboia/SInaSP+dzDqpsbL29atvIVHtU29RlPJdZ2V1ub
+Oe2O1xN9F59TtjNUgDiAtMGKTMS/0S1mbPC6Og5JAR7U4xZ7/6S5n3+p0RjYyTlH
+fhssJ7pc/bveN6mShNrsIKK0Z50YYjablzm07EDJYhfEWMG5Wu1AvEVqEH68ioDl
+JL5QO63A2bXvMN7dXS69+E0hHn6xaZYu+CnKedvgWdyhraCT1Q01ZyDyv2y7isGD
+1BAlNLlt+cPMCitETcxZne+JHdkL/mDKffHUPM4Drtzchg4DbiG49uC9Ib7zTws+
+NcburXY+9B8j7WN7ZHXhiB7/OWJ/IHJCZTdKz70mEPH4AHoRFpZNM5eMnYxYdbQD
+40MhAS7fuOYhtFIQiQ+SCeFMucE3KYvp1JpTVQwT4SNrIlHPqfPn5xFBcgDjhvwT
+hHJCgXP4HrRuf47Ta6kHy2UFQ7r5JOqSZSOFwP+tUyfhjEB5ZWJ1qCUZxFagoc9A
+//9SoyulZwCxEr2ijmes1Nzv56hSTjYb6pPjFWd92G87w+VZv4R/vF5nwcYUyuIS
+iQWPs/kOzb4NeJW24lNzR2zH2BsJt3OI+BFY64cc8O0o6EtFWcoabwyJYKe6RXPX
+0S4ngcnGzRP+tVa6LsrjAYrNpmZDrP9x93pXQHfByTS2oSaI1eGeAagFTu/HS2kC
+uCJ0HfH99sRSgJ1Ab+2C8G8305meDAbtdCtvl/1anPnV6ISy

mongo-keyfile

@@ -374,10 +374,7 @@ public function withTransaction(callable $callback): mixed
         for ($attempts = 0; $attempts < 3; $attempts++) {
             try {
                 $this->startTransaction();
-                //var_dump($attempts);
                 $result = $callback();
-                //var_dump($result);
-
                 $this->commitTransaction();
 
                 return $result;

src/Database/Adapter.php

@@ -1173,7 +1173,6 @@ public function createOrUpdateDocuments(
             $bindValues = [];
             $documentIds = [];
             $documentTenants = [];
-
             foreach ($changes as $change) {
                 $document = $change->getNew();
                 $attributes = $document->getAttributes();