blax-software
/
laravel-websockets
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wip

This commit is contained in:
Marcel Pociot 2018-11-27 16:09:35 +01:00
parent 0bb6a1bba1 0641dd6bdf
commit 5f44e177b3
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/Dashboard/EventSubscriber.php
View File

@ -8,14 +8,14 @@ use BeyondCode\LaravelWebSockets\Events\ChannelVacated;
use BeyondCode\LaravelWebSockets\Events\ClientMessageSent; use BeyondCode\LaravelWebSockets\Events\ClientMessageSent;
use BeyondCode\LaravelWebSockets\Events\ConnectionEstablished; use BeyondCode\LaravelWebSockets\Events\ConnectionEstablished;
use BeyondCode\LaravelWebSockets\Events\SubscribedToChannel; use BeyondCode\LaravelWebSockets\Events\SubscribedToChannel;
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Dashboard; use BeyondCode\LaravelWebSockets\WebSocket\Pusher\DashboardLogger;
use Illuminate\Events\Dispatcher; use Illuminate\Events\Dispatcher;
class EventSubscriber class EventSubscriber
{ {
public function onApiMessageSent(ApiMessageSent $event) public function onApiMessageSent(ApiMessageSent $event)
{ {
Dashboard::apiMessage( DashboardLogger::apiMessage(
$event->appId, $event->appId,
$event->channeldId, $event->channeldId,
$event->name, $event->name,
@ -25,27 +25,27 @@ class EventSubscriber
public function onChannelOccupied(ChannelOccupied $event) public function onChannelOccupied(ChannelOccupied $event)
{ {
Dashboard::occupied($event->connection, $event->channelId); DashboardLogger::occupied($event->connection, $event->channelId);
} }
public function onChannelVacated(ChannelVacated $event) public function onChannelVacated(ChannelVacated $event)
{ {
Dashboard::vacated($event->connection, $event->channelId); DashboardLogger::vacated($event->connection, $event->channelId);
} }
public function onClientMessageSent(ClientMessageSent $event) public function onClientMessageSent(ClientMessageSent $event)
{ {
Dashboard::clientMessage($event->connection, $event->payload); DashboardLogger::clientMessage($event->connection, $event->payload);
} }
public function onConnectionEstablished(ConnectionEstablished $event) public function onConnectionEstablished(ConnectionEstablished $event)
{ {
Dashboard::connection($event->connection); DashboardLogger::connection($event->connection);
} }
public function onSubscribedToChannel(SubscribedToChannel $event) public function onSubscribedToChannel(SubscribedToChannel $event)
{ {
Dashboard::subscribed($event->connection, $event->channelId); DashboardLogger::subscribed($event->connection, $event->channelId);
} }
public function subscribe(Dispatcher $events) public function subscribe(Dispatcher $events)

2
src/WebSocket/Pusher/Dashboard.php → src/WebSocket/Pusher/DashboardLogger.php
View File

@ -6,7 +6,7 @@ use Ratchet\ConnectionInterface;
use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager; use BeyondCode\LaravelWebSockets\WebSocket\Pusher\Channels\ChannelManager;
use stdClass; use stdClass;
class Dashboard class DashboardLogger
{ {
const LOG_CHANNEL_PREFIX = 'private-websockets-dashboard-'; const LOG_CHANNEL_PREFIX = 'private-websockets-dashboard-';
const TYPE_DISCONNECTION = 'disconnection'; const TYPE_DISCONNECTION = 'disconnection';