Function buildThreadData

shared/thread-data.ts:13–30

({
  sessionPath,
  sourceMessages,
  previousMessageCount,
  isStreaming,
  isCompacting = false,
}: BuildThreadDataInput)

}

export function buildThreadData({
  sessionPath,
  sourceMessages,
  previousMessageCount,
  isStreaming,
  isCompacting = false,
}: BuildThreadDataInput): ThreadData {
  const messages = mapAgentMessagesToUiMessages([...sourceMessages])

  return {
    sessionPath,
    title: getFirstUserTurnTitle(messages),
    messages,
    previousMessageCount,
    isStreaming,
    isCompacting,
  }
}

export function setThreadStreamingState(thread: ThreadData, isStreaming: boolean): ThreadData {
  return thread.isStreaming === isStreaming ? thread : { ...thread, isStreaming }