murashit_codex-panel/tests/features/chat/support/shell-state.ts

import { activeTurnId, chatTurnBusy } from "../../../../src/features/chat/application/conversation/turn-state";
import { runtimeSnapshotForChatState } from "../../../../src/features/chat/application/runtime/snapshot";
import {
  messageStreamActiveItems,
  messageStreamItems,
  messageStreamRollbackCandidateFromItems,
  messageStreamStableItems,
} from "../../../../src/features/chat/application/state/message-stream";
import type { ChatState } from "../../../../src/features/chat/application/state/root-reducer";
import {
  forkCandidatesFromItems,
  latestImplementablePlanTargetFromItems,
} from "../../../../src/features/chat/domain/message-stream/selectors";
import type { ChatPanelComposerShellState, ChatPanelMessageStreamShellState } from "../../../../src/features/chat/panel/shell-state";

export function composerShellStateFromChatState(state: ChatState): ChatPanelComposerShellState {
  return {
    connection: state.connection,
    threadList: state.threadList,
    runtime: state.runtime,
    composer: state.composer,
    activeThreadId: state.activeThread.id,
    turnBusy: chatTurnBusy(state),
    activeTurnId: activeTurnId(state),
    runtimeSnapshot: runtimeSnapshotForChatState(state),
  };
}

export function messageStreamShellStateFromChatState(state: ChatState): ChatPanelMessageStreamShellState {
  const turnBusy = chatTurnBusy(state);
  const items = messageStreamItems(state.messageStream);
  return {
    messageStream: state.messageStream,
    requests: state.requests,
    ui: state.ui,
    activeThreadId: state.activeThread.id,
    activeThreadCwd: state.activeThread.cwd,
    activeTurnId: activeTurnId(state),
    items,
    stableItems: messageStreamStableItems(state.messageStream),
    activeItems: messageStreamActiveItems(state.messageStream),
    rollbackCandidate: turnBusy ? null : messageStreamRollbackCandidateFromItems(items),
    forkCandidates: turnBusy ? [] : forkCandidatesFromItems(items),
    implementPlanTarget:
      !state.activeThread.id || turnBusy || state.runtime.pending.collaborationMode !== "plan"
        ? null
        : latestImplementablePlanTargetFromItems(items),
  };
}