Class FakeRpc

test/bindingRuntime.policy.test.ts:25–142

} from '../src/acp/jsonrpc.js';

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

  private promptId: number | null = null;
  private sessionId = 'sess-1';
  private workspaceFile: string;

  constructor(params: { workspaceFile: string }) {
    this.workspaceFile = params.workspaceFile;
  }

  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),
        );
        return;
      }

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

      if (req.method === 'session/prompt') {
        this.promptId = Number(req.id);

        queueMicrotask(() => {
          this.emit({
            jsonrpc: '2.0',
            id: 999,
            method: 'session/request_permission',
            params: {
              sessionId: this.sessionId,
              toolCall: { title: 'fs/read_text_file', kind: 'read' },
              options: [
                { optionId: 'a1', name: 'Allow once', kind: 'allow_once' },
                { optionId: 'r1', name: 'Reject once', kind: 'reject_once' },
              ],
            },
          } as any);
        });