[11.x] Fix: Custom Exceptions with Multiple Arguments does not properly rein… (#54705)

* Fix: Custom Exceptions with Multiple Arguments does not properly reinstantiate with Concurrency::run() 54500

* Import Class added

* StyleCI issue fixed

* Integration Test Case Added

* StyleCI issue fixed

* StyleCI issue fixed

* Test Cases function renamed

* Process Driver Updated for Default Exception

* Style CI Issue fixed

* Remove Unused class

* formatting

---------

Co-authored-by: Pandi Selvam <pandi.selvam@terrificminds.com>
Co-authored-by: Taylor Otwell <taylor@laravel.com>

Author: 3 people

src/Illuminate/Concurrency/Console/InvokeSerializedClosureCommand.php

@@ -3,6 +3,7 @@
 namespace Illuminate\Concurrency\Console;
 
 use Illuminate\Console\Command;
+use ReflectionClass;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Throwable;
 
@@ -51,12 +52,27 @@ public function handle()
         } catch (Throwable $e) {
             report($e);
 
+            $reflection = new ReflectionClass($e);
+            $constructor = $reflection->getConstructor();
+            $parameters = [];
+
+            if ($constructor) {
+                $declaringClass = $constructor->getDeclaringClass()->getName();
+
+                if ($declaringClass === $reflection->getName()) {
+                    foreach ($constructor->getParameters() as $parameter) {
+                        $parameters[$parameter->name] = $e->{$parameter->name} ?? null;
+                    }
+                }
+            }
+
             $this->output->write(json_encode([
                 'successful' => false,
                 'exception' => get_class($e),
                 'message' => $e->getMessage(),
                 'file' => $e->getFile(),
                 'line' => $e->getLine(),
+                'parameters' => $parameters,
             ]));
         }
     }

src/Illuminate/Concurrency/ProcessDriver.php

@@ -48,7 +48,9 @@ public function run(Closure|array $tasks): array
 
             if (! $result['successful']) {
                 throw new $result['exception'](
-                    $result['message']
+                    ...(! empty(array_filter($result['parameters']))
+                        ? $result['parameters']
+                        : [$result['message']])
                 );
             }
 

tests/Integration/Concurrency/ConcurrencyTest.php

@@ -2,9 +2,11 @@
 
 namespace Illuminate\Tests\Integration\Concurrency;
 
+use Exception;
 use Illuminate\Concurrency\ProcessDriver;
 use Illuminate\Foundation\Application;
 use Illuminate\Process\Factory as ProcessFactory;
+use Illuminate\Support\Facades\Concurrency;
 use Orchestra\Testbench\TestCase;
 use PHPUnit\Framework\Attributes\RequiresOperatingSystem;
 
@@ -49,4 +51,55 @@ public function testRunHandlerProcessErrorCode()
             fn () => exit(1),
         ]);
     }
+
+    public function testRunHandlerProcessErrorWithDefaultExceptionWithoutParam()
+    {
+        $this->expectException(\Exception::class);
+        $this->expectExceptionMessage('This is a different exception');
+
+        Concurrency::run([
+            fn () => throw new Exception(
+                'This is a different exception',
+            ),
+        ]);
+    }
+
+    public function testRunHandlerProcessErrorWithCustomExceptionWithoutParam()
+    {
+        $this->expectException(ExceptionWithoutParam::class);
+        $this->expectExceptionMessage('Test');
+        Concurrency::run([
+            fn () => throw new ExceptionWithoutParam('Test'),
+        ]);
+    }
+
+    public function testRunHandlerProcessErrorWithCustomExceptionWithParam()
+    {
+        $this->expectException(ExceptionWithParam::class);
+        $this->expectExceptionMessage('API request to https://api.example.com failed with status 400 Bad Request');
+        Concurrency::run([
+            fn () => throw new ExceptionWithParam(
+                'https://api.example.com',
+                400,
+                'Bad Request',
+                'Invalid payload'
+            ),
+        ]);
+    }
+}
+
+class ExceptionWithoutParam extends Exception
+{
+}
+
+class ExceptionWithParam extends Exception
+{
+    public function __construct(
+        public string $uri,
+        public int $statusCode,
+        public string $reason,
+        public string|array $responseBody = '',
+    ) {
+        parent::__construct("API request to {$uri} failed with status $statusCode $reason");
+    }
 }