Function createWorkspaceServiceMocks

src/node/services/taskService.test.ts:364–500

(
  overrides?: Partial<{
    sendMessage: ReturnType<typeof mock>;
    resumeStream: ReturnType<typeof mock>;
    clearQueue: ReturnType<typeof mock>;
    hasQueuedWorkspaceTurn: ReturnType<typeof mock>;
    hasQueuedMessages: ReturnType<typeof mock>;
    isBusyForMessage: ReturnType<typeof mock>;
    hasPendingQueuedOrPreparingTurn: ReturnType<typeof mock>;
    waitForIdleAndNoQueuedMessages: ReturnType<typeof mock>;
    waitForIdle: ReturnType<typeof mock>;
    waitForPendingStreamErrorRecoveryDecision: ReturnType<typeof mock>;
    archive: ReturnType<typeof mock>;
    deleteWorktree: ReturnType<typeof mock>;
    remove: ReturnType<typeof mock>;
    emit: ReturnType<typeof mock>;
    getInfo: ReturnType<typeof mock>;
    replaceHistory: ReturnType<typeof mock>;
    updateAgentStatus: ReturnType<typeof mock>;
    isExperimentEnabled: ReturnType<typeof mock>;
    emitChatEvent: ReturnType<typeof mock>;
    isWorkflowInvocationCurrent: ReturnType<typeof mock>;
    create: ReturnType<typeof mock>;
  }>
)

}

function createWorkspaceServiceMocks(
  overrides?: Partial<{
    sendMessage: ReturnType<typeof mock>;
    resumeStream: ReturnType<typeof mock>;
    clearQueue: ReturnType<typeof mock>;
    hasQueuedWorkspaceTurn: ReturnType<typeof mock>;
    hasQueuedMessages: ReturnType<typeof mock>;
    isBusyForMessage: ReturnType<typeof mock>;
    hasPendingQueuedOrPreparingTurn: ReturnType<typeof mock>;
    waitForIdleAndNoQueuedMessages: ReturnType<typeof mock>;
    waitForIdle: ReturnType<typeof mock>;
    waitForPendingStreamErrorRecoveryDecision: ReturnType<typeof mock>;
    archive: ReturnType<typeof mock>;
    deleteWorktree: ReturnType<typeof mock>;
    remove: ReturnType<typeof mock>;
    emit: ReturnType<typeof mock>;
    getInfo: ReturnType<typeof mock>;
    replaceHistory: ReturnType<typeof mock>;
    updateAgentStatus: ReturnType<typeof mock>;
    isExperimentEnabled: ReturnType<typeof mock>;
    emitChatEvent: ReturnType<typeof mock>;
    isWorkflowInvocationCurrent: ReturnType<typeof mock>;
    create: ReturnType<typeof mock>;
  }>
): {
  workspaceService: WorkspaceService;
  sendMessage: ReturnType<typeof mock>;
  resumeStream: ReturnType<typeof mock>;
  clearQueue: ReturnType<typeof mock>;
  hasQueuedWorkspaceTurn: ReturnType<typeof mock>;
  hasQueuedMessages: ReturnType<typeof mock>;
  isBusyForMessage: ReturnType<typeof mock>;
  waitForIdleAndNoQueuedMessages: ReturnType<typeof mock>;
  waitForIdle: ReturnType<typeof mock>;
  hasPendingQueuedOrPreparingTurn: ReturnType<typeof mock>;
  waitForPendingStreamErrorRecoveryDecision: ReturnType<typeof mock>;
  archive: ReturnType<typeof mock>;
  deleteWorktree: ReturnType<typeof mock>;
  remove: ReturnType<typeof mock>;
  emit: ReturnType<typeof mock>;
  getInfo: ReturnType<typeof mock>;
  replaceHistory: ReturnType<typeof mock>;
  updateAgentStatus: ReturnType<typeof mock>;
  isExperimentEnabled: ReturnType<typeof mock>;
  emitChatEvent: ReturnType<typeof mock>;
  isWorkflowInvocationCurrent: ReturnType<typeof mock>;
  create: ReturnType<typeof mock>;
} {
  const sendMessage =
    overrides?.sendMessage ?? mock((): Promise<Result<void>> => Promise.resolve(Ok(undefined)));
  const resumeStream =
    overrides?.resumeStream ??
    mock((): Promise<Result<{ started: boolean }>> => Promise.resolve(Ok({ started: true })));
  const clearQueue = overrides?.clearQueue ?? mock((): Result<void> => Ok(undefined));
  const hasQueuedWorkspaceTurn = overrides?.hasQueuedWorkspaceTurn ?? mock(() => false);
  const hasQueuedMessages = overrides?.hasQueuedMessages ?? mock(() => false);
  const isBusyForMessage = overrides?.isBusyForMessage ?? mock(() => false);
  const hasPendingQueuedOrPreparingTurn =