FFWEB-2628: add config to AdapterFactory

Author: grzegorz-jamroz

CHANGELOG.md

@@ -1,4 +1,9 @@
 # Changelog
+## Unreleased
+### Add
+ AdapterFactory
+- add config
+
 ## [v0.9.4] - 2022.08.25
 ### Changed
  Compatibility

src/Resource/AdapterFactory.php

@@ -16,28 +16,37 @@ class AdapterFactory
     /** @var string */
     private $version;
 
-    public function __construct(ClientBuilder $clientBuilder, string $version = Version::NG)
-    {
+    /** @var array */
+    private $config;
+
+    public function __construct(
+        ClientBuilder $clientBuilder,
+        string $version = Version::NG,
+        string $apiVersion = 'v4'
+    ) {
         $this->clientBuilder = $clientBuilder;
         $this->version       = $version;
+        $this->config        = [
+            'api_version' => $apiVersion,
+        ];
     }
 
     public function getImportAdapter(): Import
     {
         $class = $this->getAdapterClass(Import::class, $this->version);
-        return new $class($this->getClient());
+        return new $class($this->getClient(), $this->config);
     }
 
     public function getSearchAdapter(): Search
     {
         $class = $this->getAdapterClass(Search::class, $this->version);
-        return new $class($this->getClient());
+        return new $class($this->getClient(), $this->config);
     }
 
     public function getTrackingAdapter(): Tracking
     {
         $class = $this->getAdapterClass(Tracking::class, $this->version);
-        return new $class($this->getClient());
+        return new $class($this->getClient(), $this->config);
     }
 
     private function getAdapterClass(string $resource, string $version): string

src/Resource/NG/ImportAdapter.php

@@ -12,21 +12,34 @@ class ImportAdapter implements Import
     /** @var ClientInterface */
     private $client;
 
-    public function __construct(ClientInterface $client)
-    {
+    /** @var array */
+    private $config;
+
+    public function __construct(
+        ClientInterface $client,
+        array $config = []
+    ) {
         $this->client = $client;
+        $this->config = $config;
     }
 
     public function import(string $channel, string $type, array $params = []): array
     {
-        $params   = ['channel' => $channel] + $params;
-        $response = $this->client->request('POST', "rest/v4/import/{$type}", ['query' => $params]);
+        $params     = ['channel' => $channel] + $params;
+        $apiVersion = $this->getApiVersion();
+        $response   = $this->client->request('POST', "rest/{$apiVersion}/import/{$type}", ['query' => $params]);
         return (array) json_decode((string) $response->getBody(), true);
     }
 
     public function running(string $channel): bool
     {
-        $response = $this->client->request('GET', 'rest/v4/import/running', ['query' => ['channel' => $channel]]);
+        $apiVersion = $this->getApiVersion();
+        $response   = $this->client->request('GET', "rest/{$apiVersion}/import/running", ['query' => ['channel' => $channel]]);
         return (bool) json_decode((string) $response->getBody(), true);
     }
+
+    private function getApiVersion(): string
+    {
+        return (string) $this->config['api_version'] ?? 'v4';
+    }
 }

src/Resource/NG/SearchAdapter.php

@@ -12,22 +12,35 @@ class SearchAdapter implements Search
     /** @var ClientInterface */
     private $client;
 
-    public function __construct(ClientInterface $client)
-    {
+    /** @var array */
+    private $config;
+
+    public function __construct(
+        ClientInterface $client,
+        array $config = []
+    ) {
         $this->client = $client;
+        $this->config = $config;
     }
 
     public function search(string $channel, string $query, array $params = []): array
     {
-        $params   = ['query' => $query] + $params;
-        $response = $this->client->request('GET', "rest/v4/search/{$channel}", ['query' => $params]);
+        $params     = ['query' => $query] + $params;
+        $apiVersion = $this->getApiVersion();
+        $response   = $this->client->request('GET', "rest/{$apiVersion}/search/{$channel}", ['query' => $params]);
         return (array) json_decode((string) $response->getBody(), true);
     }
 
     public function suggest(string $channel, string $query, array $params = []): array
     {
-        $params   = ['query' => $query] + $params;
-        $response = $this->client->request('GET', "rest/v4/suggest/{$channel}", ['query' => $params]);
+        $params     = ['query' => $query] + $params;
+        $apiVersion = $this->getApiVersion();
+        $response   = $this->client->request('GET', "rest/{$apiVersion}/suggest/{$channel}", ['query' => $params]);
         return (array) json_decode((string) $response->getBody(), true);
     }
+
+    private function getApiVersion(): string
+    {
+        return (string) $this->config['api_version'] ?? 'v4';
+    }
 }

src/Resource/NG/TrackingAdapter.php

@@ -12,15 +12,27 @@ class TrackingAdapter implements Tracking
     /** @var ClientInterface */
     private $client;
 
-    public function __construct(ClientInterface $client)
-    {
+    /** @var array */
+    private $config;
+
+    public function __construct(
+        ClientInterface $client,
+        array $config = []
+    ) {
         $this->client = $client;
+        $this->config = $config;
     }
 
     public function track(string $channel, string $event, array $eventData = []): array
     {
-        $params   = ['body' => json_encode($eventData), 'headers' => ['Content-Type' => 'application/json']];
-        $response = $this->client->request('POST', "rest/v4/track/{$channel}/{$event}", $params);
+        $params     = ['body' => json_encode($eventData), 'headers' => ['Content-Type' => 'application/json']];
+        $apiVersion = $this->getApiVersion();
+        $response   = $this->client->request('POST', "rest/{$apiVersion}/track/{$channel}/{$event}", $params);
         return json_decode((string) $response->getBody(), true) ?? [];
     }
+
+    private function getApiVersion(): string
+    {
+        return (string) $this->config['api_version'] ?? 'v4';
+    }
 }