diff --git a/src/Protocols/Pusher/PusherPubSubIncomingMessageHandler.php b/src/Protocols/Pusher/PusherPubSubIncomingMessageHandler.php index 32c16d6..5cc5725 100644 --- a/src/Protocols/Pusher/PusherPubSubIncomingMessageHandler.php +++ b/src/Protocols/Pusher/PusherPubSubIncomingMessageHandler.php @@ -15,7 +15,9 @@ public function handle(string $payload): void $event = json_decode($payload, associative: true, flags: JSON_THROW_ON_ERROR); $application = unserialize($event['application']); - $except = app(ChannelManager::class)->for($application)->connections()[$event['socket_id']] ?? null; + $except = isset($event['socket_id']) ? + app(ChannelManager::class)->for($application)->connections()[$event['socket_id']] ?? null + : null; match ($event['type'] ?? null) { 'message' => EventDispatcher::dispatchSynchronously(