Remove dependencies

composer.json

@@ -17,22 +17,24 @@
     "require": {
         "php": "^8.2",
         "aws/aws-sdk-php": "^3.241",
-        "cboden/ratchet": "^0.4.4",
         "clue/redis-react": "^2.6",
+        "guzzlehttp/psr7": "^2.6",
         "illuminate/cache": "^10.0",
         "illuminate/console": "^10.0",
         "illuminate/http": "^10.0",
         "illuminate/redis": "^10.0",
         "illuminate/support": "^10.0",
-        "nesbot/carbon": "^2.64"
+        "nesbot/carbon": "^2.64",
+        "ratchet/rfc6455": "^0.3.1",
+        "react/socket": "^1.14",
+        "symfony/http-foundation": "^6.3"
     },
     "require-dev": {
         "orchestra/testbench": "^8.0",
         "pestphp/pest": "^2.0",
         "phpstan/phpstan": "^1.10",
         "ratchet/pawl": "^0.4.1",
-        "react/async": "^4.0",
-        "react/http": "^1.8"
+        "react/async": "^4.0"
     },
     "autoload": {
         "psr-4": {
@@ -66,4 +68,4 @@
     },
     "minimum-stability": "dev",
     "prefer-stable": true
-}
+}

config/reverb.php

@@ -11,10 +11,10 @@
     | messages received from and when sending messages to connected
     | clients. You must specify one of the servers listed below.
     |
-    | Supported: "ratchet", "api_gateway"
+    | Supported: "reverb", "api_gateway"
     */
 
-    'default' => env('REVERB_SERVER', 'ratchet'),
+    'default' => env('REVERB_SERVER', 'reverb'),
 
     /*
     |--------------------------------------------------------------------------
@@ -28,15 +28,15 @@
 
     'servers' => [
 
-        'ratchet' => [
-            'host' => env('REVERB_RATCHET_HOST', '127.0.0.1'),
-            'port' => env('REVERB_RATCHET_PORT', 8080),
+        'reverb' => [
+            'host' => env('REVERB_HOST', '127.0.0.1'),
+            'port' => env('REVERB_PORT', 8080),
             'connection_manager' => [
-                'prefix' => env('REVERB_RATCHET_CONNECTION_CACHE_PREFIX', 'reverb'),
+                'prefix' => env('REVERB_CONNECTION_CACHE_PREFIX', 'reverb'),
             ],
             'publish_events' => [
-                'enabled' => env('REVERB_RATCHET_SCALING_ENABLED', false),
-                'channel' => env('REVERB_RATCHET_SCALING_CHANNEL', 'reverb'),
+                'enabled' => env('REVERB_SCALING_ENABLED', false),
+                'channel' => env('REVERB_SCALING_CHANNEL', 'reverb'),
             ],
         ],
 

src/Channels/Channel.php

@@ -6,8 +6,8 @@
 use Illuminate\Support\Arr;
 use Illuminate\Support\Facades\App;
 use Laravel\Reverb\Application;
-use Laravel\Reverb\Connection;
 use Laravel\Reverb\Contracts\ChannelManager;
+use Laravel\Reverb\Contracts\Connection;
 use Laravel\Reverb\Output;
 
 class Channel
@@ -49,9 +49,7 @@ public function unsubscribe(Connection $connection): void
      */
     public function broadcast(Application $app, array $payload, Connection $except = null): void
     {
-        App::make(ChannelManager::class)
-            ->for($app)
-            ->connections($this)
+        collect(App::make(ChannelManager::class)->for($app)->connections($this))
             ->each(function ($connection) use ($payload, $except) {
                 if ($except && $except->identifier() === $connection->identifier()) {
                     return;

src/Channels/PresenceChannel.php

@@ -4,8 +4,8 @@
 
 use Illuminate\Support\Facades\App;
 use Laravel\Reverb\Application;
-use Laravel\Reverb\Connection;
 use Laravel\Reverb\Contracts\ChannelManager;
+use Laravel\Reverb\Contracts\Connection;
 
 class PresenceChannel extends PrivateChannel
 {

src/Channels/PrivateChannel.php

@@ -3,7 +3,7 @@
 namespace Laravel\Reverb\Channels;
 
 use Illuminate\Support\Str;
-use Laravel\Reverb\Connection;
+use Laravel\Reverb\Contracts\Connection;
 use Laravel\Reverb\Exceptions\ConnectionUnauthorized;
 
 class PrivateChannel extends Channel

src/ClientEvent.php

@@ -3,6 +3,7 @@
 namespace Laravel\Reverb;
 
 use Illuminate\Support\Str;
+use Laravel\Reverb\Contracts\Connection;
 
 class ClientEvent
 {

src/Concerns/ClosesConnections.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Laravel\Reverb\Concerns;
+
+use GuzzleHttp\Psr7\Message;
+use GuzzleHttp\Psr7\Response;
+use Laravel\Reverb\Http\Connection;
+
+trait ClosesConnections
+{
+    /**
+     * Close the connection.
+     */
+    protected function close(Connection $connection, int $statusCode = 400, array $headers = []): void
+    {
+        $response = new Response($statusCode, $headers);
+
+        $connection->send(Message::toString($response));
+        $connection->close();
+    }
+}

src/Contracts/ChannelManager.php

@@ -5,7 +5,6 @@
 use Illuminate\Support\Collection;
 use Laravel\Reverb\Application;
 use Laravel\Reverb\Channels\Channel;
-use Laravel\Reverb\Connection;
 use Laravel\Reverb\Managers\Connections;
 
 interface ChannelManager
@@ -40,17 +39,12 @@ public function all(): Collection;
      */
     public function unsubscribeFromAll(Connection $connection): void;
 
-    /**
-     * Get all connection keys for the given channel.
-     */
-    public function connectionKeys(Channel $channel): Collection;
-
     /**
      * Get all connections for the given channel.
      *
-     * @return \Laravel\Reverb\Managers\Connections|\Laravel\Reverb\Connection[]|string[]
+     * @return <array string, \Laravel\Reverb\Connection>
      */
-    public function connections(Channel $channel): Connections;
+    public function connections(Channel $channel): array;
 
     /**
      * Flush the channel manager repository.

src/Connection.php → src/Contracts/Connection.php

@@ -1,12 +1,12 @@
 <?php
 
-namespace Laravel\Reverb;
+namespace Laravel\Reverb\Contracts;
 
 use Carbon\Carbon;
 use Illuminate\Support\Facades\App;
-use Laravel\Reverb\Contracts\ChannelManager;
-use Laravel\Reverb\Contracts\ConnectionManager;
-use Laravel\Reverb\Contracts\SerializableConnection;
+use Laravel\Reverb\Application;
+use Laravel\Reverb\Output;
+use Laravel\Reverb\PusherEvent;
 
 abstract class Connection
 {

src/Contracts/ConnectionManager.php

@@ -4,7 +4,6 @@
 
 use Closure;
 use Laravel\Reverb\Application;
-use Laravel\Reverb\Connection;
 use Laravel\Reverb\Managers\Connections;
 
 interface ConnectionManager
@@ -47,21 +46,14 @@ public function find(string $identifier): ?Connection;
     /**
      * Get all of the connections from the cache.
      *
-     * @return \Laravel\Reverb\Managers\Connections|\Laravel\Reverb\Connection[]|string[]
+     * @return <int, \Laravel\Reverb\Connection>
      */
-    public function all(): Connections;
-
-    /**
-     * Synchronize the connections with the manager.
-     *
-     * @param  \Laravel\Reverb\Managers\Connections|\Laravel\Reverb\Connection[]|string[]  $connections
-     */
-    public function sync(Connections $connections): void;
+    public function all(): array;
 
     /**
      * Synchronize a connection with the manager.
      */
-    public function syncConnection(Connection $connection): void;
+    public function save(Connection $connection): void;
 
     /**
      * Flush the channel manager repository.

src/Event.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Support\Facades\App;
 use Laravel\Reverb\Channels\ChannelBroker;
+use Laravel\Reverb\Contracts\Connection;
 use Laravel\Reverb\Contracts\ServerProvider;
 
 class Event