Method handleMessage

projects/runtime-client/src/client.ts:226–253

(raw: string)

    }

    private handleMessage(raw: string): void {
        let message: unknown
        try {
            message = JSON.parse(raw)
        } catch {
            return
        }

        const response = validateRuntimeResponse(message)
        if (response.ok) {
            const pending = this.pending.get(response.value.id)
            if (!pending) return
            this.pending.delete(response.value.id)
            if (response.value.error) {
                pending.reject(new RuntimeClientError(response.value.error.code, response.value.error.message, response.value.error.data))
            } else {
                pending.resolve(response.value.result)
            }
            return
        }

        if (isRuntimeNotification(message)) {
            if (typeof message.cursor === "string") this.lastCursor = message.cursor
            for (const listener of this.listeners) {
                listener(message)
            }
        }
    }
}

export class RuntimeLocalClient {