Function publishThreadUpdate

desktop/runtime/thread-publisher.ts:313–342

(runtime: PiRuntime, reason: RuntimeThreadReason)

}

export async function publishThreadUpdate(runtime: PiRuntime, reason: RuntimeThreadReason) {
  const sessionPath = runtime.session.sessionFile
  if (!sessionPath) return

  markInternalThreadUpdate(sessionPath)

  const liveThread = buildLiveThreadData(runtime)
  if (!liveThread) return

  const thread = normalizeThreadDataForReason(liveThread, reason)
  const projectId = runtime.cwd
  const timestamp = Date.now()

  rememberLiveThread(sessionPath, thread)
  rememberSessionPath(sessionPath, projectId)

  const threadId = await applyPersistedThreadUpdate(runtime, sessionPath, thread, reason, timestamp)

  emitDesktopEvent({
    type: 'thread-update',
    reason,
    projectId,
    threadId,
    sessionPath,
    chatGroupId: runtime.chatGroupId ?? null,
    isChat: isChatSessionPath(sessionPath),
    thread,
    composer: await buildComposerState(runtime, { includeContextUsage: reason !== 'update' }),
  })
}

export async function publishExternalThreadUpdate({
  lastModifiedMs,