implements users routes

src/Pusher/Http/Controllers/ChannelController.php

@@ -15,12 +15,8 @@ class ChannelController extends Controller
      */
     public function handle(RequestInterface $request, Connection $connection, ...$args): Response
     {
-        if (! $channel = $args['channel'] ?? null) {
-            return new JsonResponse((object) []);
-        }
-
         $info = explode(',', $this->query['info'] ?? '');
-        $connections = $this->channels->channel(ChannelBroker::create($channel));
+        $connections = $this->channels->channel(ChannelBroker::create($args['channel']));
         $totalConnections = count($connections);
 
         return new JsonResponse((object) array_filter([

src/Pusher/Http/Controllers/ChannelUsersController.php

@@ -2,17 +2,26 @@
 
 namespace Laravel\Reverb\Pusher\Http\Controllers;
 
+use Laravel\Reverb\Channels\ChannelBroker;
+use Laravel\Reverb\Channels\PresenceChannel;
 use Laravel\Reverb\Http\Connection;
 use Psr\Http\Message\RequestInterface;
 use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
 
 class ChannelUsersController extends Controller
 {
     /**
      * Handle the request.
      */
-    public function handle(RequestInterface $request, Connection $connection, ...$args)
+    public function handle(RequestInterface $request, Connection $connection, ...$args): Response
     {
+        $channel = ChannelBroker::create($args['channel']);
+
+        if(! $channel instanceof PresenceChannel) {
+            return new JsonResponse((object) [], 400);
+        }
+
         return new JsonResponse((object) []);
     }
 }

src/Servers/Reverb/Factory.php

@@ -44,7 +44,7 @@ protected static function routes(): RouteCollection
         $routes->add('events_batch', Route::post('/apps/{appId}/batch_events', new EventsBatchController));
         $routes->add('channels', Route::get('/apps/{appId}/channels', new ChannelsController));
         $routes->add('channel', Route::get('/apps/{appId}/channels/{channel}', new ChannelController));
-        // $routes->add('channel_users', Route::post('/apps/{appId}/channels/{channel}/users', new ChannelUsersController));
+        $routes->add('channel_users', Route::get('/apps/{appId}/channels/{channel}/users', new ChannelUsersController));
         // $routes->add('users_terminate', Route::post('/apps/{appId}/users/{user}/terminate_connections', new UsersTerminateController));
 
         return $routes;

tests/Feature/Ratchet/ChannelUsersControllerTest.php

@@ -0,0 +1,16 @@
+<?php
+
+use Laravel\Reverb\Tests\RatchetTestCase;
+use React\Http\Message\ResponseException;
+
+use function React\Async\await;
+
+uses(RatchetTestCase::class);
+
+it('returns an error when presence channel not provided', function () {
+    await($this->signedRequest('channels/test-channel/users'));
+})->throws(ResponseException::class);
+
+it('returns the user data', function () {
+    // 
+})->todo();