workflow exception wraps error, provides access

src/Exceptions/WorkflowException.php

@@ -0,0 +1,53 @@
+<?php
+
+/*
+ * This file is part of Chevere.
+ *
+ * (c) Rodolfo Berrios <rodolfo@chevere.org>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Chevere\Workflow\Exceptions;
+
+use Chevere\Workflow\Interfaces\JobInterface;
+use Exception;
+use Throwable;
+
+/**
+ * Exception thrown when validating Workflow runtime.
+ */
+final class WorkflowException extends Exception
+{
+    /**
+     * The job name that thrown the exception.
+     */
+    public readonly string $name;
+
+    /**
+     * The job that thrown the exception.
+     */
+    public readonly JobInterface $job;
+
+    /**
+     * The exception thrown by the job.
+     */
+    public readonly Throwable $throwable;
+
+    public function __construct(
+        string $name,
+        JobInterface $job,
+        string $message,
+        Throwable $throwable,
+    ) {
+        parent::__construct(message: $message, previous: $throwable);
+        $this->name = $name;
+        $this->job = $job;
+        $this->throwable = $throwable;
+        $this->file = $job->caller()->file();
+        $this->line = $job->caller()->line();
+    }
+}

src/Runner.php

@@ -15,6 +15,7 @@
 
 use Amp\Parallel\Worker\Execution;
 use Chevere\Parameter\Interfaces\CastInterface;
+use Chevere\Workflow\Exceptions\WorkflowException;
 use Chevere\Workflow\Interfaces\JobInterface;
 use Chevere\Workflow\Interfaces\ResponseReferenceInterface;
 use Chevere\Workflow\Interfaces\RunInterface;
@@ -91,14 +92,15 @@ public function withRunJob(string $name): RunnerInterface
         try {
             $response = cast($action(...$arguments));
         } catch (Throwable $e) {
-            throw new $e(
-                previous: $e->getPrevious(),
-                code: $e->getCode(),
+            throw new WorkflowException(
+                name: $name,
+                job: $job,
+                throwable: $e,
                 message: (string) message(
                     '%message% at job `%name%` declared in %fileLine%',
                     name: $name,
                     message: $e->getMessage(),
-                    fileLine: $job->caller(),
+                    fileLine: strval($job->caller()),
                 )
             );
         }