Function buildLiveThreadData

desktop/runtime/thread-publisher.ts:141–165

(runtime: PiRuntime)

}

function buildLiveThreadData(runtime: PiRuntime) {
  const sessionPath = runtime.session.sessionFile
  if (!sessionPath) {
    return null
  }

  const streamingMessage = runtime.session.state.streamingMessage
  const historySlice = buildThreadHistorySlice(
    [...(runtime.session.sessionManager.getBranch() as SessionPathEntry[])],
    0,
  )
  const sourceMessages = [
    ...historySlice.sourceMessages,
    ...(streamingMessage ? [streamingMessage] : []),
    ...getLiveToolProgressMessages(runtime),
  ] as AgentMessage[]

  return buildThreadData({
    sessionPath,
    sourceMessages,
    previousMessageCount: historySlice.previousMessageCount,
    isStreaming: runtime.session.isStreaming,
    isCompacting: runtime.session.isCompacting,
  })
}

function hasAssistantMessageChanged(
  sessionPath: string,