Added Cluster Support

src/ApiSettings.php

@@ -33,15 +33,17 @@ public static function getVersion(string $version = ''): string
      * @param  string $appId
      * @return string
      */
-    public static function createUrl(string $appId): string
+    public static function createUrl(string $appId, string $cluster = null): string
     {
         $query = [
             'client' => 'api-clients/pusher (https://php-api-clients.org/clients/pusher)',
             'protocol' => 7,
             'version' => ApiSettings::getVersion(),
         ];
 
-        return 'wss://ws.pusherapp.com/app/' .
+        $host = ($cluster) ? "ws-{$cluster}.pusher.com" : 'ws.pusherapp.com';
+
+        return 'wss://'.$host.'/app/' .
             $appId .
             '?' . http_build_query($query)
         ;

src/AsyncClient.php

@@ -83,7 +83,7 @@ public function __construct(Subject $client)
      * @throws \InvalidArgumentException
      * @return AsyncClient
      */
-    public static function create(LoopInterface $loop, string $app, Resolver $resolver = null): AsyncClient
+    public static function create(LoopInterface $loop, string $app, Resolver $resolver = null, $cluster = null): AsyncClient
     {
         try {
             Scheduler::setDefaultFactory(function () use ($loop) {
@@ -93,7 +93,7 @@ public static function create(LoopInterface $loop, string $app, Resolver $resolv
         }
 
         return new self(
-            WebSocket::createFactory(ApiSettings::createUrl($app), false, [], $loop, $resolver)
+            WebSocket::createFactory(ApiSettings::createUrl($app, $cluster), false, [], $loop, $resolver)
         );
     }
 

tests/ApiSettingsTest.php

@@ -43,5 +43,9 @@ public function testCreateUrl()
         $expectedUrl = 'wss://ws.pusherapp.com/app/barBaz?client=api-clients%2Fpusher+%28https%3A%2F%2Fphp-api-clients.org%2Fclients%2Fpusher%29&protocol=7&version=' . ApiSettings::getVersion();
 
         self::assertSame($expectedUrl, ApiSettings::createUrl('barBaz'));
+
+        $expectedUrl = 'wss://ws-ap1.pusher.com/app/barBaz?client=api-clients%2Fpusher+%28https%3A%2F%2Fphp-api-clients.org%2Fclients%2Fpusher%29&protocol=7&version=' . ApiSettings::getVersion();
+
+        self::assertSame($expectedUrl, ApiSettings::createUrl('barBaz','ap1'));
     }
 }