oh-my-opencode/src/shared/delegated-child-session-bootstrap.ts

import type { ModelFallbackControllerAccessor } from "../hooks/model-fallback"
import { createInternalAgentTextPart } from "./internal-initiator-marker"
import type { FallbackEntry } from "./model-requirements"
import { SessionCategoryRegistry } from "./session-category-registry"

export type DelegatedChildSessionRetryPart = {
  type: "text"
  text: string
}

export type DelegatedChildSessionBootstrap = {
  retryParts: DelegatedChildSessionRetryPart[]
  fallbackChain?: FallbackEntry[]
  category?: string
  system?: string
  tools?: Record<string, boolean>
}

const delegatedChildSessionBootstraps = new Map<string, DelegatedChildSessionBootstrap>()

function cloneRetryParts(parts: DelegatedChildSessionRetryPart[]): DelegatedChildSessionRetryPart[] {
  return parts.map((part) => ({ type: part.type, text: part.text }))
}

function cloneFallbackChain(fallbackChain: FallbackEntry[] | undefined): FallbackEntry[] | undefined {
  return fallbackChain?.map((entry) => ({
    ...entry,
    providers: [...entry.providers],
  }))
}

function cloneTools(tools: Record<string, boolean> | undefined): Record<string, boolean> | undefined {
  return tools ? { ...tools } : undefined
}

export function registerDelegatedChildSessionBootstrap(_args: {
  sessionID: string
  promptText: string
  fallbackChain?: FallbackEntry[]
  category?: string
  system?: string
  tools?: Record<string, boolean>
  modelFallbackControllerAccessor?: ModelFallbackControllerAccessor
}): void {
  const retryParts = [createInternalAgentTextPart(_args.promptText)]
  const fallbackChain = cloneFallbackChain(_args.fallbackChain)
  const tools = cloneTools(_args.tools)
  delegatedChildSessionBootstraps.set(_args.sessionID, {
    retryParts,
    ...(fallbackChain ? { fallbackChain } : {}),
    ...(_args.category ? { category: _args.category } : {}),
    ...(_args.system ? { system: _args.system } : {}),
    ...(tools ? { tools } : {}),
  })

  _args.modelFallbackControllerAccessor?.setSessionFallbackChain(_args.sessionID, fallbackChain)
  if (_args.category) {
    SessionCategoryRegistry.register(_args.sessionID, _args.category)
  }
}

export function getDelegatedChildSessionBootstrap(_sessionID: string): DelegatedChildSessionBootstrap | undefined {
  const bootstrap = delegatedChildSessionBootstraps.get(_sessionID)
  if (!bootstrap) {
    return undefined
  }

  const fallbackChain = cloneFallbackChain(bootstrap.fallbackChain)
  const tools = cloneTools(bootstrap.tools)
  return {
    retryParts: cloneRetryParts(bootstrap.retryParts),
    ...(fallbackChain ? { fallbackChain } : {}),
    ...(bootstrap.category ? { category: bootstrap.category } : {}),
    ...(bootstrap.system ? { system: bootstrap.system } : {}),
    ...(tools ? { tools } : {}),
  }
}

export function clearDelegatedChildSessionBootstrap(_sessionID: string): void {
  delegatedChildSessionBootstraps.delete(_sessionID)
}

export function clearAllDelegatedChildSessionBootstrap(): void {
  delegatedChildSessionBootstraps.clear()
}