Function publishThreadUpdate

desktop/runtime-host/live-thread-publisher.ts:48–65

(runtime: PiRuntime, reason: RuntimeThreadReason)

}

export async function publishThreadUpdate(runtime: PiRuntime, reason: RuntimeThreadReason) {
  const sessionPath = runtime.session.sessionFile
  if (!sessionPath) return
  const liveThread = buildLiveThreadData(runtime)
  if (!liveThread) return
  emitDesktopEvent({ type: 'internal-thread-update', sessionPath })
  emitDesktopEvent({
    type: 'thread-update',
    reason,
    projectId: runtime.cwd,
    threadId: runtime.session.sessionId,
    sessionPath,
    chatGroupId: runtime.chatGroupId ?? null,
    isChat: isChatSessionPath(sessionPath),
    thread: normalizeThreadDataForReason(liveThread, reason),
    composer: await buildComposerState(runtime, { includeContextUsage: reason !== 'update' }),
  })
}

export function publishComposerUpdate(
  composer: Awaited<ReturnType<typeof buildComposerState>>,