send content length

laravel · Apr 23, 2024 · 3e0ca9b · 3e0ca9b
1 parent 4a08256
commit 3e0ca9b
Show file tree

Hide file tree

Showing 8 changed files with 39 additions and 25 deletions.
diff --git a/src/Protocols/Pusher/Http/Controllers/ChannelController.php b/src/Protocols/Pusher/Http/Controllers/ChannelController.php
@@ -4,9 +4,9 @@
 
 use Laravel\Reverb\Protocols\Pusher\MetricsHandler;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
 
 class ChannelController extends Controller
 {
@@ -20,6 +20,6 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         return app(MetricsHandler::class)->gather($this->application, 'channel', [
             'channel' => $channel,
             'info' => ($info = $this->query['info']) ? $info.',occupied' : 'occupied',
-        ])->then(fn ($channel) => new JsonResponse((object) $channel));
+        ])->then(fn ($channel) => new Response((object) $channel));
     }
 }
diff --git a/src/Protocols/Pusher/Http/Controllers/ChannelUsersController.php b/src/Protocols/Pusher/Http/Controllers/ChannelUsersController.php
@@ -5,10 +5,9 @@
 use Laravel\Reverb\Protocols\Pusher\Concerns\InteractsWithChannelInformation;
 use Laravel\Reverb\Protocols\Pusher\MetricsHandler;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
-use Symfony\Component\HttpFoundation\Response;
 
 class ChannelUsersController extends Controller
 {
@@ -24,15 +23,15 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         $channel = $this->channels->find($channel);
 
         if (! $channel) {
-            return new JsonResponse((object) [], 404);
+            return new Response((object) [], 404);
         }
 
         if (! $this->isPresenceChannel($channel)) {
-            return new JsonResponse((object) [], 400);
+            return new Response((object) [], 400);
         }
 
         return app(MetricsHandler::class)
             ->gather($this->application, 'channel_users', ['channel' => $channel->name()])
-            ->then(fn ($connections) => new JsonResponse(['users' => $connections]));
+            ->then(fn ($connections) => new Response(['users' => $connections]));
     }
 }
diff --git a/src/Protocols/Pusher/Http/Controllers/ChannelsController.php b/src/Protocols/Pusher/Http/Controllers/ChannelsController.php
@@ -4,9 +4,9 @@
 
 use Laravel\Reverb\Protocols\Pusher\MetricsHandler;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
 
 class ChannelsController extends Controller
 {
@@ -20,6 +20,6 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         return app(MetricsHandler::class)->gather($this->application, 'channels', [
             'filter' => $this->query['filter_by_prefix'] ?? null,
             'info' => $this->query['info'] ?? null,
-        ])->then(fn ($channels) => new JsonResponse(['channels' => array_map(fn ($item) => (object) $item, $channels)]));
+        ])->then(fn ($channels) => new Response(['channels' => array_map(fn ($item) => (object) $item, $channels)]));
     }
 }
diff --git a/src/Protocols/Pusher/Http/Controllers/ConnectionsController.php b/src/Protocols/Pusher/Http/Controllers/ConnectionsController.php
@@ -4,9 +4,9 @@
 
 use Laravel\Reverb\Protocols\Pusher\MetricsHandler;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
 
 class ConnectionsController extends Controller
 {
@@ -18,6 +18,6 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         $this->verify($request, $connection, $appId);
 
         return app(MetricsHandler::class)->gather($this->application, 'connections')
-            ->then(fn ($connections) => new JsonResponse(['connections' => count($connections)]));
+            ->then(fn ($connections) => new Response(['connections' => count($connections)]));
     }
 }
diff --git a/src/Protocols/Pusher/Http/Controllers/EventsBatchController.php b/src/Protocols/Pusher/Http/Controllers/EventsBatchController.php
@@ -8,10 +8,9 @@
 use Laravel\Reverb\Protocols\Pusher\EventDispatcher;
 use Laravel\Reverb\Protocols\Pusher\MetricsHandler;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
-use Symfony\Component\HttpFoundation\Response;
 
 use function React\Promise\all;
 
@@ -31,7 +30,7 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         $validator = $this->validator($payload);
 
         if ($validator->fails()) {
-            return new JsonResponse($validator->errors(), 422);
+            return new Response($validator->errors(), 422);
         }
 
         $items = collect($payload['batch']);
@@ -56,11 +55,11 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
 
         if ($items->contains(fn ($item) => ! empty($item))) {
             return all($items)->then(function ($items) {
-                return new JsonResponse(['batch' => array_map(fn ($item) => (object) $item, $items)]);
+                return new Response(['batch' => array_map(fn ($item) => (object) $item, $items)]);
             });
         }
 
-        return new JsonResponse(['batch' => (object) []]);
+        return new Response(['batch' => (object) []]);
     }
 
     /**

diff --git a/src/Protocols/Pusher/Http/Controllers/EventsController.php b/src/Protocols/Pusher/Http/Controllers/EventsController.php
@@ -9,10 +9,9 @@
 use Laravel\Reverb\Protocols\Pusher\EventDispatcher;
 use Laravel\Reverb\Protocols\Pusher\MetricsHandler;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
-use Symfony\Component\HttpFoundation\Response;
 
 class EventsController extends Controller
 {
@@ -30,7 +29,7 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         $validator = $this->validator($payload);
 
         if ($validator->fails()) {
-            return new JsonResponse($validator->errors(), 422);
+            return new Response($validator->errors(), 422);
         }
 
         $channels = Arr::wrap($payload['channels'] ?? $payload['channel'] ?? []);
@@ -51,10 +50,10 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
         if (isset($payload['info'])) {
             return app(MetricsHandler::class)
                 ->gather($this->application, 'channels', ['info' => $payload['info'], 'channels' => $channels])
-                ->then(fn ($channels) => new JsonResponse(['channels' => array_map(fn ($channel) => (object) $channel, $channels)]));
+                ->then(fn ($channels) => new Response(['channels' => array_map(fn ($channel) => (object) $channel, $channels)]));
         }
 
-        return new JsonResponse((object) []);
+        return new Response((object) []);
     }
 
     /**

diff --git a/src/Protocols/Pusher/Http/Controllers/UsersTerminateController.php b/src/Protocols/Pusher/Http/Controllers/UsersTerminateController.php
@@ -5,10 +5,9 @@
 use Laravel\Reverb\ServerProviderManager;
 use Laravel\Reverb\Servers\Reverb\Contracts\PubSubProvider;
 use Laravel\Reverb\Servers\Reverb\Http\Connection;
+use Laravel\Reverb\Servers\Reverb\Http\Response;
 use Psr\Http\Message\RequestInterface;
 use React\Promise\PromiseInterface;
-use Symfony\Component\HttpFoundation\JsonResponse;
-use Symfony\Component\HttpFoundation\Response;
 
 class UsersTerminateController extends Controller
 {
@@ -24,7 +23,7 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
                 'type' => 'terminate',
                 'application' => serialize($this->application),
                 'payload' => ['user_id' => $userId],
-            ])->then(fn () => new JsonResponse((object) []));
+            ])->then(fn () => new Response((object) []));
         }
 
         $connections = collect($this->channels->connections());
@@ -35,6 +34,6 @@ public function __invoke(RequestInterface $request, Connection $connection, stri
             }
         });
 
-        return new JsonResponse((object) []);
+        return new Response((object) []);
     }
 }
diff --git a/src/Servers/Reverb/Http/Response.php b/src/Servers/Reverb/Http/Response.php
@@ -0,0 +1,18 @@
+<?php
+
+namespace Laravel\Reverb\Servers\Reverb\Http;
+
+use Symfony\Component\HttpFoundation\JsonResponse;
+
+class Response extends JsonResponse
+{
+    /**
+     * Create a new Http response instance.
+     */
+    public function __construct(mixed $data = null, int $status = 200, array $headers = [], bool $json = false)
+    {
+        parent::__construct($data, $status, $headers, $json);
+
+        $this->headers->set('Content-Length', strlen($this->content));
+    }
+}