as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-09-02 14:02:20 +08:00
parent 02b8bdbf9b
commit dea1fa0332
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
http-server/Events/OnMessage.php
+5 -4
View File
@@ -29,7 +29,6 @@ class OnMessage extends Callback
if ($frame->opcode == 0x08) { if ($frame->opcode == 0x08) {
return; return;
} }
$event = Snowflake::get()->event; $event = Snowflake::get()->event;
if ($event->exists(Event::SERVER_MESSAGE)) { if ($event->exists(Event::SERVER_MESSAGE)) {
$event->trigger(Event::SERVER_MESSAGE, [$server, $frame]); $event->trigger(Event::SERVER_MESSAGE, [$server, $frame]);
@@ -39,7 +38,11 @@ class OnMessage extends Callback
/** @var AWebsocket $manager */ /** @var AWebsocket $manager */
$manager = Snowflake::get()->annotation->get('websocket'); $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) { } catch (\Exception $exception) {
$this->addError($exception->getMessage(), 'websocket'); $this->addError($exception->getMessage(), 'websocket');
$server->send($frame->fd, $exception->getMessage()); $server->send($frame->fd, $exception->getMessage());
@@ -51,6 +54,4 @@ class OnMessage extends Callback
} }
} }