Fixed store action and added support for 201 responses

induxx · Nov 12, 2024 · 1e065a8 · 1e065a8
1 parent 1aae72e
commit 1e065a8
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 6 deletions.
diff --git a/src/Component/Action/StoreAction.php b/src/Component/Action/StoreAction.php
@@ -54,15 +54,17 @@ public function init(): void
             if ([] !== $falseAction) {
                 $this->falseActionProcessor = $this->configuration->generateActionProcessor($falseAction);
             }
-            $this->setOption('init', true);            
+            $this->setOption('init', true);
         }
     }
 
     public function apply(array $item): array
     {
         $this->init();
         $entity = $this->getOption('entity');
-        $identifier =  $entity.':'.$item['identifier']; // $this->getOption('identifier');
+        $identifierKey = $this->getOption('identifier');
+
+        $identifier =  $entity.':'.$item[$identifierKey];
         $event = $this->getOption('event');
         if (empty($identifier) || empty($event)) {
             return $item;
@@ -109,7 +111,13 @@ public function apply(array $item): array
                 if ([] !== $falseAction) {
                     $item = $this->falseActionProcessor->process($item);
                 }
+
+                $this->storeProduct($identifier);
+
+                return $item;
             }
+
+            return [];
         }
 
         return $item;

diff --git a/src/Component/Akeneo/Client/ApiWriter.php b/src/Component/Akeneo/Client/ApiWriter.php
@@ -83,7 +83,7 @@ private function doWrite(array $data)
             $response = $this->execute($data);
         }
 
-        if (!in_array($response->getCode(),  [200, 204])) {
+        if (!in_array($response->getCode(),  [200, 201, 204])) {
             throw new InvalidItemException('API exception', ['message' => $response->getContent()], $data);
         }
 

diff --git a/src/Component/Common/Client/BasicAuthApiClient.php b/src/Component/Common/Client/BasicAuthApiClient.php
@@ -42,13 +42,13 @@ public function sendRequest($method, $endpoint, $data = null, $headers = []): vo
         $authHeader = 'Authorization: Basic ' . base64_encode($this->username . ':' . $this->password);
         $headers[] = $authHeader;
 
-        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
-
         if ($method === 'POST' || $method === 'PUT' || $method === 'PATCH') {
             curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
             $headers[] = 'Content-Type: application/json';
         }
 
+        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
+
         $this->response = json_decode(curl_exec($curl), true);
         $this->status = \curl_getinfo($curl, CURLINFO_HTTP_CODE);
 
@@ -69,7 +69,7 @@ public function getResponse(): ApiResponse
         if (is_string($this->response)) {
             $response = new ApiResponse($this->status, null, $this->response);
         }
-        if (in_array($this->status, [200, 204]) && !$this->response) {
+        if (in_array($this->status, [200, 201, 204]) && !$this->response) {
             $response = ApiResponse::create([], $this->status);
         }