CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-06-02 19:04:49 +12:00
Code Issues Projects Releases Wiki Activity

fix(realtime): project stats channel

Browse source
This commit is contained in:
Torsten Dittmann 2021-06-08 14:09:50 +02:00
parent f0d3b2f22a
commit f76695fb09
1 changed files with 11 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
app/realtime.php
View file

@ -102,19 +102,17 @@ $server->on('workerStart', function ($server, $workerId) use (&$subscriptions, &
$payload[$projectId] = $value['connectionsTotal'];
}
foreach ($subscriptions['console']['role:member']['project'] as $connection => $value) {
foreach ($stats as $projectId => $value) {
$server->push(
$connection,
json_encode([
'event' => 'stats.connections',
'channels' => ['project'],
'timestamp' => time(),
'payload' => $payload
]),
SWOOLE_WEBSOCKET_OPCODE_TEXT,
SWOOLE_WEBSOCKET_FLAG_FIN | SWOOLE_WEBSOCKET_FLAG_COMPRESS
);
}
$server->push(
$connection,
json_encode([
'event' => 'stats.connections',
'channels' => ['project'],
'timestamp' => time(),
'payload' => $payload
]),
SWOOLE_WEBSOCKET_OPCODE_TEXT,
SWOOLE_WEBSOCKET_FLAG_FIN | SWOOLE_WEBSOCKET_FLAG_COMPRESS
);
}
}
});