wip

src/Protocols/Pusher/Concerns/InteractsWithChannelInformation.php

@@ -44,18 +44,11 @@ protected function info(Application $application, string $channel, string $info)
      */
     private function occupiedInfo(Channel $channel, array $info): array
     {
-        if (in_array('user_count', $info) && $this->isPresenceChannel($channel)) {
-            $count = collect($channel->connections())
-                ->map(fn ($connection) => $connection->data())
-                ->unique('user_id')
-                ->count();
-        } else {
-            $count = count($channel->connections());
-        }
+        $count = count($channel->connections());
 
         return [
             'occupied' => in_array('occupied', $info) ? $count > 0 : null,
-            'user_count' => in_array('user_count', $info) && $this->isPresenceChannel($channel) ? $count : null,
+            'user_count' => in_array('user_count', $info) && $this->isPresenceChannel($channel) ? $this->presenceUserCount($channel) : null,
             'subscription_count' => in_array('subscription_count', $info) && ! $this->isPresenceChannel($channel) ? $count : null,
             'cache' => in_array('cache', $info) && $this->isCacheChannel($channel) ? $channel->cachedPayload() : null,
         ];
@@ -86,4 +79,15 @@ protected function isCacheChannel(Channel $channel): bool
     {
         return $channel instanceof CacheChannel;
     }
+
+    /**
+     * Get the count of unique users in the presence channel.
+     */
+    protected function presenceUserCount(Channel $channel): int
+    {
+        return collect($channel->connections())
+            ->map(fn ($connection) => $connection->data())
+            ->unique('user_id')
+            ->count();
+    }
 }

tests/Feature/Protocols/Pusher/Reverb/ChannelControllerTest.php

@@ -33,6 +33,16 @@
     expect($response->getBody()->getContents())->toBe('{"occupied":true,"subscription_count":1,"cache":{"some":"data"}}');
 });
 
+it('can return presence channel attributes', function () {
+    subscribe('presence-test-channel-one', ['id' => 123]);
+    subscribe('presence-test-channel-one', ['id' => 123]);
+
+    $response = await($this->signedRequest('channels/presence-test-channel-one?info=user_count,subscription_count,cache'));
+
+    expect($response->getStatusCode())->toBe(200);
+    expect($response->getBody()->getContents())->toBe('{"occupied":true,"user_count":1}');
+});
+
 it('can return only the requested attributes', function () {
     subscribe('test-channel-one');
 
@@ -82,6 +92,18 @@
     expect($response->getBody()->getContents())->toBe('{"occupied":true,"subscription_count":1,"cache":{"some":"data"}}');
 });
 
+it('can gather presence channel attributes', function () {
+    $this->usingRedis();
+
+    subscribe('presence-test-channel-one', ['id' => 123]);
+    subscribe('presence-test-channel-one', ['id' => 123]);
+
+    $response = await($this->signedRequest('channels/presence-test-channel-one?info=user_count,subscription_count,cache'));
+
+    expect($response->getStatusCode())->toBe(200);
+    expect($response->getBody()->getContents())->toBe('{"occupied":true,"user_count":1}');
+});
+
 it('can gather only the requested attributes', function () {
     $this->usingRedis();
 

tests/Feature/Protocols/Pusher/Reverb/ChannelUsersControllerTest.php

@@ -33,6 +33,20 @@
     expect($response->getBody()->getContents())->toBe('{"users":[{"id":1},{"id":2},{"id":3}]}');
 });
 
+it('returns the unique user data', function () {
+    $channel = app(ChannelManager::class)
+        ->for(app()->make(ApplicationProvider::class)->findByKey('reverb-key'))
+        ->findOrCreate('presence-test-channel');
+    $channel->subscribe($connection = new FakeConnection('test-connection-one'), validAuth($connection->id(), 'presence-test-channel', $data = json_encode(['user_id' => 3, 'user_info' => ['name' => 'Taylor']])), $data);
+    $channel->subscribe($connection = new FakeConnection('test-connection-two'), validAuth($connection->id(), 'presence-test-channel', $data = json_encode(['user_id' => 2, 'user_info' => ['name' => 'Joe']])), $data);
+    $channel->subscribe($connection = new FakeConnection('test-connection-three'), validAuth($connection->id(), 'presence-test-channel', $data = json_encode(['user_id' => 3, 'user_info' => ['name' => 'Jess']])), $data);
+
+    $response = await($this->signedRequest('channels/presence-test-channel/users'));
+
+    expect($response->getStatusCode())->toBe(200);
+    expect($response->getBody()->getContents())->toBe('{"users":[{"id":3},{"id":2}]}');
+});
+
 it('returns an error when gathering a non-existent presence channel', function () {
     $this->usingRedis();
 
@@ -62,3 +76,19 @@
     expect($response->getStatusCode())->toBe(200);
     expect($response->getBody()->getContents())->toBe('{"users":[{"id":1},{"id":2},{"id":3}]}');
 });
+
+it('gathers the unique user data', function () {
+    $this->usingRedis();
+
+    $channel = app(ChannelManager::class)
+        ->for(app()->make(ApplicationProvider::class)->findByKey('reverb-key'))
+        ->findOrCreate('presence-test-channel');
+    $channel->subscribe($connection = new FakeConnection('test-connection-one'), validAuth($connection->id(), 'presence-test-channel', $data = json_encode(['user_id' => 2, 'user_info' => ['name' => 'Taylor']])), $data);
+    $channel->subscribe($connection = new FakeConnection('test-connection-two'), validAuth($connection->id(), 'presence-test-channel', $data = json_encode(['user_id' => 2, 'user_info' => ['name' => 'Joe']])), $data);
+    $channel->subscribe($connection = new FakeConnection('test-connection-three'), validAuth($connection->id(), 'presence-test-channel', $data = json_encode(['user_id' => 3, 'user_info' => ['name' => 'Jess']])), $data);
+
+    $response = await($this->signedRequest('channels/presence-test-channel/users'));
+
+    expect($response->getStatusCode())->toBe(200);
+    expect($response->getBody()->getContents())->toBe('{"users":[{"id":2},{"id":3}]}');
+});