handle stale apps (#143)

laravel · Apr 11, 2024 · 47e6a7d · 47e6a7d
1 parent 0fb2e03
commit 47e6a7d
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 6 deletions.
diff --git a/src/Protocols/Pusher/Http/Controllers/Controller.php b/src/Protocols/Pusher/Http/Controllers/Controller.php
@@ -46,12 +46,8 @@ public function verify(RequestInterface $request, Connection $connection, $appId
         $this->body = $request->getBody()->getContents();
         $this->query = $query;
 
-        try {
-            $this->setApplication($appId);
-            $this->setChannels();
-        } catch (HttpException $e) {
-            $this->close($connection, $e->getStatusCode(), $e->getMessage());
-        }
+        $this->setApplication($appId);
+        $this->setChannels();
     }
 
     /**

diff --git a/src/Servers/Reverb/Http/Server.php b/src/Servers/Reverb/Http/Server.php
@@ -11,6 +11,7 @@
 use React\EventLoop\LoopInterface;
 use React\Socket\ConnectionInterface;
 use React\Socket\ServerInterface;
+use Symfony\Component\HttpKernel\Exception\HttpException;
 use Throwable;
 
 class Server
@@ -57,6 +58,8 @@ protected function handleRequest(string $message, Connection $connection): void
 
         try {
             $this->router->dispatch($request, $connection);
+        } catch (HttpException $e) {
+            $this->close($connection, $e->getStatusCode(), $e->getMessage());
         } catch (Throwable $e) {
             Log::error($e->getMessage());
             $this->close($connection, 500, 'Internal server error.');

diff --git a/tests/Feature/Protocols/Pusher/Reverb/EventsControllerTest.php b/tests/Feature/Protocols/Pusher/Reverb/EventsControllerTest.php
@@ -193,3 +193,7 @@
 
     expect($response->getStatusCode())->toBe(500);
 })->throws(ResponseException::class, exceptionCode: 500);
+
+it('fails when app cannot be found', function () {
+    await($this->signedPostRequest('events', appId: 'invalid-app-id'));
+})->throws(ResponseException::class, exceptionCode: 404);