Added new events

src/Events/WebSocketConnected.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Laravel\Reverb\Contracts\Connection;
+
+class WebSocketConnected
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(public Connection $connection)
+    {
+        //
+    }
+}

src/Events/WebSocketDisconnect.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Laravel\Reverb\Contracts\Connection;
+
+class WebSocketDisconnect
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(public Connection $connection)
+    {
+        //
+    }
+}

src/Protocols/Pusher/Server.php

@@ -6,6 +6,8 @@
 use Illuminate\Support\Str;
 use Laravel\Reverb\Contracts\Connection;
 use Laravel\Reverb\Events\MessageReceived;
+use Laravel\Reverb\Events\WebSocketConnected;
+use Laravel\Reverb\Events\WebSocketDisconnect;
 use Laravel\Reverb\Loggers\Log;
 use Laravel\Reverb\Protocols\Pusher\Contracts\ChannelManager;
 use Laravel\Reverb\Protocols\Pusher\Exceptions\InvalidOrigin;
@@ -34,6 +36,8 @@ public function open(Connection $connection): void
             $this->handler->handle($connection, 'pusher:connection_established');
 
             Log::info('Connection Established', $connection->id());
+
+            WebSocketConnected::dispatch($connection);
         } catch (Exception $e) {
             $this->error($connection, $e);
         }
@@ -81,6 +85,8 @@ public function close(Connection $connection): void
 
         $connection->disconnect();
 
+        WebSocketDisconnect::dispatch($connection);
+
         Log::info('Connection Closed', $connection->id());
     }