Add tests for InvokeSerializedClosureCommand (#55281)

* Add tests for InvokeSerializedClosureCommand

* Fix code style issues in InvokeSerializedClosureCommandTest

---------

Co-authored-by: AmirHossein Fallah <amirhossein.fallah@arvancloud.ir>

Author: Amirhf1

tests/Integration/Concurrency/Console/InvokeSerializedClosureCommandTest.php

@@ -0,0 +1,141 @@
+<?php
+
+namespace Illuminate\Tests\Integration\Concurrency\Console;
+
+use Illuminate\Concurrency\Console\InvokeSerializedClosureCommand;
+use Illuminate\Contracts\Console\Kernel;
+use Illuminate\Support\Facades\Artisan;
+use Laravel\SerializableClosure\SerializableClosure;
+use Orchestra\Testbench\TestCase;
+use RuntimeException;
+use Symfony\Component\Console\Output\BufferedOutput;
+
+class CustomParameterException extends RuntimeException
+{
+    public function __construct(
+        public string $customParam,
+        string $message = '',
+    ) {
+        parent::__construct($message ?: "Exception with param: {$customParam}");
+    }
+}
+
+class InvokeSerializedClosureCommandTest extends TestCase
+{
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->app[Kernel::class]->registerCommand(new InvokeSerializedClosureCommand);
+    }
+
+    public function testItCanInvokeSerializedClosureFromArgument()
+    {
+        // Create a simple closure and serialize it
+        $closure = fn () => 'Hello, World!';
+        $serialized = serialize(new SerializableClosure($closure));
+
+        // Create a new output buffer
+        $output = new BufferedOutput;
+
+        // Call the command with the serialized closure
+        Artisan::call('invoke-serialized-closure', [
+            'code' => $serialized,
+        ], $output);
+
+        // Get the output and decode it
+        $result = json_decode($output->fetch(), true);
+
+        // Verify the result
+        $this->assertTrue($result['successful']);
+        $this->assertEquals('Hello, World!', unserialize($result['result']));
+    }
+
+    public function testItCanInvokeSerializedClosureFromEnvironment()
+    {
+        // Create a simple closure and serialize it
+        $closure = fn () => 'From Environment';
+        $serialized = serialize(new SerializableClosure($closure));
+
+        // Set the environment variable
+        $_SERVER['LARAVEL_INVOKABLE_CLOSURE'] = $serialized;
+
+        // Create a new output buffer
+        $output = new BufferedOutput;
+
+        // Call the command without arguments
+        Artisan::call('invoke-serialized-closure', [], $output);
+
+        // Get the output and decode it
+        $result = json_decode($output->fetch(), true);
+
+        // Verify the result
+        $this->assertTrue($result['successful']);
+        $this->assertEquals('From Environment', unserialize($result['result']));
+
+        // Clean up
+        unset($_SERVER['LARAVEL_INVOKABLE_CLOSURE']);
+    }
+
+    public function testItReturnsNullWhenNoClosureIsProvided()
+    {
+        // Create a new output buffer
+        $output = new BufferedOutput;
+
+        // Call the command without arguments
+        Artisan::call('invoke-serialized-closure', [], $output);
+
+        // Get the output and decode it
+        $result = json_decode($output->fetch(), true);
+
+        // Verify the result
+        $this->assertTrue($result['successful']);
+        $this->assertNull(unserialize($result['result']));
+    }
+
+    public function testItHandlesExceptionsGracefully()
+    {
+        // Create a closure that throws an exception
+        $closure = fn () => throw new RuntimeException('Test exception');
+        $serialized = serialize(new SerializableClosure($closure));
+
+        // Create a new output buffer
+        $output = new BufferedOutput;
+
+        // Call the command with the serialized closure
+        Artisan::call('invoke-serialized-closure', [
+            'code' => $serialized,
+        ], $output);
+
+        // Get the output and decode it
+        $result = json_decode($output->fetch(), true);
+
+        // Verify the exception was caught
+        $this->assertFalse($result['successful']);
+        $this->assertEquals('RuntimeException', $result['exception']);
+        $this->assertEquals('Test exception', $result['message']);
+    }
+
+    public function testItHandlesCustomExceptionWithParameters()
+    {
+        // Create a closure that throws an exception with parameters
+        $closure = fn () => throw new CustomParameterException('Test param');
+        $serialized = serialize(new SerializableClosure($closure));
+
+        // Create a new output buffer
+        $output = new BufferedOutput;
+
+        // Call the command with the serialized closure
+        Artisan::call('invoke-serialized-closure', [
+            'code' => $serialized,
+        ], $output);
+
+        // Get the output and decode it
+        $result = json_decode($output->fetch(), true);
+
+        // Verify the exception was caught and parameters were captured
+        $this->assertFalse($result['successful']);
+        $this->assertArrayHasKey('parameters', $result);
+        $this->assertEquals('Test param', $result['parameters']['customParam'] ?? null);
+    }
+}