add mongodb(replica set) environment into docker configuration

MongoReplsetDockerFile

@@ -0,0 +1,5 @@
+FROM mongo
+
+ADD mongo-replset-init.sh /usr/local/bin/
+
+RUN chmod +x /usr/local/bin/mongo-replset-init.sh

docker-compose.yml

@@ -12,6 +12,9 @@ services:
         depends_on:
           - mongodb
           - mysql
+          - mongo1
+          - mongo2
+          - mongo3
 
     mysql:
         container_name: mysql
@@ -30,3 +33,46 @@ services:
             - 27017:27017
         logging:
             driver: none
+
+    mongo1:
+        hostname: mongo1
+        container_name: mongo1
+        image: mongo
+        restart: always
+        expose:
+            - 27017
+        ports:
+            - 27018:27017
+        command: '--quiet --bind_ip_all --replSet rs0'
+
+    mongo2:
+        hostname: mongo2
+        container_name: mongo2
+        image: mongo
+        restart: always
+        expose:
+            - 27017
+        ports:
+            - 27019:27017
+        command: '--quiet --bind_ip_all --replSet rs0'
+
+    mongo3:
+        hostname: mongo3
+        container_name: mongo3
+        image: mongo
+        restart: always
+        expose:
+            - 27017
+        ports:
+            - 27020:27017
+        command: '--quiet --bind_ip_all --replSet rs0'
+
+    mongoreplret:
+        build:
+            context: .
+            dockerfile: MongoReplsetDockerFile
+        depends_on:
+            - mongo1
+            - mongo2
+            - mongo3
+        entrypoint: ["sh", "-c", "mongo-replset-init.sh"]

mongo-replset-init.sh

@@ -0,0 +1,23 @@
+#!/bin/bash
+
+echo "prepare rs initiating"
+
+check_db_status() {
+  mongo1=$(mongo --host mongo1 --port 27017 --eval "db.stats().ok" | tail -n1 | grep -E '(^|\s)1($|\s)')
+  mongo2=$(mongo --host mongo2 --port 27017 --eval "db.stats().ok" | tail -n1 | grep -E '(^|\s)1($|\s)')
+  mongo3=$(mongo --host mongo3 --port 27017 --eval "db.stats().ok" | tail -n1 | grep -E '(^|\s)1($|\s)')
+  if [[ $mongo1 == 1 ]] && [[ $mongo2 == 1 ]] && [[ $mongo3 == 1 ]]; then
+    init_rs
+  else
+    check_db_status
+  fi
+}
+
+init_rs() {
+  ret=$(mongo --host mongo1 --port 27017 --eval "rs.initiate({ _id: 'rs0', members: [{ _id: 0, host: 'mongo1:27017' }, { _id: 1, host: 'mongo2:27017' }, { _id: 2, host: 'mongo3:27017' } ] })" > /dev/null 2>&1)
+}
+
+check_db_status > /dev/null 2>&1
+
+echo "rs initiating finished"
+exit 0

tests/TestCase.php

@@ -53,6 +53,7 @@ protected function getEnvironmentSetUp($app)
         $app['config']->set('database.connections.mongodb', $config['connections']['mongodb']);
         $app['config']->set('database.connections.mongodb2', $config['connections']['mongodb']);
         $app['config']->set('database.connections.dsn_mongodb', $config['connections']['dsn_mongodb']);
+        $app['config']->set('database.connections.mongodb_replset', $config['connections']['mongodb_replset']);
 
         $app['config']->set('auth.model', 'User');
         $app['config']->set('auth.providers.users.model', 'User');

tests/TransactionBuilderTest.php

@@ -7,18 +7,25 @@ class TransactionBuilderTest extends TestCase
 {
     protected $insertData = ['name' => 'klinson', 'age' => 20, 'title' => 'admin'];
     protected $originData = ['name' => 'users', 'age' => 20, 'title' => 'user'];
+    protected $connection = 'mongodb_replset';
+    protected $originConnection = 'mongodb';
 
     public function setUp(): void
     {
         parent::setUp();
 
+        /** change connection to seplset? because the transaction needs  */
+        $this->originConnection = DB::getDefaultConnection();
+        DB::setDefaultConnection($this->connection);
+
         DB::collection('users')->truncate();
         DB::collection('users')->insert($this->originData);
     }
 
     public function tearDown(): void
     {
         DB::collection('users')->truncate();
+        DB::setDefaultConnection($this->originConnection);
         parent::tearDown();
     }
 

tests/TransactionTest.php

@@ -7,17 +7,26 @@ class TransactionTest extends TestCase
 {
     protected $insertData = ['name' => 'klinson', 'age' => 20, 'title' => 'admin'];
     protected $originData = ['name' => 'users', 'age' => 20, 'title' => 'user'];
+    protected $connection = 'mongodb_replset';
+    protected $originConnection = 'mongodb';
 
     public function setUp(): void
     {
         parent::setUp();
+
+        /** change connection to seplset? because the transaction needs  */
+        $this->originConnection = DB::getDefaultConnection();
+        DB::setDefaultConnection($this->connection);
+
         User::truncate();
         User::create($this->originData);
     }
 
     public function tearDown(): void
     {
         User::truncate();
+        DB::setDefaultConnection($this->originConnection);
+
         parent::tearDown();
     }
 

tests/config/database.php

@@ -14,6 +14,19 @@
             'database' => env('MONGO_DATABASE', 'unittest'),
         ],
 
+        'mongodb_replset' => [
+            'driver' => 'mongodb',
+            'host' => [
+                'mongo1:27017',
+                'mongo2:27017',
+                'mongo3:27017',
+            ],
+            'database' => env('MONGO_DATABASE', 'unittest'),
+            'options'  => [
+                'replicaSet' => 'rs0'
+            ]
+        ],
+
         'dsn_mongodb' => [
             'driver' => 'mongodb',
             'dsn' => "mongodb://$mongoHost:$mongoPort",

tests/models/User.php

@@ -23,7 +23,7 @@ class User extends Eloquent implements AuthenticatableContract, CanResetPassword
 {
     use Authenticatable, CanResetPassword, HybridRelations, Notifiable;
 
-    protected $connection = 'mongodb';
+//    protected $connection = 'mongodb';
     protected $dates = ['birthday', 'entry.date'];
     protected static $unguarded = true;