Lazy connections

Author: GrahamCampbell

composer.json

@@ -41,7 +41,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-master": "6.0-dev"
+            "dev-master": "6.1-dev"
         },
         "laravel": {
             "providers": [

src/Locker.php

@@ -28,18 +28,18 @@ class Locker
     /**
      * The connection instance.
      *
-     * @var \AltThree\Locker\Connections\ConnectionInterface
+     * @var \AltThree\Locker\Connections\ConnectionInterface|callable
      */
     protected $connection;
 
     /**
      * Create a new locker instance.
      *
-     * @param \AltThree\Locker\Connections\ConnectionInterface $connection
+     * @param \AltThree\Locker\Connections\ConnectionInterface|callable $connection
      *
      * @return void
      */
-    public function __construct(ConnectionInterface $connection)
+    public function __construct($connection)
     {
         $this->connection = $connection;
     }
@@ -59,7 +59,7 @@ public function __construct(ConnectionInterface $connection)
      */
     public function make(string $name, int $timeout, int $play = 500, int $interval = 100, int $attempts = 128)
     {
-        return new Lock($this->connection, $name, $timeout, $play, $interval, $attempts);
+        return new Lock($this->resolveConnection(), $name, $timeout, $play, $interval, $attempts);
     }
 
     /**
@@ -95,4 +95,20 @@ public function execute(Closure $function, string $name, int $timeout, int $play
 
         return $result;
     }
+
+    /**
+     * Resolve the connection instance.
+     *
+     * @return \AltThree\Locker\Connections\ConnectionInterface
+     */
+    protected function resolveConnection()
+    {
+        if ($this->connection instanceof ConnectionInterface) {
+            return $this->connection;
+        }
+
+        $c = $this->connection;
+
+        return $this->connection = $c();
+    }
 }

src/LockerServiceProvider.php

@@ -96,7 +96,9 @@ protected function registerConnection()
     protected function registerLocker()
     {
         $this->app->singleton('locker', function (Container $app) {
-            $connection = $app['locker.connection'];
+            $connection = function () use ($app) {
+                return $app['locker.connection'];
+            };
 
             return new Locker($connection);
         });