From e57e02d839c623c5e1cbc5b070e3b3ac600da526 Mon Sep 17 00:00:00 2001 From: Taylor Otwell Date: Fri, 19 Jan 2024 10:37:16 -0600 Subject: [PATCH] formatting --- src/Protocols/Pusher/EventDispatcher.php | 1 + src/Servers/Reverb/Console/Commands/StartServer.php | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/Protocols/Pusher/EventDispatcher.php b/src/Protocols/Pusher/EventDispatcher.php index 1dd950b7..75758321 100644 --- a/src/Protocols/Pusher/EventDispatcher.php +++ b/src/Protocols/Pusher/EventDispatcher.php @@ -39,6 +39,7 @@ public static function dispatchSynchronously(Application $app, array $payload, ? foreach ($channels as $channel) { unset($payload['channels']); + if (! $channel = app(ChannelManager::class)->for($app)->find($channel)) { continue; } diff --git a/src/Servers/Reverb/Console/Commands/StartServer.php b/src/Servers/Reverb/Console/Commands/StartServer.php index ea930ecf..ada7b114 100644 --- a/src/Servers/Reverb/Console/Commands/StartServer.php +++ b/src/Servers/Reverb/Console/Commands/StartServer.php @@ -57,7 +57,7 @@ public function handle(): void $server = ServerFactory::make($host, $port, loop: $loop); - if ($this->laravel->make(ServerProviderManager::class)->subscribesToEvents()) { + if ($this->laravel->make(ServerProviderManager::class)->driver('reverb')->subscribesToEvents()) { $this->laravel->make(PubSubProvider::class)->connect($loop); $this->laravel->make(PubSubProvider::class)->subscribe(); }