From cc9fb7d7eb6867b7efa98de370b2b75f38dad2ab Mon Sep 17 00:00:00 2001
From: freek <freek@spatie.be>
Date: Mon, 26 Nov 2018 22:05:24 +0100
Subject: [PATCH] commit

---
 src/Dashboard/EventHandler.php              |  8 ------
 src/Dashboard/EventSubscriber.php           | 27 +++++++++++++++++++++
 src/Events/ClientMessageSent.php            | 22 +++++++++++++++++
 src/LaravelEcho/Pusher/Channels/Channel.php |  1 -
 src/LaravelEcho/WebSocket/Message.php       |  3 ++-
 src/WebSocketsServiceProvider.php           |  4 +++
 6 files changed, 55 insertions(+), 10 deletions(-)
 delete mode 100644 src/Dashboard/EventHandler.php
 create mode 100644 src/Dashboard/EventSubscriber.php
 create mode 100644 src/Events/ClientMessageSent.php

diff --git a/src/Dashboard/EventHandler.php b/src/Dashboard/EventHandler.php
deleted file mode 100644
index 460b2b6..0000000
--- a/src/Dashboard/EventHandler.php
+++ /dev/null
@@ -1,8 +0,0 @@
-<?php
-
-namespace BeyondCode\LaravelWebSockets\Dashboard;
-
-class EventHandler
-{
-    //TODO: listen for events, pass them to Dashboard:: methods
-}
\ No newline at end of file
diff --git a/src/Dashboard/EventSubscriber.php b/src/Dashboard/EventSubscriber.php
new file mode 100644
index 0000000..7f75044
--- /dev/null
+++ b/src/Dashboard/EventSubscriber.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Dashboard;
+
+use BeyondCode\LaravelWebSockets\Events\ChannelVacated;
+use BeyondCode\LaravelWebSockets\Events\ClientMessageSent;
+use BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Dashboard;
+use Illuminate\Events\Dispatcher;
+
+class EventSubscriber
+{
+    public function onChannelVacated(ChannelVacated $event)
+    {
+        Dashboard::vacated($event->connection, $event->channelId);
+    }
+
+    public function onClientMessageSent(ClientMessageSent $event)
+    {
+        Dashboard::clientMessage($event->connection, $event->payload);
+    }
+
+    public function subscribe(Dispatcher $events)
+    {
+        $events->listen(ChannelVacated::class, static::class . '@onChannelVacated');
+        $events->listen(ClientMessageSent::class, static::class . '@onClientMessageSent');
+    }
+}
\ No newline at end of file
diff --git a/src/Events/ClientMessageSent.php b/src/Events/ClientMessageSent.php
new file mode 100644
index 0000000..7c171ed
--- /dev/null
+++ b/src/Events/ClientMessageSent.php
@@ -0,0 +1,22 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Ratchet\ConnectionInterface;
+use stdClass;
+
+class ClientMessageSent
+{
+    /** @var \Ratchet\ConnectionInterface */
+    public $connection;
+
+    /** @var string */
+    public $payload;
+
+    public function __construct(ConnectionInterface $connection, stdClass $payload)
+    {
+        $this->connection = $connection;
+
+        $this->payload = $payload;
+    }
+}
\ No newline at end of file
diff --git a/src/LaravelEcho/Pusher/Channels/Channel.php b/src/LaravelEcho/Pusher/Channels/Channel.php
index 759c83c..d7a1b3e 100644
--- a/src/LaravelEcho/Pusher/Channels/Channel.php
+++ b/src/LaravelEcho/Pusher/Channels/Channel.php
@@ -61,7 +61,6 @@ class Channel
 
         if (! $this->hasConnections()) {
             event(new ChannelVacated($connection, $this->channelId));
-            Dashboard::vacated($connection, $this->channelId);
         }
     }
 
diff --git a/src/LaravelEcho/WebSocket/Message.php b/src/LaravelEcho/WebSocket/Message.php
index 5617f59..72197eb 100644
--- a/src/LaravelEcho/WebSocket/Message.php
+++ b/src/LaravelEcho/WebSocket/Message.php
@@ -2,6 +2,7 @@
 
 namespace BeyondCode\LaravelWebSockets\LaravelEcho\WebSocket;
 
+use BeyondCode\LaravelWebSockets\Events\ClientMessageSent;
 use BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Channels\ChannelManager;
 use BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Dashboard;
 use Ratchet\ConnectionInterface;
@@ -30,7 +31,7 @@ class Message implements RespondableMessage
     public function respond()
     {
         if (starts_with($this->payload->event, 'client-')) {
-            Dashboard::clientMessage($this->connection, $this->payload);
+            event(new ClientMessageSent($this->connection, $this->payload));
 
             $channel = $this->channelManager->find($this->connection->client->appId, $this->payload->channel);
 
diff --git a/src/WebSocketsServiceProvider.php b/src/WebSocketsServiceProvider.php
index 49a185e..5f1168f 100644
--- a/src/WebSocketsServiceProvider.php
+++ b/src/WebSocketsServiceProvider.php
@@ -2,6 +2,8 @@
 
 namespace BeyondCode\LaravelWebSockets;
 
+use BeyondCode\LaravelWebSockets\Dashboard\EventSubscriber;
+use Illuminate\Support\Facades\Event;
 use Illuminate\Support\Facades\Gate;
 use Illuminate\Support\Facades\Route;
 use BeyondCode\LaravelWebSockets\ClientProviders\ClientProvider;
@@ -27,6 +29,8 @@ class WebSocketsServiceProvider extends ServiceProvider
         $this->commands([
             Console\StartWebSocketServer::class,
         ]);
+
+        Event::subscribe(EventSubscriber::class);
     }
 
     protected function registerRoutes()