Function persistHostThreadUpdate

desktop/pi-desktop-runtime.ts:77–120

(event: Extract<DesktopEvent, { type: 'thread-update' }>)

}

async function persistHostThreadUpdate(event: Extract<DesktopEvent, { type: 'thread-update' }>) {
  try {
    await stat(event.sessionPath)
  } catch {
    return
  }
  const timestamp = Date.now()
  const threadId = upsertThreadSummary({
    id: event.threadId,
    cwd: event.projectId,
    sessionPath: event.sessionPath,
    title: event.thread.title,
    lastModifiedMs: timestamp,
  })

  event.threadId = threadId
  if (isChatSessionPath(event.sessionPath)) {
    upsertChatThread({ sessionPath: event.sessionPath, groupId: event.chatGroupId ?? null })
  }
  setThreadRunningState(
    event.sessionPath,
    event.reason === 'update' ||
      event.reason === 'compaction-start' ||
      (event.reason === 'start' && event.thread.messages.length > 0),
  )

  const latestUserPrompt = getLatestUserPrompt(event.thread)
  if (event.reason === 'start' && (latestUserPrompt || hasInboxItem(event.sessionPath))) {
    beginInboxThreadTurn(event.sessionPath, latestUserPrompt)
  }

  if (event.reason === 'end') {
    const latestAssistantMessage = getLatestInboxAssistantMessage(event.thread.messages)
    if (latestAssistantMessage) {
      upsertInboxThreadMessage({
        sessionPath: event.sessionPath,
        userPrompt: latestUserPrompt,
        content: latestAssistantMessage.content,
        preview: latestAssistantMessage.preview,
        lastAssistantAtMs: timestamp,
      })
    }
  }
}

const threadUpdateForwardingBySession = new Map<string, Promise<void>>()