Class PermReqRpc

test/bindingRuntime.misc.test.ts:37–100

}

class PermReqRpc implements StdioProcess {
  private handlers: Array<(m: JsonRpcMessage) => void> = [];
  written: JsonRpcMessage[] = [];

  write(message: JsonRpcMessage): void {
    this.written.push(message);

    if ('method' in message) {
      const req = message as JsonRpcRequest;
      if (req.method === 'initialize') {
        queueMicrotask(() =>
          this.emit({
            jsonrpc: '2.0',
            id: req.id,
            result: { protocolVersion: 1, agentCapabilities: {} },
          } as any),
        );
      }
      if (req.method === 'session/new') {
        queueMicrotask(() =>
          this.emit({
            jsonrpc: '2.0',
            id: req.id,
            result: { sessionId: 'sess' },
          } as any),
        );
      }
      if (req.method === 'session/prompt') {
        queueMicrotask(() => {
          this.emit({
            jsonrpc: '2.0',
            id: 999,
            method: 'session/request_permission',
            params: {
              sessionId: 'sess',
              toolCall: { title: 'terminal/create', kind: 'execute' },
              options: [
                { optionId: 'a1', name: 'Allow once', kind: 'allow_once' },
                { optionId: 'r1', name: 'Reject once', kind: 'reject_once' },
              ],
            },
          } as any);

          this.emit({
            jsonrpc: '2.0',
            id: req.id,
            result: { stopReason: 'end' },
          } as any);
        });
      }
    }
  }

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

  onStderr(): void {}