Class RuntimeClient

projects/runtime-client/src/client.ts:54–254

}

export class RuntimeClient {
    private socket: WebSocket | null = null
    private nextId = 1
    private retryMs = 1000
    private stopped = false
    private connecting: Promise<void> | null = null
    private lastStatus: RuntimeClientStatus | null = null
    private lastCursor: string | null = null
    private readonly pending = new Map<RuntimeRequestId, { resolve: (value: unknown) => void; reject: (error: Error) => void }>()
    private readonly listeners = new Set<NotificationListener>()

    constructor(private readonly options: RuntimeClientOptions) {}

    async request<T>(method: string, params?: unknown): Promise<T> {
        await this.connect()

        const socket = this.socket
        if (!socket || socket.readyState !== WebSocket.OPEN) throw new Error("Runtime socket is not connected")

        return this.sendRequest<T>(socket, method, params)
    }

    private sendRequest<T>(socket: WebSocket, method: string, params?: unknown): Promise<T> {
        const id = this.nextId++
        const message = params === undefined ? { id, method } : { id, method, params }

        return new Promise<T>((resolve, reject) => {
            this.pending.set(id, {
                resolve: (value) => resolve(value as T),
                reject,
            })
            try {
                socket.send(JSON.stringify(message))
            } catch (error) {
                this.pending.delete(id)
                reject(error instanceof Error ? error : new Error("Runtime socket send failed"))
            }
        })
    }

    subscribe(listener: NotificationListener): () => void {
        this.listeners.add(listener)
        this.connectQuietly()
        return () => {
            this.listeners.delete(listener)
        }
    }

    close(): void {
        this.stopped = true
        this.socket?.close()
        this.socket = null
        for (const pending of this.pending.values()) {
            pending.reject(new Error("Runtime socket closed"))
        }
        this.pending.clear()
        this.emitStatus("disconnected")
    }