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

Collect metrics only if statistics are enabled.

This commit is contained in:
Alex Renoki 2020-12-08 16:52:55 +02:00
parent 81ee07f003
commit 9c41cf32a2
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/API/TriggerEvent.php
View File

@ -49,7 +49,9 @@ class TriggerEvent extends Controller
$request->appId, $request->socket_id, $channelName, (object) $payload $request->appId, $request->socket_id, $channelName, (object) $payload
); );
StatisticsCollector::apiMessage($request->appId); if ($this->app->statisticsEnabled) {
StatisticsCollector::apiMessage($request->appId);
}
DashboardLogger::log($request->appId, DashboardLogger::TYPE_API_MESSAGE, [ DashboardLogger::log($request->appId, DashboardLogger::TYPE_API_MESSAGE, [
'event' => $request->name, 'event' => $request->name,

12
src/Server/WebSocketHandler.php
View File

@ -56,7 +56,9 @@ class WebSocketHandler implements MessageComponentInterface
/** @var \GuzzleHttp\Psr7\Request $request */ /** @var \GuzzleHttp\Psr7\Request $request */
$request = $connection->httpRequest; $request = $connection->httpRequest;
StatisticsCollector::connection($connection->app->id); if ($connection->app->statisticsEnabled) {
StatisticsCollector::connection($connection->app->id);
}
$this->channelManager->subscribeToApp($connection->app->id); $this->channelManager->subscribeToApp($connection->app->id);
@ -88,7 +90,9 @@ class WebSocketHandler implements MessageComponentInterface
$message, $connection, $this->channelManager $message, $connection, $this->channelManager
)->respond(); )->respond();
StatisticsCollector::webSocketMessage($connection->app->id); if ($connection->app->statisticsEnabled) {
StatisticsCollector::webSocketMessage($connection->app->id);
}
WebSocketMessageReceived::dispatch( WebSocketMessageReceived::dispatch(
$connection->app->id, $connection->app->id,
@ -109,7 +113,9 @@ class WebSocketHandler implements MessageComponentInterface
->unsubscribeFromAllChannels($connection) ->unsubscribeFromAllChannels($connection)
->then(function (bool $unsubscribed) use ($connection) { ->then(function (bool $unsubscribed) use ($connection) {
if (isset($connection->app)) { if (isset($connection->app)) {
StatisticsCollector::disconnection($connection->app->id); if ($connection->app->statisticsEnabled) {
StatisticsCollector::disconnection($connection->app->id);
}
$this->channelManager->unsubscribeFromApp($connection->app->id); $this->channelManager->unsubscribeFromApp($connection->app->id);