Merge pull request #17 from resslinger/patch-1

add error handling for short write error
repat · Jan 20, 2022 · 43ce455 · 43ce455
2 parents 3e7a5d7 + 76a7d63
commit 43ce455
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/PlentymarketsRestClient/PlentymarketsRestClient.php b/src/PlentymarketsRestClient/PlentymarketsRestClient.php
@@ -18,6 +18,9 @@ class PlentymarketsRestClient
     const WAIT_ERROR_SHORT_PERIOD_READ_LIMIT = 5;
     const ERROR_SHORT_PERIOD_READ_LIMIT = 'short period read limit reached';
 
+    const WAIT_ERROR_SHORT_PERIOD_WRITE_LIMIT = 10;
+    const ERROR_SHORT_PERIOD_WRITE_LIMIT = 'short period write limit reached';
+
     const THROTTLING_PREFIX_LONG_PERIOD = 'X-Plenty-Global-Long-Period';
     const THROTTLING_PREFIX_SHORT_PERIOD = 'X-Plenty-Global-Short-Period';
     const THROTTLING_PREFIX_ROUTE = 'X-Plenty-Route';
@@ -90,10 +93,13 @@ public function singleCall($method, $path, $params = [])
         } catch (\Exception $e) {
 
             // For a better Plentymarkets exception handling. Sometimes the limit is not correct
+            // TODO possible handle recursion errors
             if (stripos($e->getMessage(), self::ERROR_SHORT_PERIOD_READ_LIMIT) !== false) {
                 sleep(self::WAIT_ERROR_SHORT_PERIOD_READ_LIMIT);
                 $this->singleCall($method, $path, $params);
-                // TODO possible handle recursion errors
+            } elseif (stripos($e->getMessage(), self::ERROR_SHORT_PERIOD_WRITE_LIMIT) !== false) {
+                sleep(self::WAIT_ERROR_SHORT_PERIOD_WRITE_LIMIT);
+                $this->singleCall($method, $path, $params);
             }
 
             if ($this->handleExceptions === true) {