Function fakeRpc

packages/computer/src/shell.test.ts:83–152

(options: FakeRpcOptions = {})

}

function fakeRpc(options: FakeRpcOptions = {}): FakeRpc {
  const events = options.events ?? [{ id: "_", seq: 1, name: "exit", value: 0 }];
  const mintedId = options.mintedId ?? "runner-minted-id";
  const calls: FakeRpc["calls"] = {
    exec: [],
    getExec: [],
    killExec: [],
  };

  function makeStream(id: string): ReadableStream<ExecEvent> {
    return new ReadableStream<ExecEvent>({
      start(c) {
        for (const e of events) c.enqueue({ ...e, id });
        if (options.streamError !== undefined) {
          c.error(options.streamError);
          return;
        }
        c.close();
      },
    });
  }

  const sync: SyncRPC = {
    async push() {
      throw new Error("not wired");
    },
    async fetchChanges() {
      throw new Error("not wired");
    },
    async readEntry() {
      return null;
    },
    async watermarks() {
      return { currentRev: 0, pushRev: 0, fetchCursor: { rev: 0, path: null } };
    },
    async hasObjects() {
      return [];
    },
    fetchObjects() {
      throw new Error("not wired");
    },
    async pushObjects() {
      throw new Error("not wired");
    },
  };

  const shell: ShellRPC = {
    async exec(input) {
      calls.exec.push({
        command: input.command,
        id: input.id,
        cwd: input.cwd,
        timeoutMs: input.timeoutMs,
      });
      if (options.throwOnExec !== undefined) throw options.throwOnExec;
      const id = input.id ?? mintedId;
      return { id, events: makeStream(id) };
    },