1
0
Fork 0
mirror of synced 2024-06-11 07:14:51 +12:00

fix(console): realtime

This commit is contained in:
Torsten Dittmann 2021-08-17 10:58:33 +02:00
parent 32328e7c6f
commit e0f0a6e24b
3 changed files with 9 additions and 7 deletions

View file

@ -465,7 +465,7 @@ App::setResource('user', function($mode, $project, $console, $request, $response
} catch (JWTException $error) {
throw new Exception('Failed to verify JWT. '.$error->getMessage(), 401);
}
$jwtUserId = $payload['userId'] ?? '';
$jwtSessionId = $payload['sessionId'] ?? '';

View file

@ -95,14 +95,16 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
$event = [
'project' => 'console',
'event' => 'stats.connections',
'channels' => ['project'],
'roles' => ['role:member'],
'timestamp' => time(),
'payload' => $payload
'data' => [
'event' => 'stats.connections',
'channels' => ['project'],
'timestamp' => time(),
'payload' => $payload
]
];
$server->send($realtime->getSubscribers($event), json_encode($event));
$server->send($realtime->getSubscribers($event), json_encode($event['data']));
}
});

View file

@ -512,7 +512,7 @@
* @param {string} failure
* @param {string[]} scopes
* @throws {AppwriteException}
* @returns {void|string}
* @returns {void|URL}
*/
createOAuth2Session: (provider, success, failure, scopes) => {
if (typeof provider === 'undefined') {