Function handleRuntimeSessionEvent

desktop/runtime/runtime-registry.ts:188–213

(runtime: PiRuntime, event: RuntimeSessionEvent)

}

function handleRuntimeSessionEvent(runtime: PiRuntime, event: RuntimeSessionEvent) {
  const runtimeKey = getPersistedSessionPath(runtime.session.sessionFile)
  if (runtimeKey) suspendRuntimeDisposal(runtimeKey)
  if (event.type === 'message_start' || event.type === 'message_update')
    return scheduleLiveThreadUpdate(runtime, publishLiveThreadUpdate)
  if (event.type === 'message_end') return handleRuntimeMessageEnd(runtime, runtimeKey, event)
  if (event.type === 'agent_end') return handleRuntimeAgentEnd(runtime, runtimeKey)
  if (event.type === 'compaction_start') {
    cancelLiveThreadUpdate(runtime)
    void publishThreadUpdate(runtime, 'compaction-start')
    void publishRuntimeComposerState(runtime)
    return
  }
  if (event.type === 'compaction_end') return handleRuntimeCompactionEnd(runtime, runtimeKey)
  if (
    event.type === 'tool_execution_start' ||
    event.type === 'tool_execution_update' ||
    event.type === 'tool_execution_end'
  )
    return handleRuntimeToolEvent(runtime, event)
  if (event.type === 'queue_update')
    void publishRuntimeComposerState(runtime).finally(() => {
      if (runtimeKey && !runtime.session.isStreaming)
        scheduleRuntimeDisposal(runtimeKey, isHowcodeRuntimeBusy)
    })
}

async function createRuntime(options: {
  cwd: string