CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-06-09 14:24:44 +12:00
Code Issues Projects Releases Wiki Activity

fix(realtime): proper permission handling for realtime stats

Browse source
This commit is contained in:
Torsten Dittmann 2021-08-19 11:41:08 +02:00
parent 54600d0015
commit da92c5e2be
1 changed files with 15 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
app/realtime.php
View file

@ -88,23 +88,23 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
* Sending current connections to project channels on the console project every 5 seconds.
*/
if ($realtime->hasSubscriber('console', 'role:member', 'project')) {
$payload = [];
foreach ($stats as $projectId => $value) {
$payload[$projectId] = $value['connectionsTotal'];
$payload = [
'projectId' => $value['connectionsTotal']
];
$event = [
'project' => 'console',
'roles' => ['team:'.$projectId],
'data' => [
'event' => 'stats.connections',
'channels' => ['project'],
'timestamp' => time(),
'payload' => $payload
]
];
$server->send($realtime->getSubscribers($event), json_encode($event['data']));
}
$event = [
'project' => 'console',
'roles' => ['role:member'],
'data' => [
'event' => 'stats.connections',
'channels' => ['project'],
'timestamp' => time(),
'payload' => $payload
]
];
$server->send($realtime->getSubscribers($event), json_encode($event['data']));
}
/**
* Sending test message for SDK E2E tests every 5 seconds.