Merge branch 'main' into introduce-migrator

Author: apacheborys

src/BasicExecutor/CommandExecutor.php

@@ -7,6 +7,7 @@
 use ApacheBorys\Retry\Entity\Message;
 use ApacheBorys\Retry\Interfaces\Executor;
 use Psr\Log\LoggerInterface;
+use Throwable;
 
 class CommandExecutor implements Executor
 {
@@ -75,8 +76,8 @@ public function handle(Message $message): bool
                 sleep(1);
             }
 
-            proc_close($process);
-        } catch (\Throwable $e) {
+            $returnValue = proc_close($process);
+        } catch (Throwable $e) {
             $this->rollbackEnvironmentVariables();
             if ($this->logger) {
                 $this->logger->debug(
@@ -96,26 +97,30 @@ public function handle(Message $message): bool
         return true;
     }
 
-    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

@@ -142,7 +142,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;
     }