fixes states

Author: goshasafonov

src/Actions/RunProcessAction.php

@@ -52,16 +52,16 @@ public function execute(Process $model): Process
 
         Bus::batch([$jobs->toArray()])
         ->before(function (Batch $batch) use ($action) {
-            $action->execute(ProcessState::Started, $batch);
+            $action->execute(Config::getProcessStateClass(ProcessState::class)::Started, $batch);
         })
         ->progress(function (Batch $batch) use ($action) {
-            $action->execute(ProcessState::Processing, $batch);
+            $action->execute(Config::getProcessStateClass(ProcessState::class)::Processing, $batch);
         })
         ->catch(function (Batch $batch, Throwable $e) use ($action) {
-            $action->execute(ProcessState::Failed, $batch, $e);
+            $action->execute(Config::getProcessStateClass(ProcessState::class)::Failed, $batch, $e);
         })
         ->finally(function (Batch $batch) use ($action) {
-            $action->execute(ProcessState::Finished, $batch);
+            $action->execute(Config::getProcessStateClass(ProcessState::class)::Finished, $batch);
         })
         ->onConnection(Config::getQueueConnection())
         ->onQueue(Config::getQueueName())

src/Handlers/ProcessEventHandler.php

@@ -30,7 +30,8 @@ public function before(JobProcessing $event): void
             return;
         }
 
-        Config::getUpdateProcessStageAction($job->getStage())->execute(StageState::Started);
+        Config::getUpdateProcessStageAction($job->getStage())
+            ->execute(Config::getStageStateClass(StageState::class)::Started);
     }
 
     public function after(JobProcessed $event): void
@@ -47,7 +48,8 @@ public function after(JobProcessed $event): void
             return;
         }
 
-        Config::getUpdateProcessStageAction($job->getStage())->execute(StageState::Finished);
+        Config::getUpdateProcessStageAction($job->getStage())
+            ->execute(Config::getStageStateClass(StageState::class)::Finished);
     }
 
     public function failing(JobFailed $event): void
@@ -64,6 +66,7 @@ public function failing(JobFailed $event): void
             return;
         }
 
-        Config::getUpdateProcessStageAction($job->getStage())->execute(StageState::Failed);
+        Config::getUpdateProcessStageAction($job->getStage())
+            ->execute(Config::getStageStateClass(StageState::class)::Failed);
     }
 }

src/Handlers/StageEventHandler.php

@@ -29,7 +29,8 @@ public function before(JobProcessing $event): void
             return;
         }
 
-        Config::getUpdateProcessStageAction($job->getStage())->execute(StageState::Started, $event->job);
+        Config::getUpdateProcessStageAction($job->getStage())
+            ->execute(Config::getStageStateClass(StageState::class)::Started, $event->job);
     }
 
     public function after(JobProcessed $event): void
@@ -45,7 +46,8 @@ public function after(JobProcessed $event): void
             return;
         }
 
-        Config::getUpdateProcessStageAction($job->getStage())->execute(StageState::Finished, $event->job);
+        Config::getUpdateProcessStageAction($job->getStage())
+            ->execute(Config::getStageStateClass(StageState::class)::Finished, $event->job);
     }
 
     public function failing(JobFailed $event): void
@@ -62,7 +64,7 @@ public function failing(JobFailed $event): void
         }
 
         Config::getUpdateProcessStageAction($job->getStage())->execute(
-            StageState::Failed,
+            Config::getStageStateClass(StageState::class)::Failed,
             $event->job,
             $event->exception
         );

src/Jobs/ProcessStageJob.php

@@ -42,15 +42,15 @@ public function handle(): void
             UpdateProcessStageAction::class
         );
 
-        $this->stage = $action->execute(StageState::Processing, $this->job);
+        $this->stage = $action->execute(Config::getStageStateClass(StageState::class)::Processing, $this->job);
 
         $stage
             ->setStage($this->stage)
             ->setProcess($this->process)
             ->setProcessable($this->processable)
             ->execute();
 
-        $this->stage = $action->execute(StageState::Processed, $this->job);
+        $this->stage = $action->execute(Config::getStageStateClass(StageState::class)::Processed, $this->job);
     }
 
     public function getStage(): Stage