wip

Author: rennokki

src/Statistics/DnsResolver.php

@@ -9,7 +9,7 @@ class StartWebSocketServerTest extends TestCase
     /** @test */
     public function does_not_fail_if_building_up()
     {
-        $this->artisan('websockets:serve', ['--test' => true]);
+        $this->artisan('websockets:serve', ['--test' => true, '--debug' => true]);
 
         $this->assertTrue(true);
     }

tests/Commands/StartWebSocketServerTest.php

@@ -2,7 +2,10 @@
 
 namespace BeyondCode\LaravelWebSockets\Tests\PubSub;
 
+use BeyondCode\LaravelWebSockets\PubSub\Drivers\RedisClient;
 use BeyondCode\LaravelWebSockets\Tests\TestCase;
+use BeyondCode\LaravelWebSockets\Tests\Mocks\RedisFactory;
+use React\EventLoop\Factory as LoopFactory;
 
 class RedisDriverTest extends TestCase
 {
@@ -46,4 +49,35 @@ public function redis_listener_responds_properly_on_payload()
                 '1234:test-channel', $payload,
             ]);
     }
+
+    /** @test */
+    public function redis_listener_responds_properly_on_payload_by_direct_call()
+    {
+        $connection = $this->getConnectedWebSocketConnection(['test-channel']);
+
+        $this->pusherServer->onOpen($connection);
+
+        $channelData = [
+            'user_id' => 1,
+            'user_info' => [
+                'name' => 'Marcel',
+            ],
+        ];
+
+        $payload = json_encode([
+            'appId' => '1234',
+            'event' => 'test',
+            'data' => $channelData,
+            'socket' => $connection->socketId,
+        ]);
+
+        $client = (new RedisClient)->boot(
+            LoopFactory::create(), RedisFactory::class
+        );
+
+        $client->onMessage('1234:test-channel', $payload);
+
+        $client->getSubscribeClient()
+            ->assertEventDispatched('message');
+    }
 }