Skip to content
This repository has been archived by the owner on Feb 7, 2024. It is now read-only.

Commit

Permalink
Removed replicator-message-published
Browse files Browse the repository at this point in the history
  • Loading branch information
rennokki committed Oct 7, 2020
1 parent 0ca6355 commit 6a04f9c
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 11 deletions.
2 changes: 1 addition & 1 deletion resources/views/dashboard.blade.php
Original file line number Diff line number Diff line change
Expand Up @@ -428,7 +428,7 @@ class="rounded-full px-3 py-1 inline-block text-sm"
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';
}
Expand Down
7 changes: 0 additions & 7 deletions src/ChannelManagers/RedisChannelManager.php
Original file line number Diff line number Diff line change
Expand Up @@ -287,13 +287,6 @@ public function broadcastAcrossServers($appId, ?string $socketId, string $channe
$payload->socketId = $socketId;
$payload->serverId = $serverId ?: $this->getServerId();

DashboardLogger::log($appId, DashboardLogger::TYPE_REPLICATOR_MESSAGE_PUBLISHED, [
'fromServerId' => $serverId,
'fromSocketId' => $socketId,
'channel' => $channel,
'payload' => $payload,
]);

return $this->publishClient
->publish($this->getRedisKey($appId, $channel), json_encode($payload))
->then(function () use ($appId, $socketId, $channel, $payload, $serverId) {
Expand Down
3 changes: 0 additions & 3 deletions src/DashboardLogger.php
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,6 @@ class DashboardLogger

const TYPE_REPLICATOR_UNSUBSCRIBED = 'replicator-unsubscribed';

const TYPE_REPLICATOR_MESSAGE_PUBLISHED = 'replicator-message-published';

const TYPE_REPLICATOR_MESSAGE_RECEIVED = 'replicator-message-received';

/**
Expand All @@ -39,7 +37,6 @@ class DashboardLogger
self::TYPE_API_MESSAGE,
self::TYPE_REPLICATOR_SUBSCRIBED,
self::TYPE_REPLICATOR_UNSUBSCRIBED,
self::TYPE_REPLICATOR_MESSAGE_PUBLISHED,
self::TYPE_REPLICATOR_MESSAGE_RECEIVED,
];

Expand Down

0 comments on commit 6a04f9c

Please sign in to comment.