Logging

Author: georgeboot

src/Driver.php

@@ -121,6 +121,7 @@ public function broadcast(array $channels, $event, array $payload = [])
 
         $this->subscriptionRepository->getConnectionIdsForChannels(...$channels)
             ->reject(fn($connectionId) => $connectionId === $skipConnectionId)
+            ->tap(fn($collection) => logger()->debug("Preparing to send to connections", $collection->toArray()))
             ->each(fn(string $connectionId) => $this->sendMessage($connectionId, $data));
 
         return;
@@ -139,6 +140,8 @@ public function broadcast(array $channels, $event, array $payload = [])
 
     protected function sendMessage(string $connectionId, string $data): void
     {
+        logger()->debug("Sending message to connection '{$connectionId}'");
+
         try {
             $this->connectionRepository->sendMessage($connectionId, $data);
         } catch (ApiGatewayManagementApiException $exception) {