force cancel on connection close
This commit is contained in:
parent
68fb6666ff
commit
61b114a999
1 changed files with 4 additions and 0 deletions
|
@ -240,6 +240,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
|
||||||
if (empty($project->getId())) {
|
if (empty($project->getId())) {
|
||||||
$server->push($connection, 'Missing or unknown project ID');
|
$server->push($connection, 'Missing or unknown project ID');
|
||||||
$server->close($connection);
|
$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') {
|
if ($abuse->check() && App::getEnv('_APP_OPTIONS_ABUSE', 'enabled') === 'enabled') {
|
||||||
$server->push($connection, 'Too many requests');
|
$server->push($connection, 'Too many requests');
|
||||||
$server->close($connection);
|
$server->close($connection);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -271,6 +273,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
|
||||||
if (!$originValidator->isValid($origin)) {
|
if (!$originValidator->isValid($origin)) {
|
||||||
$server->push($connection, $originValidator->getDescription());
|
$server->push($connection, $originValidator->getDescription());
|
||||||
$server->close($connection);
|
$server->close($connection);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Realtime::setUser($user);
|
Realtime::setUser($user);
|
||||||
|
@ -284,6 +287,7 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
|
||||||
if (empty($channels)) {
|
if (empty($channels)) {
|
||||||
$server->push($connection, 'Missing channels');
|
$server->push($connection, 'Missing channels');
|
||||||
$server->close($connection);
|
$server->close($connection);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Realtime::subscribe($project->getId(), $connection, $roles, $subscriptions, $connections, $channels);
|
Realtime::subscribe($project->getId(), $connection, $roles, $subscriptions, $connections, $channels);
|
||||||
|
|
Loading…
Reference in a new issue