Merge pull request #18 from neighborhoods/feature/KOJO-36

Create a formatter for the \Throwable type and use when jobs Panic

src/Process/Job.php

@@ -4,10 +4,10 @@
 namespace Neighborhoods\Kojo\Process;
 
 use Neighborhoods\Kojo\Foreman;
-use Neighborhoods\Kojo\Scheduler;
 use Neighborhoods\Kojo\Maintainer;
-use Neighborhoods\Kojo\Selector;
 use Neighborhoods\Kojo\Process;
+use Neighborhoods\Kojo\Scheduler;
+use Neighborhoods\Kojo\Selector;
 
 class Job extends Forked implements JobInterface
 {
@@ -17,20 +17,21 @@ class Job extends Forked implements JobInterface
     use Selector\AwareTrait;
     use Process\Pool\Factory\AwareTrait;
 
-    protected function _run(): Forked
+    protected function _run() : Forked
     {
-        try{
+        try {
             $this->_getSelector()->setProcess($this);
             $this->_getMaintainer()->rescheduleCrashedJobs();
             $this->_getScheduler()->scheduleStaticJobs();
             $this->_getMaintainer()->updatePendingJobs();
             $this->_getMaintainer()->deleteCompletedJobs();
             $this->_getForeman()->workWorker();
-        }catch(\Throwable $throwable){
-            $this->_getLogger()->critical($throwable->getMessage());
+        } catch (\Throwable $throwable) {
+            $message = $this->_getLogger()->getLogFormatter()->getFormattedThrowableMessage($throwable);
+            $this->_getLogger()->critical($message);
             $this->_setOrReplaceExitCode(255);
         }
 
         return $this;
     }
-}
+}

src/Process/Pool/Logger/Formatter.php

@@ -27,6 +27,20 @@ public function getFormattedMessage(MessageInterface $message) : string
         }
     }
 
+    public function getFormattedThrowableMessage(\Throwable $throwable): string
+    {
+        if ($throwable->getPrevious()) {
+            $previousType = get_class($throwable->getPrevious());
+            $previousMessage = $throwable->getPrevious()->getMessage();
+            $previousMessage = "{$previousType}: {$previousMessage}";
+            $message = implode(' ', [$throwable->getMessage(), $previousMessage]);
+        } else {
+            $message = $throwable->getMessage();
+        }
+
+        return $message;
+    }
+
     protected function formatPipes(MessageInterface $message) : string
     {
         $processIdPaddingLength = $this->getProcessIdPadding();

src/Process/Pool/Logger/FormatterInterface.php

@@ -14,4 +14,6 @@ public function setProcessPathPadding(int $processPathPadding) : FormatterInterf
     public function setProcessIdPadding(int $processIdPadding) : FormatterInterface;
 
     public function setLogFormat(string $logFormat);
+
+    public function getFormattedThrowableMessage(\Throwable $throwable) : string;
 }