CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-05-18 19:52:39 +12:00
Code Issues Projects Releases Wiki Activity

fix permission handling for stats

Browse source
This commit is contained in:
Torsten Dittmann 2021-08-19 12:14:19 +02:00
parent da92c5e2be
commit 10cdb33585
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
app/realtime.php
View file

@ -34,6 +34,7 @@ $connections = [];
$stats = new Table(4096, 1);
$stats->column('projectId', Table::TYPE_STRING, 64);
$stats->column('teamId', Table::TYPE_STRING, 64);
$stats->column('connections', Table::TYPE_INT);
$stats->column('connectionsTotal', Table::TYPE_INT);
$stats->column('messages', Table::TYPE_INT);
@ -64,7 +65,6 @@ $server->onStart(function () use ($stats) {
->setParam('networkResponseSize', 0);
$stats->set($projectId, [
'projectId' => $projectId,
'messages' => 0,
'connections' => 0
]);
@ -90,11 +90,11 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
if ($realtime->hasSubscriber('console', 'role:member', 'project')) {
foreach ($stats as $projectId => $value) {
$payload = [
'projectId' => $value['connectionsTotal']
$projectId => $value['connectionsTotal']
];
$event = [
'project' => 'console',
'roles' => ['team:'.$projectId],
'roles' => ['team:'.$value['teamId']],
'data' => [
'event' => 'stats.connections',
'channels' => ['project'],
@ -298,6 +298,10 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server,
$server->send([$connection], json_encode($channels));
$stats->set($project->getId(), [
'projectId' => $project->getId(),
'teamId' => $project->getAttribute('teamId')
]);
$stats->incr($project->getId(), 'connections');
$stats->incr($project->getId(), 'connectionsTotal');
} catch (\Throwable $th) {