Removed $this->connection from RedisPusherBroadcaster

Author: rennokki

src/Contracts/PushesToPusher.php

@@ -20,8 +20,7 @@ public function getPusherBroadcaster(array $app)
             return new RedisPusherBroadcaster(
                 new Pusher($app['key'], $app['secret'], $app['id'], config('broadcasting.connections.websockets.options', [])),
                 $app['id'],
-                app('redis'),
-                config('broadcasting.connections.websockets.connection', null)
+                app('redis')
             );
         }
 

src/PubSub/Broadcasters/RedisPusherBroadcaster.php

@@ -35,27 +35,18 @@ class RedisPusherBroadcaster extends Broadcaster
      */
     protected $redis;
 
-    /**
-     * The Redis connection to use for broadcasting.
-     *
-     * @var string|null
-     */
-    protected $connection;
-
     /**
      * Create a new broadcaster instance.
      *
      * @param  Pusher  $pusher
      * @param  mixed  $appId
      * @param  \Illuminate\Contracts\Redis\Factory  $redis
-     * @param  string|null  $connection
      */
-    public function __construct(Pusher $pusher, $appId, Redis $redis, $connection = null)
+    public function __construct(Pusher $pusher, $appId, Redis $redis)
     {
         $this->pusher = $pusher;
         $this->appId = $appId;
         $this->redis = $redis;
-        $this->connection = $connection;
     }
 
     /**
@@ -133,7 +124,9 @@ protected function decodePusherResponse($request, $response)
      */
     public function broadcast(array $channels, $event, array $payload = [])
     {
-        $connection = $this->redis->connection($this->connection);
+        $connection = $this->redis->connection(
+            config('websockets.replication.redis.connection') ?: 'default'
+        );
 
         $payload = json_encode([
             'appId' => $this->appId,

src/WebSocketsServiceProvider.php

@@ -105,8 +105,7 @@ protected function configurePubSub()
             return new RedisPusherBroadcaster(
                 $pusher,
                 $config['app_id'],
-                $this->app->make('redis'),
-                $config['connection'] ?? null
+                $this->app->make('redis')
             );
         });
     }