CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-06-26 18:20:43 +12:00
Code Issues Projects Releases Wiki Activity

Merge branch 'feat-265-realtime' of https://github.com/appwrite/appwrite into feat-265-realtime-console

Browse source
This commit is contained in:
Torsten Dittmann 2021-08-27 18:33:21 +02:00
parent a944975dcb e4451f7e0b
commit 0402adff82
2 changed files with 21 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
app/realtime.php
View file

@ -204,6 +204,10 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
}
foreach ($stats as $projectId => $value) {
if (!array_key_exists($projectId, $payload)) {
continue;
}
$event = [
'project' => 'console',
'roles' => ['team:' . $value['teamId']],
@ -451,8 +455,8 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server,
if (App::isDevelopment()) {
Console::error("[Error] Connection Error");
Console::error("[Error] Code: " . $response['code']);
Console::error("[Error] Message: " . $response['message']);
Console::error("[Error] Code: " . $response['data']['code']);
Console::error("[Error] Message: " . $response['data']['message']);
}
if ($th instanceof PDOException) {

22
tests/benchmarks/ws.js
View file

@ -6,12 +6,12 @@ import { check } from 'k6';
export let options = {
stages: [
{
duration: '10s',
{
duration: '10s',
target: 500
},
{
duration: '1m',
{
duration: '1m',
target: 500
},
],
@ -21,7 +21,7 @@ export default function () {
// const url = new URL('wss://appwrite-realtime.monitor-api.com/v1/realtime');
// url.searchParams.append('project', '604249e6b1a9f');
const url = new URL('ws://localhost/v1/realtime');
url.searchParams.append('project', 'console');
url.searchParams.append('project', '612625394933c');
url.searchParams.append('channels[]', 'files');
const res = ws.connect(url.toString(), function (socket) {
@ -41,10 +41,18 @@ export default function () {
check(payload, {
'connection opened': (r) => connection,
'message received': (r) => checked,
'channels are right': (r) => r === `{"files":0}`
'channels are right': (r) => r === JSON.stringify({
"type": "connected",
"data": {
"channels": [
"files"
],
"user": null
}
})
})
socket.close();
}, 5000);
}, 5000);
});
check(res, { 'status is 101': (r) => r && r.status === 101 });