[11.x] Add support for middlewares & failed handler on broadcastable events (#54562)

* [11.x] Add support for broadcasting middlewares & failed handler via proxy call

* CS fix

* CS fix

* CS fix

* Update BroadcastEvent.php

---------

Co-authored-by: Taylor Otwell <[email protected]>

Author: Jacobs63

src/Illuminate/Broadcasting/BroadcastEvent.php

@@ -9,6 +9,7 @@
 use Illuminate\Support\Arr;
 use ReflectionClass;
 use ReflectionProperty;
+use Throwable;
 
 class BroadcastEvent implements ShouldQueue
 {
@@ -170,6 +171,35 @@ protected function getConnectionPayload($payload, $connection)
         return $connectionPayload;
     }
 
+    /**
+     * Get the middleware for the underlying event.
+     *
+     * @return array<int, object>
+     */
+    public function middleware(): array
+    {
+        if (! method_exists($this->event, 'middleware')) {
+            return [];
+        }
+
+        return $this->event->middleware();
+    }
+
+    /**
+     * Handle a job failure.
+     *
+     * @param  \Throwable  $e
+     * @return void
+     */
+    public function failed(?Throwable $e = null): void
+    {
+        if (! method_exists($this->event, 'failed')) {
+            return;
+        }
+
+        $this->event->failed($e);
+    }
+
     /**
      * Get the display name for the queued job.
      *

tests/Broadcasting/BroadcastEventTest.php

@@ -2,12 +2,14 @@
 
 namespace Illuminate\Tests\Broadcasting;
 
+use Exception;
 use Illuminate\Broadcasting\BroadcastEvent;
 use Illuminate\Broadcasting\InteractsWithBroadcasting;
 use Illuminate\Contracts\Broadcasting\Broadcaster;
 use Illuminate\Contracts\Broadcasting\Factory as BroadcastingFactory;
 use Mockery as m;
 use PHPUnit\Framework\TestCase;
+use Throwable;
 
 class BroadcastEventTest extends TestCase
 {
@@ -86,6 +88,39 @@ public function testSpecificChannelsPerConnection()
 
         (new BroadcastEvent($event))->handle($manager);
     }
+
+    public function testMiddlewareProxiesMiddlewareFromUnderlyingEvent()
+    {
+        $event = new class
+        {
+            public function middleware(): array
+            {
+                return ['foo', 'bar'];
+            }
+        };
+
+        $job = new BroadcastEvent($event);
+
+        $this->assertSame(['foo', 'bar'], $job->middleware());
+    }
+
+    public function testMiddlewareProxiesFailedHandlerFromUnderlyingEvent()
+    {
+        $event = new class
+        {
+            public function failed(?Throwable $e = null): void
+            {
+                $e->validateCall();
+            }
+        };
+
+        $job = new BroadcastEvent($event);
+
+        $exception = m::mock(Exception::class);
+        $exception->expects('validateCall');
+
+        $job->failed($exception);
+    }
 }
 
 class TestBroadcastEvent