Merge pull request #5 from zimmo-be/ME-125

ME-125: Add updatePropertyPublicationForBroker
zimmo-be · May 27, 2024 · 308d349 · 308d349
2 parents 586707e + bd3f7ce
commit 308d349
Show file tree

Hide file tree

Showing 6 changed files with 95 additions and 10 deletions.
diff --git a/composer.json b/composer.json
@@ -34,6 +34,9 @@
     }
   },
   "config": {
-    "sort-packages": true
+    "sort-packages": true,
+    "allow-plugins": {
+      "dealerdirect/phpcodesniffer-composer-installer": true
+    }
   }
 }
diff --git a/src/Client.php b/src/Client.php
@@ -10,22 +10,28 @@
 use Psr\Http\Client\ClientInterface;
 use Psr\Http\Message\RequestFactoryInterface;
 use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\StreamFactoryInterface;
+use RuntimeException;
 
+use function assert;
 use function http_build_query;
 use function is_array;
 use function is_string;
+use function json_encode;
 
 class Client
 {
     protected ResponseEvaluator $responseEvaluator;
     private ClientInterface $httpClient;
     private RequestFactoryInterface $requestFactory;
+    private ?StreamFactoryInterface $streamFactory;
 
-    public function __construct(ClientInterface $httpClient, RequestFactoryInterface $requestFactory, ResponseEvaluator $responseEvaluator)
+    public function __construct(ClientInterface $httpClient, RequestFactoryInterface $requestFactory, ResponseEvaluator $responseEvaluator, ?StreamFactoryInterface $streamFactory = null)
     {
         $this->httpClient        = $httpClient;
         $this->requestFactory    = $requestFactory;
         $this->responseEvaluator = $responseEvaluator;
+        $this->streamFactory     = $streamFactory;
     }
 
     /**
@@ -128,6 +134,26 @@ public function getPropertyForBroker(string $brokerId, int $propertyId, AccessTo
         return $evaluatedResponse;
     }
 
+    public function updatePropertyPublicationForBroker(
+        string $brokerId,
+        int $propertyId,
+        string $status,
+        ?string $link,
+        AccessToken $accessToken
+    ): void {
+        $response = $this->sendPutCall(
+            '/api/brokers/' . $brokerId . '/real-estate/properties/' . $propertyId . '/publication',
+            $this->getAuthorizationHeader($accessToken->getAccessToken()),
+            [],
+            [
+                'status' => $status,
+                'link'   => $link,
+            ]
+        );
+
+        $this->responseEvaluator->evaluateResponse($response);
+    }
+
     /**
      * @return mixed[]
      *
@@ -200,18 +226,48 @@ private function sendGetCall(string $uri, array $headers = [], array $queryParam
 
     /**
      * @param array<string, string> $headers
+     * @param string[]              $queryParams
      *
      * @throws ClientExceptionInterface
      */
-    private function send(string $method, string $uri, array $headers = []): ResponseInterface
+    private function sendPutCall(string $uri, array $headers = [], array $queryParams = [], mixed $content = null): ResponseInterface
+    {
+        return $this->send(
+            'PUT',
+            $this->createUrl($uri, $queryParams),
+            $headers,
+            $content
+        );
+    }
+
+    /**
+     * @param array<string, string> $headers
+     *
+     * @throws ClientExceptionInterface
+     */
+    private function send(string $method, string $uri, array $headers = [], mixed $content = null): ResponseInterface
     {
         $request = $this->requestFactory->createRequest($method, $uri)
-            ->withHeader('Content-Type', 'application/problem+json');
+            ->withHeader('Content-Type', 'application/json');
 
         foreach ($headers as $headerName => $headerValue) {
             $request = $request->withHeader($headerName, $headerValue);
         }
 
+        if ($content) {
+            if (! $this->streamFactory) {
+                throw new RuntimeException('StreamFactory is required to send content');
+            }
+
+            $jsonContent = json_encode($content);
+            assert(is_string($jsonContent));
+
+            $stream = $this->streamFactory->createStream();
+            $stream->write($jsonContent);
+
+            $request = $request->withBody($stream);
+        }
+
         return $this->httpClient->sendRequest($request);
     }
 

diff --git a/src/JsonResponseEvaluator.php b/src/JsonResponseEvaluator.php
@@ -36,6 +36,9 @@ public function evaluateResponse(ResponseInterface $response): mixed
             case StatusCode::OK:
                 return $this->handleResponseOk($response);
 
+            case StatusCode::NO_CONTENT:
+                return null;
+
             case StatusCode::BAD_REQUEST:
                 $this->handleResponseBadRequest($response);
                 break;

diff --git a/src/MiepClient.php b/src/MiepClient.php
@@ -116,6 +116,17 @@ public function getPropertyForBroker(string $brokerId, int $propertyId): array
         }
     }
 
+    public function updatePropertyPublicationForBroker(string $brokerId, int $propertyId, string $status, ?string $link): void
+    {
+        try {
+            $this->client->updatePropertyPublicationForBroker($brokerId, $propertyId, $status, $link, $this->getAccessToken());
+        } catch (Unauthorized $e) {
+            $this->resetAccessToken();
+
+            $this->client->updatePropertyPublicationForBroker($brokerId, $propertyId, $status, $link, $this->getAccessToken());
+        }
+    }
+
     /**
      * @return mixed[]
      *

diff --git a/src/PublicationStatus.php b/src/PublicationStatus.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace MaxImmo\ExternalParties;
+
+interface PublicationStatus
+{
+    public const CREATED = 'CREATED';
+    public const UPDATED = 'UPDATED';
+    public const REMOVED = 'REMOVED';
+}
diff --git a/tests/ClientTest.php b/tests/ClientTest.php
@@ -53,7 +53,7 @@ public function testGetBrokersShouldPerformRequestUsingCorrectParameters(): void
             ->expects($this->exactly(2))
             ->method('withHeader')
             ->withConsecutive(
-                ['Content-Type', 'application/problem+json'],
+                ['Content-Type', 'application/json'],
                 ['Authorization', 'Bearer access_token_test'],
             )
             ->willReturn($this->request);
@@ -77,7 +77,7 @@ public function testGetRealEstateListForBrokerShouldPerformRequestUsingCorrectPa
             ->expects($this->exactly(2))
             ->method('withHeader')
             ->withConsecutive(
-                ['Content-Type', 'application/problem+json'],
+                ['Content-Type', 'application/json'],
                 ['Authorization', 'Bearer access_token_test'],
             )
             ->willReturn($this->request);
@@ -101,7 +101,7 @@ public function testGetPropertyForBrokerShouldPerformRequestUsingCorrectParamete
             ->expects($this->exactly(2))
             ->method('withHeader')
             ->withConsecutive(
-                ['Content-Type', 'application/problem+json'],
+                ['Content-Type', 'application/json'],
                 ['Authorization', 'Bearer access_token_test'],
             )
             ->willReturn($this->request);
@@ -125,7 +125,7 @@ public function testGetProjectForBrokerShouldPerformRequestUsingCorrectParameter
             ->expects($this->exactly(2))
             ->method('withHeader')
             ->withConsecutive(
-                ['Content-Type', 'application/problem+json'],
+                ['Content-Type', 'application/json'],
                 ['Authorization', 'Bearer access_token_test'],
             )
             ->willReturn($this->request);
@@ -150,7 +150,7 @@ public function testGetAccessTokenShouldPerformRequestUsingCorrectParameters():
             ->expects($this->exactly(2))
             ->method('withHeader')
             ->withConsecutive(
-                ['Content-Type', 'application/problem+json'],
+                ['Content-Type', 'application/json'],
                 ['Authorization', 'Basic authorization'],
             )
             ->willReturn($this->request);
@@ -170,7 +170,7 @@ public function testGetAccessTokenShouldReturnAccessTokenIfExists(): void
             ->expects($this->exactly(2))
             ->method('withHeader')
             ->withConsecutive(
-                ['Content-Type', 'application/problem+json'],
+                ['Content-Type', 'application/json'],
                 ['Authorization', 'Basic authorization'],
             )
             ->willReturn($this->request);