Method handleMessage

projects/runtime/src/server.ts:234–258

(connection: RuntimeConnection, raw: string)

    }

    async handleMessage(connection: RuntimeConnection, raw: string): Promise<void> {
        let message: unknown
        try {
            message = JSON.parse(raw)
        } catch (error) {
            connection.send({
                id: "parse-error",
                error: runtimeError("parse_error", error instanceof Error ? error.message : "Invalid JSON"),
            })
            return
        }

        const request = validateRuntimeRequest(message)
        if (!request.ok) {
            const id = typeof (message as { id?: unknown })?.id === "string" || typeof (message as { id?: unknown })?.id === "number" ? (message as { id: string | number }).id : "invalid-message"
            connection.send({
                id,
                error: runtimeError(request.error.code, request.error.message, { path: request.error.path }),
            })
            return
        }

        const response = await this.handleRequest(request.value, connection, { requireInitialized: true })
        connection.send(response)
    }

    async handleRequest(request: RuntimeRequest, connection: RuntimeConnection, options: { requireInitialized?: boolean } = {}): Promise<RuntimeResponse> {
        if (options.requireInitialized && request.method !== "initialize" && !this.initializedConnections.has(connection.id)) {