Function publishExternalThreadUpdate

desktop/runtime/thread-publisher.ts:344–396

({
  lastModifiedMs,
  projectId,
  sessionPath,
  thread,
  threadId,
}: {
  lastModifiedMs: number
  projectId: string
  sessionPath: string
  thread: ThreadData
  threadId: string
})

}

export async function publishExternalThreadUpdate({
  lastModifiedMs,
  projectId,
  sessionPath,
  thread,
  threadId,
}: {
  lastModifiedMs: number
  projectId: string
  sessionPath: string
  thread: ThreadData
  threadId: string
}) {
  thread = normalizeThreadDataForReason(thread, 'external')

  rememberLiveThread(sessionPath, thread)
  rememberSessionPath(sessionPath, projectId)
  threadId = upsertThreadSummary({
    id: threadId,
    cwd: projectId,
    sessionPath,
    title: thread.title,
    lastModifiedMs,
  })
  setThreadRunningState(sessionPath, false)

  const latestUserPrompt = getLatestUserPrompt(thread)
  const latestAssistantMessage = getLatestInboxAssistantMessage(thread.messages)

  if (!latestAssistantMessage && (latestUserPrompt || hasInboxItem(sessionPath))) {
    beginInboxThreadTurn(sessionPath, latestUserPrompt)
  }

  if (latestAssistantMessage && hasAssistantMessageChanged(sessionPath, latestAssistantMessage)) {
    upsertInboxThreadMessage({
      sessionPath,
      userPrompt: latestUserPrompt,
      content: latestAssistantMessage.content,
      preview: latestAssistantMessage.preview,
      lastAssistantAtMs: lastModifiedMs,
    })
  }

  emitDesktopEvent({
    type: 'thread-update',
    reason: 'external',
    projectId,
    threadId,
    sessionPath,
    thread,
    composer: null,
  })
}

export function publishComposerUpdate(
  composer: ComposerState,