wip

laravel · May 8, 2024 · c9b2663 · c9b2663
1 parent 146c2c3
commit c9b2663
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 17 deletions.
diff --git a/tests/Feature/Protocols/Pusher/Reverb/ChannelControllerTest.php b/tests/Feature/Protocols/Pusher/Reverb/ChannelControllerTest.php
@@ -68,17 +68,17 @@
     expect($response->getHeader('Content-Length'))->toBe(['40']);
 });
 
-// it('can gather data for a single channel', function () {
-//     $this->usingRedis();
+it('can gather data for a single channel', function () {
+    $this->usingRedis();
 
-//     subscribe('test-channel-one');
-//     subscribe('test-channel-one');
+    subscribe('test-channel-one');
+    subscribe('test-channel-one');
 
-//     $response = await($this->signedRequest('channels/test-channel-one?info=user_count,subscription_count,cache'));
+    $response = await($this->signedRequest('channels/test-channel-one?info=user_count,subscription_count,cache'));
 
-//     expect($response->getStatusCode())->toBe(200);
-//     expect($response->getBody()->getContents())->toBe('{"occupied":true,"subscription_count":2}');
-// });
+    expect($response->getStatusCode())->toBe(200);
+    expect($response->getBody()->getContents())->toBe('{"occupied":true,"subscription_count":2}');
+});
 
 it('gathers unoccupied when no connections', function () {
     $this->usingRedis();

diff --git a/tests/Feature/Protocols/Pusher/Reverb/ConnectionsControllerTest.php b/tests/Feature/Protocols/Pusher/Reverb/ConnectionsControllerTest.php
@@ -61,13 +61,13 @@
     expect($response->getBody()->getContents())->toBe('{"connections":1}');
 });
 
-// it('can send the content-length header when gathering results', function () {
-//     $this->usingRedis();
+it('can send the content-length header when gathering results', function () {
+    $this->usingRedis();
 
-//     subscribe('test-channel-one');
-//     subscribe('presence-test-channel-two');
+    subscribe('test-channel-one');
+    subscribe('presence-test-channel-two');
 
-//     $response = await($this->signedRequest('connections'));
+    $response = await($this->signedRequest('connections'));
 
-//     expect($response->getHeader('Content-Length'))->toBe(['17']);
-// });
+    expect($response->getHeader('Content-Length'))->toBe(['17']);
+});
diff --git a/tests/ReverbTestCase.php b/tests/ReverbTestCase.php
@@ -76,7 +76,7 @@ public function usingRedis(): void
 
         app(PubSubProvider::class)->connect($this->loop);
         app(PubSubProvider::class)->subscribe();
-        usleep(50_000);
+        usleep(100_000);
     }
 
     /**
@@ -108,7 +108,7 @@ public function stopServer(): void
     {
         app(PubSubProvider::class)->disconnect();
 
-        usleep(50_000);
+        usleep(100_000);
 
         if ($this->server) {
             $this->server->stop();