WithParallelPhyiscalDatabase trait

Author: recca0120

README.md

@@ -21,20 +21,7 @@ composer require recca0120/laravel-parallel
 
 ## Usage
 
-1. set a real database in phpunit.xml
-
-```xml
-
-<phpunit>
-    <php>
-        <!-- DB_CONNECTION can't be %memory% -->
-        <server name="DB_CONNECTION" value="sqlite"/>
-        <server name="DB_DATABASE" value="database/database.sqlite"/>
-    </php>
-</phpunit>
-```
-
-2. make a product migration
+- make a product migration
 
 ```php
 <?php
@@ -74,7 +61,7 @@ class CreateProductsTable extends Migration
 
 ```
 
-3. define product model `App\Models\Product`
+- define product model `App\Models\Product`
 
 ```php
 <?php
@@ -104,7 +91,7 @@ class Product extends Model
 
 ```
 
-4. define router in `routes/web.php`
+- define router in `routes/web.php`
 
 ```php
 <?php
@@ -133,7 +120,7 @@ Route::post('/product/{productId}', function ($productId) {
 
 ```
 
-5. testing
+- testing
 
 ```php
 <?php
@@ -142,24 +129,23 @@ namespace Tests\Feature;
 
 use App\Models\Product;
 use Illuminate\Foundation\Testing\DatabaseMigrations;
+use Recca0120\LaravelParallel\Tests\Concerns\WithParallelPhyiscalDatabase;
 use Recca0120\LaravelParallel\Tests\ParallelRequest;
 use Tests\TestCase;
 
 class RaceConditionTest extends TestCase
 {
     use DatabaseMigrations;
+    use WithParallelPhyiscalDatabase;
 
     private $product;
     private $quantity = 10;
 
-    public function setUp(): void
-    {
-        parent::setUp();
-        $this->product = Product::create(['name' => 'test', 'quantity' => $this->quantity]);
-    }
-
     public function test_race_condition()
     {
+        $this->useParallelPhyiscalDatabase();
+
+        $this->product = Product::create(['name' => 'test', 'quantity' => $this->quantity]);
         $request = $this->app->make(ParallelRequest::class);
 
         $promises = collect();
@@ -178,6 +164,10 @@ class RaceConditionTest extends TestCase
 
     public function test_multiple_times_to_test_race_condition()
     {
+        $this->useParallelPhyiscalDatabase();
+
+        $this->product = Product::create(['name' => 'test', 'quantity' => $this->quantity]);
+
         $request = $this->app->make(ParallelRequest::class);
 
         $promises = collect($request->times(10)->post('/product/'.$this->product->id));

composer.json

@@ -3,7 +3,6 @@
     "description": "",
     "keywords": [
         "laravel",
-        "testing",
         "parallel",
         "parallel request"
     ],

src/ParallelServiceProvider.php

@@ -2,6 +2,7 @@
 
 namespace Recca0120\LaravelParallel;
 
+use Illuminate\Http\Request;
 use Illuminate\Support\ServiceProvider;
 use Recca0120\LaravelParallel\Console\ParallelCommand;
 
@@ -19,5 +20,12 @@ public function register()
         ]);
 
         $this->commands([ParallelCommand::class]);
+
+        $this->app->bind(ParallelRequest::class, function () {
+            /** @var Request $request */
+            $request = app('request');
+
+            return (new ParallelRequest($request))->withServerVariables($request->server->all());
+        });
     }
 }

src/Tests/Concerns/WithParallelPhyiscalDatabase.php

@@ -0,0 +1,90 @@
+<?php
+
+namespace Recca0120\LaravelParallel\Tests\Concerns;
+
+use Illuminate\Contracts\Console\Kernel;
+use Illuminate\Foundation\Testing\DatabaseMigrations;
+use Illuminate\Foundation\Testing\RefreshDatabase;
+use Illuminate\Foundation\Testing\RefreshDatabaseState;
+use Illuminate\Foundation\Testing\Traits\CanConfigureMigrationCommands;
+use Illuminate\Http\Request;
+use Illuminate\Support\Arr;
+use Illuminate\Support\Facades\File;
+use Illuminate\Support\Str;
+use Recca0120\LaravelParallel\Tests\ParallelRequest;
+
+trait WithParallelPhyiscalDatabase
+{
+    use CanConfigureMigrationCommands;
+
+    private $parallelDatabaseName = 'laravel-parallel';
+
+    public function useParallelPhyiscalDatabase(): void
+    {
+        $this->setParallelPhyiscalDatabase();
+        $this->refreshParallelPhyiscalDatabase();
+        $this->bindParallelRequest();
+    }
+
+    protected function setParallelPhyiscalDatabase(): void
+    {
+        if ($this->usingPhyiscalDatabase()) {
+            return;
+        }
+
+        $config = collect(Arr::dot(config()->all()))
+            ->filter(function ($value, $key) {
+                return $value && Str::endsWith($key, 'database.connection');
+            })
+            ->map(function () {
+                return $this->parallelDatabaseName;
+            })
+            ->merge(['database.default' => $this->parallelDatabaseName])
+            ->toArray();
+
+        config($config);
+
+        File::put(config('database.connections.'.$this->parallelDatabaseName.'.database'), '');
+    }
+
+    protected function refreshParallelPhyiscalDatabase(): void
+    {
+        $this->artisan('migrate:fresh', $this->migrateFreshUsing());
+
+        $this->app[Kernel::class]->setArtisan(null);
+
+        $uses = array_flip(class_uses_recursive(static::class));
+        foreach ([RefreshDatabase::class, DatabaseMigrations::class] as $class) {
+            if (array_key_exists($class, $uses)) {
+                RefreshDatabaseState::$migrated = false;
+                RefreshDatabaseState::$lazilyRefreshed = false;
+
+                return;
+            }
+        }
+    }
+
+    /**
+     * @return void
+     */
+    private function bindParallelRequest(): void
+    {
+        $this->app->bind(ParallelRequest::class, function () {
+            /** @var Request $request */
+            $request = app('request');
+            $default = config('database.default');
+
+            return (new ParallelRequest($request))->withServerVariables(array_merge($request->server->all(), [
+                'DB_CONNECTION' => $default,
+                'DB_DATABASE' => config('database.connections.'.$default.'.database'),
+            ]));
+        });
+    }
+
+    protected function usingPhyiscalDatabase(): bool
+    {
+        $default = config('database.default');
+
+        return config("database.connections.$default.database") !== ':memory:';
+    }
+}