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

Removed replicator-message-published

This commit is contained in:
Alex Renoki 2020-10-07 23:28:38 +03:00
parent 0ca6355aa6
commit 6a04f9ce4c
3 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
resources/views/dashboard.blade.php
View File

@ -428,7 +428,7 @@
return 'bg-red-700 text-white'; return 'bg-red-700 text-white';
} }
if (['api_message', 'replicator-message-published', 'replicator-message-received'].includes(log.type)) { if (['api_message', 'replicator-message-received'].includes(log.type)) {
return 'bg-black text-white'; return 'bg-black text-white';
} }

7
src/ChannelManagers/RedisChannelManager.php
View File

@ -287,13 +287,6 @@ class RedisChannelManager extends LocalChannelManager
$payload->socketId = $socketId; $payload->socketId = $socketId;
$payload->serverId = $serverId ?: $this->getServerId(); $payload->serverId = $serverId ?: $this->getServerId();
DashboardLogger::log($appId, DashboardLogger::TYPE_REPLICATOR_MESSAGE_PUBLISHED, [
'fromServerId' => $serverId,
'fromSocketId' => $socketId,
'channel' => $channel,
'payload' => $payload,
]);
return $this->publishClient return $this->publishClient
->publish($this->getRedisKey($appId, $channel), json_encode($payload)) ->publish($this->getRedisKey($appId, $channel), json_encode($payload))
->then(function () use ($appId, $socketId, $channel, $payload, $serverId) { ->then(function () use ($appId, $socketId, $channel, $payload, $serverId) {

3
src/DashboardLogger.php
View File

@ -22,8 +22,6 @@ class DashboardLogger
const TYPE_REPLICATOR_UNSUBSCRIBED = 'replicator-unsubscribed'; const TYPE_REPLICATOR_UNSUBSCRIBED = 'replicator-unsubscribed';
const TYPE_REPLICATOR_MESSAGE_PUBLISHED = 'replicator-message-published';
const TYPE_REPLICATOR_MESSAGE_RECEIVED = 'replicator-message-received'; const TYPE_REPLICATOR_MESSAGE_RECEIVED = 'replicator-message-received';
/** /**
@ -39,7 +37,6 @@ class DashboardLogger
self::TYPE_API_MESSAGE, self::TYPE_API_MESSAGE,
self::TYPE_REPLICATOR_SUBSCRIBED, self::TYPE_REPLICATOR_SUBSCRIBED,
self::TYPE_REPLICATOR_UNSUBSCRIBED, self::TYPE_REPLICATOR_UNSUBSCRIBED,
self::TYPE_REPLICATOR_MESSAGE_PUBLISHED,
self::TYPE_REPLICATOR_MESSAGE_RECEIVED, self::TYPE_REPLICATOR_MESSAGE_RECEIVED,
]; ];