exception to error

Author: goshasafonov

src/Actions/UpdateProcessStageAction.php

@@ -2,10 +2,12 @@
 
 namespace Yuges\Processable\Actions;
 
+use Throwable;
 use Carbon\Carbon;
 use Yuges\Processable\Models\Stage;
 use Illuminate\Contracts\Queue\Job;
 use Yuges\Processable\Enums\StageState;
+use Yuges\Processable\Error\StageError;
 use Yuges\Processable\Interfaces\StageState as StageStateInterface;
 
 class UpdateProcessStageAction
@@ -20,14 +22,23 @@ public static function create(Stage $stage): self
         return new static($stage);
     }
 
-    public function execute(StageStateInterface $state, ?Job $job = null): Stage
+    public function execute(StageStateInterface $state, ?Job $job = null, ?Throwable $e = null): Stage
     {
         $attributes = [
             'state' => $state,
             'job_id' => $job?->getJobId() ?? $this->stage->job_id,
             'job_uuid' => $job?->uuid() ?? $this->stage->job_uuid,
         ];
 
+        if ($e) {
+            $attributes['error'] = new StageError(
+                $e->getMessage(),
+                $e->getCode(),
+                $e->getFile(),
+                $e->getLine(),
+            );
+        }
+
         match ($state->value) {
             StageState::Started->value => $attributes['started_at'] = Carbon::now(),
             StageState::Finished->value => $attributes['finished_at'] = Carbon::now(),

src/Handlers/StageEventHandler.php

@@ -18,8 +18,7 @@ public static function create(): self
 
     public function before(JobProcessing $event): void
     {
-        if ($event->job->resolveName() != Config::getProcessStageJobClass(ProcessStageJob::class))
-        {
+        if ($event->job->resolveName() != Config::getProcessStageJobClass(ProcessStageJob::class)) {
             return;
         }
 
@@ -35,8 +34,7 @@ public function before(JobProcessing $event): void
 
     public function after(JobProcessed $event): void
     {
-        if ($event->job->resolveName() != Config::getProcessStageJobClass(ProcessStageJob::class))
-        {
+        if ($event->job->resolveName() != Config::getProcessStageJobClass(ProcessStageJob::class)) {
             return;
         }
 
@@ -52,8 +50,7 @@ public function after(JobProcessed $event): void
 
     public function failing(JobFailed $event): void
     {
-        if ($event->job->resolveName() != Config::getProcessStageJobClass(ProcessStageJob::class))
-        {
+        if ($event->job->resolveName() != Config::getProcessStageJobClass(ProcessStageJob::class)) {
             return;
         }
 
@@ -64,6 +61,10 @@ public function failing(JobFailed $event): void
             return;
         }
 
-        Config::getUpdateProcessStageAction($job->getStage())->execute(StageState::Failed, $event->job);
+        Config::getUpdateProcessStageAction($job->getStage())->execute(
+            StageState::Failed,
+            $event->job,
+            $event->exception
+        );
     }
 }