Merge branch 'feature/add-setup-endpoint' into 'master'

Add createConnect method

See merge request signalise/signalise-php-client!7

Author: Ndottens

src/Client/ApiClient.php

@@ -12,23 +12,27 @@
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\GuzzleException;
 use Psr\Http\Message\ResponseInterface;
+use Signalise\PhpClient\enum\CallMethods;
 use Signalise\PhpClient\Exception\ResponseException;
 use Signalise\PhpClient\Traits\FailedResponse;
 
 class ApiClient
 {
     use FailedResponse;
 
+    private const SIGNALISE_POST_CONNECTS      = 'api/v1/connects';
+    private const SIGNALISE_GET_CONNECTS       = 'api/v1/connects';
+    private const SIGNALISE_POST_ORDER_HISTORY = 'api/v1/connects/{{connectId}}/history';
+    private const SIGNALISE_GET_HISTORY_STATUS = 'api/v1/connects/{{connectId}}/history/status';
+    private const CREATE_CONNECT_CONTENT_TYPE  = 'application/x-www-form-urlencoded';
+    private const ORDER_HISTORY_CONTENT_TYPE   = 'application/json';
+
     private Client $client;
 
     private string $apiKey;
 
     private string $apiUrl;
 
-    private const SIGNALISE_GET_CONNECTS       = 'api/v1/connects';
-    private const SIGNALISE_POST_ORDER_HISTORY = 'api/v1/connects/{{connectId}}/history';
-    private const SIGNALISE_GET_HISTORY_STATUS = 'api/v1/connects/{{connectId}}/history/status';
-
     public function __construct(Client $client)
     {
         $this->client = $client;
@@ -40,12 +44,12 @@ private function setUp(string $apiUrl, string $apiKey): void
         $this->apiKey = $apiKey;
     }
 
-    private function getHeaders(): array
+    private function getHeaders(string $contentType): array
     {
         return [
             'User-Agent' => 'ApiClient / PHP ' . phpversion(),
             'Accept' => 'application/json',
-            'Content-Type' => 'application/json',
+            'Content-Type' => $contentType,
             'Authorization' => sprintf('Bearer %s', $this->apiKey)
         ];
     }
@@ -59,20 +63,25 @@ private function createConnectIdUri(string $connectId, string $param): string
         );
     }
 
+    private function createUrl(string $call): string
+    {
+        return sprintf(
+            '%s/%s',
+            rtrim($this->apiUrl, '/'),
+            $call
+        );
+    }
+
     /**
      * @throws GuzzleException
      */
     private function get(string $call): ResponseInterface
     {
         return $this->client->request(
-            'GET',
-            sprintf(
-                '%s/%s',
-                rtrim($this->apiUrl, '/'),
-                $call
-            ),
+            CallMethods::GET_METHOD,
+            $this->createUrl($call),
             [
-                'headers' => $this->getHeaders()
+                'headers' => $this->getHeaders(self::ORDER_HISTORY_CONTENT_TYPE)
             ]
         );
     }
@@ -83,10 +92,10 @@ private function get(string $call): ResponseInterface
     private function post(string $serializedData, string $connectId): ResponseInterface
     {
         return $this->client->request(
-            'POST',
+            CallMethods::POST_METHOD,
             $this->createConnectIdUri($connectId, self::SIGNALISE_POST_ORDER_HISTORY),
             [
-                'headers' => $this->getHeaders(),
+                'headers' => $this->getHeaders(self::ORDER_HISTORY_CONTENT_TYPE),
                 'body' => $serializedData
             ]
         );
@@ -144,4 +153,31 @@ public function postOrderHistory(
 
         return json_decode($response->getBody()->getContents(), true);
     }
+
+    /**
+     * @throws GuzzleException|ResponseException
+     */
+    public function createConnect(
+        string $apiUrl,
+        string $apiKey,
+        array $formData
+    ): array {
+        $this->setUp($apiUrl, $apiKey);
+
+        $response = $this->client->request(
+            CallMethods::POST_METHOD,
+            $this->createUrl(self::SIGNALISE_POST_CONNECTS),
+            [
+                'headers' => $this->getHeaders(self::CREATE_CONNECT_CONTENT_TYPE),
+                'form_params' => [
+                    'name' => $formData['name'],
+                    'type' => $formData['type']
+                ]
+            ]
+        );
+
+        self::unableProcessResponse($response);
+
+        return json_decode($response->getBody()->getContents(), true);
+    }
 }

src/enum/CallMethods.php

@@ -0,0 +1,16 @@
+<?php
+
+/**
+ * Copyright Elgentos BV. All rights reserved.
+ * https://www.elgentos.nl/
+ */
+
+declare(strict_types=1);
+
+namespace Signalise\PhpClient\enum;
+
+abstract class CallMethods
+{
+    public const POST_METHOD = 'POST';
+    public const GET_METHOD  = 'GET';
+}

tests/Client/ApiClientTest.php

@@ -173,7 +173,7 @@ private function createPostClientMock(
                     ->invoke($subject, $connectId, self::SIGNALISE_POST_ORDER_HISTORY),
                 [
                     'headers' => $this->callPrivateFunction($subject, 'getHeaders')
-                        ->invoke($subject),
+                        ->invoke($subject, 'application/json'),
                     'body' => $data
                 ]
             )