Function makeBridge

packages/agent-core/test/services/task-service.test.ts:40–65

(state: FakeState)

}

function makeBridge(state: FakeState): ICoreProcessService {
  const rpc: Partial<CoreRPC> = {
    listSessions: async () => state.sessions,
    getBackground: async (p: { sessionId: string; agentId: string; activeOnly?: boolean }) =>
      state.tasksBySession.get(p.sessionId) ?? [],
    getBackgroundOutput: async (p: { sessionId: string; agentId: string; taskId: string; tail?: number }) => {
      const output = state.outputByTaskId.get(p.taskId);
      if (output === undefined) return '';
      if (p.tail !== undefined && output.length > p.tail) {
        return output.slice(-p.tail);
      }
      return output;
    },
    stopBackground: async (
      p: StopBackgroundPayload & { sessionId: string; agentId: string },
    ) => {
      state.stopCalls.push(p);
    },
  };
  return {
    rpc: rpc as CoreRPC,
    ready: async () => undefined,
    dispose: () => undefined,
    _serviceBrand: undefined,
  };
}

function session(id: string): SessionSummary {
  return {