This commit is contained in:
2020-12-21 17:31:11 +08:00
parent ca1b094ba3
commit 660dda4454
+8 -5
View File
@@ -28,12 +28,15 @@ class OnMessage extends Callback
public function onHandler(Server $server, Frame $frame) public function onHandler(Server $server, Frame $frame)
{ {
try { try {
if ($frame->opcode == 0x08) {
return;
}
Coroutine::defer(fn() => fire(Event::EVENT_AFTER_REQUEST));
$event = Snowflake::app()->getEvent(); $event = Snowflake::app()->getEvent();
if ($frame->opcode != 0x08) { $content = $this->resolve($event, $frame, $server);
$content = $this->resolve($event, $frame, $server); if (!empty($content)) {
if (!empty($content)) { $server->send($frame->fd, $content);
$server->send($frame->fd, $content);
}
} }
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
$this->addError($exception->getMessage(), 'websocket'); $this->addError($exception->getMessage(), 'websocket');