Feature: Allow to disable switching of default connection and restore…

… "current" connection (#285)

* Adjust hooks to perform properly on queues

* Linting

* Include tests

* Adjust to comply with PHP 8.0

* Return the connection to the tenant connection and replace default connection

* Add a test

src/Hooks/Migration/Hooks/MigratesHook.php

@@ -30,6 +30,8 @@ class MigratesHook extends ConfigurableHook
 
     public int $priority = -50;
 
+    protected bool $replaceDefaultConnection = true;
+
     public array $paths;
 
     public function __construct()
@@ -50,6 +52,13 @@ public function for($event): static
         return $this;
     }
 
+    public function withDefaultConnection(bool $replace = true): static
+    {
+        $this->replaceDefaultConnection = $replace;
+
+        return $this;
+    }
+
     public function fire(): void
     {
         $db = resolve('db');
@@ -66,7 +75,10 @@ public function fire(): void
         }
         call_user_func([$migrator, $this->action], $this->paths);
 
-        $resolver->__invoke(null, $this->connection);
-        $db->setDefaultConnection($default);
+        $resolver->__invoke(Tenancy::getTenant(), $this->connection);
+
+        if ($this->replaceDefaultConnection) {
+            $db->setDefaultConnection($default);
+        }
     }
 }

tests/Hooks/Migration/Unit/ConfiguresMigrationsTest.php

@@ -75,4 +75,25 @@ public function it_can_clear_paths_from_the_migrator($tenantEvent)
             $this->hook->paths
         );
     }
+
+    /**
+     * @dataProvider tenantEventsProvider
+     *
+     * @test */
+    public function it_can_decide_whether_to_replace_the_default($tenantEvent)
+    {
+        $this->events->listen($this->eventClass, function ($event) {
+            $event->hook->withDefaultConnection(false);
+        });
+
+        $this->hook->for(new $tenantEvent($this->mockTenant()));
+
+        $reflection = new \ReflectionClass($this->hook);
+        $property = $reflection->getProperty('replaceDefaultConnection');
+        $property->setAccessible(true);
+
+        $this->assertFalse(
+            $property->getValue($this->hook)
+        );
+    }
 }