Method write

test/bindingRuntime.misc.test.ts:116–163

(message: JsonRpcMessage)

  }

  write(message: JsonRpcMessage): void {
    this.written.push(message);
    if (!('method' in message)) return;

    const req = message as JsonRpcRequest;
    if (req.method === 'initialize') {
      queueMicrotask(() => {
        this.emit({
          jsonrpc: '2.0',
          id: req.id,
          result: {
            protocolVersion: 1,
            agentCapabilities: { loadSession: this.loadSession },
          },
        } as JsonRpcResponse);
      });
      return;
    }

    if (req.method === 'session/new') {
      queueMicrotask(() => {
        this.emit({
          jsonrpc: '2.0',
          id: req.id,
          result: { sessionId: this.sessionId },
        } as JsonRpcResponse);
      });
      return;
    }

    if (req.method === 'session/prompt') {
      this.promptRequests.push(req);
      queueMicrotask(() => {
        this.updates.forEach((update) => {
          this.emit({
            jsonrpc: '2.0',
            method: 'session/update',
            params: { sessionId: this.sessionId, update },
          } as any);
        });
        this.emit({
          jsonrpc: '2.0',
          id: req.id,
          result: { stopReason: 'end' },
        } as JsonRpcResponse);
      });
    }
  }

  onMessage(cb: (message: JsonRpcMessage) => void): void {
    this.handlers.push(cb);