From dea1fa03326304369bdf7de4dc0fcd5ce8b7e434 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 2 Sep 2020 14:02:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- http-server/Events/OnMessage.php | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/http-server/Events/OnMessage.php b/http-server/Events/OnMessage.php index a2ea667c..4a3b88a4 100644 --- a/http-server/Events/OnMessage.php +++ b/http-server/Events/OnMessage.php @@ -29,7 +29,6 @@ class OnMessage extends Callback if ($frame->opcode == 0x08) { return; } - $event = Snowflake::get()->event; if ($event->exists(Event::SERVER_MESSAGE)) { $event->trigger(Event::SERVER_MESSAGE, [$server, $frame]); @@ -39,7 +38,11 @@ class OnMessage extends Callback /** @var AWebsocket $manager */ $manager = Snowflake::get()->annotation->get('websocket'); - $manager->runWith($manager->getName(AWebsocket::MESSAGE, [null, null, $frame->data['route']]), [$frame, $server]); + if (!isset($frame->data['route'])) { + throw new \Exception('Fromat errr.'); + } + $events = $manager->getName(AWebsocket::MESSAGE, [null, null, $frame->data['route']]); + $manager->runWith($events, [$frame, $server]); } catch (\Exception $exception) { $this->addError($exception->getMessage(), 'websocket'); $server->send($frame->fd, $exception->getMessage()); @@ -51,6 +54,4 @@ class OnMessage extends Callback } - - }