kiri-core/HttpServer/Events/OnMessage.php

<?php
declare(strict_types=1);

namespace HttpServer\Events;


use Annotation\Route\Socket;
use Exception;
use HttpServer\Abstracts\Callback;
use HttpServer\Http\Context;
use HttpServer\Http\HttpHeaders;
use HttpServer\Http\HttpParams;
use HttpServer\Http\Request;
use ReflectionException;
use Snowflake\Abstracts\Config;
use Snowflake\Core\Json;
use Snowflake\Event;
use Snowflake\Exception\ComponentException;
use Snowflake\Exception\ConfigException;
use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake;
use Swoole\Coroutine;
use Swoole\WebSocket\Frame;
use Swoole\WebSocket\Server;

/**
 * Class OnMessage
 * @package HttpServer\Events
 */
class OnMessage extends Callback
{

    /**
     * @param Server $server
     * @param Frame $frame
     * @throws
     */
    public function onHandler(Server $server, Frame $frame)
    {
        try {
            defer(function () {
                fire(Event::SYSTEM_RESOURCE_CLEAN);
            });
            if ($frame->opcode === 0x08) {
                return;
            }
            $clientInfo = $server->getClientInfo($frame->fd);
            $event = Snowflake::app()->getEvent();

            if (!$event->exists(($name = $this->getName($clientInfo)))) {
                return;
            }
            $event->trigger($name, [$frame, $server]);
        } catch (\Throwable $exception) {
            $this->addError($exception, 'websocket');
            if (!swoole()->exist($frame->fd)) {
                return;
            }
            $server->send($frame->fd, $exception->getMessage());
        }
    }


    /**
     * @param $clientInfo
     * @return string
     */
    private function getName($clientInfo): string
    {
        return 'listen ' . $clientInfo['server_port'] . ' ' . Event::SERVER_MESSAGE;
    }

}