Merge pull request #2 from apacheborys/bug/file-transport-undefined-index-in-howManyTries-method

Bug/file transport undefined index in how many tries method

Author: apacheborys

src/BasicExecutor/CommandExecutor.php

@@ -6,6 +6,7 @@
 use ApacheBorys\Retry\Entity\Config;
 use ApacheBorys\Retry\Entity\Message;
 use ApacheBorys\Retry\Interfaces\Executor;
+use Throwable;
 
 class CommandExecutor implements Executor
 {
@@ -67,7 +68,7 @@ public function handle(Message $message): bool
             }
 
             $returnValue = proc_close($process);
-        } catch (\Throwable $e) {
+        } catch (Throwable $e) {
             $this->rollbackEnvironmentVariables();
 
             throw $e;
@@ -79,26 +80,30 @@ public function handle(Message $message): bool
         return $returnValue !== -1;
     }
 
-    public function compilePayload(\Throwable $exception, Config $config): array
+    public function compilePayload(Throwable $exception, Config $config): array
     {
         $result = [];
 
         foreach ($this->arguments as $argName => $argRegExp) {
-            preg_match($argRegExp, $exception->getMessage(), $matches);
-            if ($matches && isset($matches[0])) {
-                $result[$argName] = $matches[0];
+            $matches = [];
+
+            try {
+                preg_match($argRegExp, $exception->getMessage(), $matches);
+            } catch (Throwable $e) {
             }
+
+            $result[$argName] = count($matches) > 0 ? $matches[0] : $argRegExp;
         }
 
         return $result;
     }
 
-    public function getCorrelationId(\Throwable $exception, Config $config): string
+    public function getCorrelationId(Throwable $exception, Config $config): string
     {
         $id = getenv(self::ALIAS_FOR_CORRELATION_ID);
 
         if (!$id) {
-            $config->getTransport()->getNextId($exception, $config);
+            $id = $config->getTransport()->getNextId($exception, $config);
         }
 
         return (string) $id;

src/BasicExecutor/HttpExecutor.php

@@ -97,7 +97,7 @@ public function getCorrelationId(\Throwable $exception, Config $config): string
         $id = $_SERVER['HTTP_' . self::CID] ?? apache_request_headers()[self::CID] ?? null;
 
         if (!$id) {
-            $config->getTransport()->getNextId($exception, $config);
+            $id = $config->getTransport()->getNextId($exception, $config);
         }
 
         return (string) $id;

src/BasicTransport/FileTransport.php

@@ -133,7 +133,7 @@ public function howManyTriesWasBefore(\Throwable $exception, Config $config): in
 
         $correlationId = $config->getExecutor()->getCorrelationId($exception, $config);
 
-        $keysFromIndex = array_keys($this->fileIndexPosition[$correlationId]);
+        $keysFromIndex = array_keys($this->fileIndexPosition[$correlationId] ?? []);
 
         return isset($this->fileIndexPosition[$correlationId]) && count($keysFromIndex) > 0 ? max($keysFromIndex) : 0;
     }