Merge pull request #12 from tweet9ra/add_get_intergration_connection

add_get_intergration_connection

Author: ehunov

composer.json

@@ -26,7 +26,8 @@
         "doctrine/cache": "^1.8",
         "guzzlehttp/guzzle": "^6.3",
         "symfony/property-access": "^3.4 | ^4.0 | ^5.0",
-        "symfony/serializer": "^3.4 | ^4.0 | ^5.0"
+        "symfony/serializer": "^3.4 | ^4.0 | ^5.0",
+        "ext-json": "*"
     },
     "require-dev": {
         "phpunit/phpunit": "^8.5.12 | ^9.0"

src/V2/Dto/GetIntegrationConnectionResponse.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace Lamoda\OmsClient\V2\Dto;
+
+final class GetIntegrationConnectionResponse
+{
+    public const STATUS_SUCCESS = 'SUCCESS';
+    public const STATUS_REJECTED = 'REJECTED';
+
+    /**
+     * @var string
+     */
+    private $status;
+
+    /**
+     * @var string|null
+     */
+    private $omsConnection;
+
+    /**
+     * @var string|null
+     */
+    private $rejectionReason;
+
+    /**
+     * @param string $status
+     * @param string|null $omsConnection
+     * @param string|null $rejectionReason
+     */
+    public function __construct(string $status, ?string $omsConnection, ?string $rejectionReason)
+    {
+        $this->status = $status;
+        $this->omsConnection = $omsConnection;
+        $this->rejectionReason = $rejectionReason;
+    }
+
+    /**
+     * @return string
+     */
+    public function getStatus(): string
+    {
+        return $this->status;
+    }
+
+    /**
+     * @return string|null
+     */
+    public function getOmsConnection(): ?string
+    {
+        return $this->omsConnection;
+    }
+
+    /**
+     * @return string|null
+     */
+    public function getRejectionReason(): ?string
+    {
+        return $this->rejectionReason;
+    }
+}

src/V2/OmsApi.php

@@ -17,6 +17,7 @@
 use Lamoda\OmsClient\V2\Dto\CreateOrderForEmissionICResponse;
 use Lamoda\OmsClient\V2\Dto\GetICBufferStatusResponse;
 use Lamoda\OmsClient\V2\Dto\GetICsFromOrderResponse;
+use Lamoda\OmsClient\V2\Dto\GetIntegrationConnectionResponse;
 use Lamoda\OmsClient\V2\Dto\PingResponse;
 use Lamoda\OmsClient\V2\Signer\SignerInterface;
 
@@ -124,6 +125,22 @@ public function closeICArray(
         return $this->serializer->deserialize(CloseICArrayResponse::class, $result);
     }
 
+    public function getIntegrationConnection(string $address, string $omsId, string $registrationKey, SignerInterface $signer = null): GetIntegrationConnectionResponse {
+        $body = json_encode(['address' => $address]);
+
+        $headers = [
+            'X-RegistrationKey' => $registrationKey
+        ];
+        $headers = $this->appendSignatureHeader($headers, $body, $signer);
+
+        $result = $this->request(null, 'POST', '/api/v2/integration/connection', [
+            'omsId' => $omsId,
+        ], $body, $headers);
+
+        /* @noinspection PhpIncompatibleReturnTypeInspection */
+        return $this->serializer->deserialize(GetIntegrationConnectionResponse::class, $result);
+    }
+
     public function ping(Extension $extension, string $token, string $omsId): PingResponse
     {
         $url = sprintf('/api/v2/%s/ping', (string)$extension);
@@ -137,19 +154,21 @@ public function ping(Extension $extension, string $token, string $omsId): PingRe
      * @throws OmsRequestErrorException
      */
     private function request(
-        string $token,
+        ?string $token,
         string $method,
         string $uri,
         array $query = [],
         $body = null,
         $headers = []
-    ): string {
+    ): string
+    {
+        $headers['Content-Type'] = 'application/json';
+        if ($token != null) {
+            $headers['clientToken'] = $token;
+        }
         $options = [
             RequestOptions::BODY => $body,
-            RequestOptions::HEADERS => array_merge($headers, [
-                'Content-Type' => 'application/json',
-                'clientToken' => $token,
-            ]),
+            RequestOptions::HEADERS => $headers,
             RequestOptions::QUERY => $query,
             RequestOptions::HTTP_ERRORS => true,
         ];

tests/V2/OmsApiTest.php

@@ -18,6 +18,7 @@
 use Lamoda\OmsClient\V2\Dto\CreateOrderForEmissionICResponse;
 use Lamoda\OmsClient\V2\Dto\GetICBufferStatusResponse;
 use Lamoda\OmsClient\V2\Dto\GetICsFromOrderResponse;
+use Lamoda\OmsClient\V2\Dto\GetIntegrationConnectionResponse;
 use Lamoda\OmsClient\V2\Dto\PingResponse;
 use Lamoda\OmsClient\V2\Extension;
 use Lamoda\OmsClient\V2\OmsApi;
@@ -460,4 +461,55 @@ public function testPing(): void
         $this->assertEquals($expectedResult, $result);
     }
 
+    public function testGetIntegrationConnection(): void
+    {
+        $this->client->expects($this->once())
+            ->method('request')
+            ->with(
+                'POST',
+                'api/v2/integration/connection',
+                [
+                    RequestOptions::BODY => $requestBody = json_encode([
+                        'address' => $address = 'Kremlin 1, Moscow, Russia'
+                    ]),
+                    RequestOptions::HEADERS => [
+                        'X-RegistrationKey' => $registrationKey = 'registration-key-received-from-ismp-support',
+                        'X-Signature' => $signature = 'signature',
+                        'Content-Type' => 'application/json',
+                    ],
+                    RequestOptions::QUERY => [
+                        'omsId' => $omsId = 'oms-id-string',
+                    ],
+                    RequestOptions::HTTP_ERRORS => true,
+                ]
+            )
+            ->willReturn(
+                (new Response())
+                    ->withBody(stream_for(self::API_RESPONSE))
+            );
+
+        $expectedResult = new GetIntegrationConnectionResponse(GetIntegrationConnectionResponse::STATUS_SUCCESS, $address, null);
+        $this->serializer->expects($this->once())
+            ->method('deserialize')
+            ->with(
+                GetIntegrationConnectionResponse::class,
+                self::API_RESPONSE
+            )
+            ->willReturn($expectedResult);
+
+
+        $signer = $this->createMock(SignerInterface::class);
+        $signer->method('sign')
+            ->with($requestBody)
+            ->willReturn($signature);
+
+        $result = $this->api->getIntegrationConnection(
+            $address,
+            $omsId,
+            $registrationKey,
+            $signer
+        );
+
+        $this->assertEquals($expectedResult, $result);
+    }
 }