Unified Injections

Author: transistive

src/Contracts/Injections.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+/*
+ * This file is part of the Laudis Neo4j package.
+ *
+ * (c) Laudis technologies <http://laudis.tech>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Laudis\Neo4j\Contracts;
+
+interface Injections
+{
+    /**
+     * @param string|callable():string $database
+     *
+     * @return static
+     */
+    public function withDatabase($database): self;
+
+    /**
+     * @param callable():bool|bool $routing
+     *
+     * @return static
+     */
+    public function withAutoRouting($routing): self;
+
+    public function database(): string;
+
+    public function hasAutoRouting(): bool;
+}

src/Network/Bolt/BoltInjections.php

@@ -15,6 +15,7 @@
 
 use function call_user_func;
 use function is_callable;
+use Laudis\Neo4j\Contracts\Injections;
 
 /**
  * @psalm-type SSLContextOptions = null|array{
@@ -39,7 +40,7 @@
  *
  * @psalm-type LazySSLContextOptions = callable():SSLContextOptions|SSLContextOptions
  */
-final class BoltInjections
+final class BoltInjections implements Injections
 {
     /** @var callable():string|string */
     private $database;

src/Network/Http/HttpInjections.php

@@ -15,11 +15,12 @@
 
 use Http\Discovery\Psr17FactoryDiscovery;
 use Http\Discovery\Psr18ClientDiscovery;
+use Laudis\Neo4j\Contracts\Injections;
 use Psr\Http\Client\ClientInterface;
 use Psr\Http\Message\RequestFactoryInterface;
 use Psr\Http\Message\StreamFactoryInterface;
 
-final class HttpInjections
+final class HttpInjections implements Injections
 {
     /** @var ClientInterface|callable():ClientInterface */
     private $client;
@@ -29,6 +30,8 @@ final class HttpInjections
     private $requestFactory;
     /** @var string|callable():string */
     private $database;
+    /** @var bool|callable():bool */
+    private $autoRouting;
 
     /**
      * Injector constructor.
@@ -37,8 +40,9 @@ final class HttpInjections
      * @param ClientInterface|callable():ClientInterface|null                 $client
      * @param StreamFactoryInterface|callable():StreamFactoryInterface|null   $streamFactory
      * @param RequestFactoryInterface|callable():RequestFactoryInterface|null $requestFactory
+     * @param bool|callable():bool                                            $autoRouting
      */
-    public function __construct($database = null, $client = null, $streamFactory = null, $requestFactory = null)
+    public function __construct($database = null, $client = null, $streamFactory = null, $requestFactory = null, $autoRouting = null)
     {
         $this->database = $database ?? static function (): string {
             return 'neo4j';
@@ -52,6 +56,7 @@ public function __construct($database = null, $client = null, $streamFactory = n
         $this->requestFactory = $requestFactory ?? static function (): RequestFactoryInterface {
             return Psr17FactoryDiscovery::findRequestFactory();
         };
+        $this->autoRouting = $autoRouting ?? false;
     }
 
     public static function create(): self
@@ -73,31 +78,31 @@ public function client(): ClientInterface
      */
     public function withClient($client): self
     {
-        return new self($this->database, $client, $this->streamFactory, $this->requestFactory);
+        return new self($this->database, $client, $this->streamFactory, $this->requestFactory, $this->autoRouting);
     }
 
     /**
      * @param StreamFactoryInterface|callable():StreamFactoryInterface $factory
      */
     public function withStreamFactory($factory): self
     {
-        return new self($this->database, $this->client, $factory, $this->requestFactory);
+        return new self($this->database, $this->client, $factory, $this->requestFactory, $this->autoRouting);
     }
 
     /**
      * @param RequestFactoryInterface|callable():RequestFactoryInterface $factory
      */
     public function withRequestFactory($factory): self
     {
-        return new self($this->database, $this->client, $this->streamFactory, $factory);
+        return new self($this->database, $this->client, $this->streamFactory, $factory, $this->autoRouting);
     }
 
     /**
      * @param string|callable():string $database
      */
     public function withDatabase($database): self
     {
-        return new self($database, $this->client, $this->streamFactory, $this->requestFactory);
+        return new self($database, $this->client, $this->streamFactory, $this->requestFactory, $this->autoRouting);
     }
 
     public function streamFactory(): StreamFactoryInterface
@@ -126,4 +131,24 @@ public function database(): string
 
         return $this->database;
     }
+
+    public function withAutoRouting($routing): Injections
+    {
+        return new self(
+            $this->database,
+            $this->client,
+            $this->streamFactory,
+            $this->requestFactory,
+            $routing
+        );
+    }
+
+    public function hasAutoRouting(): bool
+    {
+        if (is_callable($this->autoRouting)) {
+            $this->autoRouting = call_user_func($this->autoRouting);
+        }
+
+        return $this->autoRouting;
+    }
 }