Dont filter out duplicate connections

Author: georgeboot

src/Driver.php

@@ -112,17 +112,20 @@ protected function generateSignaturePresence(string $channel, string $socketId,
      */
     public function broadcast(array $channels, $event, array $payload = [])
     {
-        $data = json_encode([
-            'event' => $event,
-            'data' => $payload,
-        ], JSON_THROW_ON_ERROR);
-
         $skipConnectionId = Arr::pull($payload, 'socket');
 
-        $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));
+        foreach ($channels as $channel) {
+            $data = json_encode([
+                'event' => $event,
+                'channel' => $channel,
+                'data' => $payload,
+            ], JSON_THROW_ON_ERROR);
+
+            $this->subscriptionRepository->getConnectionIdsForChannel($channel)
+                ->reject(fn($connectionId) => $connectionId === $skipConnectionId)
+                ->tap(fn($connectionIds) => logger()->debug("Preparing to send to connections for channel '{$channel}'", $connectionIds->toArray()))
+                ->each(fn(string $connectionId) => $this->sendMessage($connectionId, $data));
+        }
 
         return;
 

src/SubscriptionRepository.php

@@ -21,7 +21,7 @@ public function __construct(array $config)
         $this->table = $config['table'];
     }
 
-    public function getConnectionIdsForChannels(string ...$channels): Collection
+    public function getConnectionIdsForChannel(string ...$channels): Collection
     {
         $promises = collect($channels)->map(fn($channel) => $this->dynamoDb->queryAsync([
             'TableName' => $this->table,