Method accept

framework/framework/router.ts:24–38

(socket: WebSocket, request: IncomingMessage, ctx: KoaContext)

    }

    accept(socket: WebSocket, request: IncomingMessage, ctx: KoaContext) {
        const match = this.regexp.exec(new URL(request.url, `http://${request.headers.host}`).pathname);
        if (!match) return false;
        ctx.params ||= {};
        for (let i = 0; i < this.keys.length; i++) {
            ctx.params[this.keys[i].name] = match[i + 1];
            ctx.HydroContext.args[this.keys[i].name] = match[i + 1];
        }
        this.clients.add(socket);
        socket.on('close', () => {
            this.clients.delete(socket);
        });
        this.callback?.(socket, request, ctx);
        return true;
    }

    close() {
        for (const socket of this.clients) {