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-support' into feat-265-realtime-e2e

Browse source
This commit is contained in:
Torsten Dittmann 2021-03-02 11:23:47 +01:00
parent 03330ea607 61b114a999
commit 0f6e33f4ed
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
app/realtime.php
View file

@ -240,6 +240,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
if (empty($project->getId())) {
$server->push($connection, 'Missing or unknown project ID');
$server->close($connection);
return;
}
/*
@ -258,6 +259,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
if ($abuse->check() && App::getEnv('_APP_OPTIONS_ABUSE', 'enabled') === 'enabled') {
$server->push($connection, 'Too many requests');
$server->close($connection);
return;
}
/*
@ -271,6 +273,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
if (!$originValidator->isValid($origin)) {
$server->push($connection, $originValidator->getDescription());
$server->close($connection);
return;
}
Realtime::setUser($user);
@ -284,6 +287,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
if (empty($channels)) {
$server->push($connection, 'Missing channels');
$server->close($connection);
return;
}
Realtime::subscribe($project->getId(), $connection, $roles, $subscriptions, $connections, $channels);