Function setComposerModel

desktop/runtime-host/live-runtime-service.ts:277–319

(
  request: ComposerStateRequest,
  provider: string,
  modelId: string,
)

}

export async function setComposerModel(
  request: ComposerStateRequest,
  provider: string,
  modelId: string,
) {
  const persistedSessionPath = getPersistedSessionPath(request.sessionPath)
  if (!persistedSessionPath) {
    const { AuthStorage, ModelRegistry, SettingsManager, getAgentDir } = await getPiModule()
    const cwd = request.projectId ?? getDesktopWorkingDirectory()
    const agentDir = getAgentDir()
    const authStorage = AuthStorage.create()
    const modelRegistry = normalizeModelRegistryContextWindows(
      ModelRegistry.create(authStorage, `${agentDir}/models.json`),
    )
    const model = modelRegistry.find(provider, modelId)
    if (!model) throw new Error(`Unknown Pi model: ${provider}/${modelId}`)
    const currentComposer = await buildComposerStateSnapshot({ projectId: cwd, sessionPath: null })
    const settingsManager = SettingsManager.create(cwd, agentDir)
    settingsManager.setDefaultModelAndProvider(provider, modelId)
    settingsManager.setDefaultThinkingLevel(
      clampThinkingLevel(
        currentComposer.currentThinkingLevel,
        getAvailableThinkingLevelsForModel(model),
      ),
    )
    await emitComposerUpdate({ ...request, sessionPath: null })
    return { ok: true as const }
  }
  await withRuntimeMutationLock(persistedSessionPath, async () => {
    await reloadRuntimeSettingsIfSafe(persistedSessionPath, { useMutationLock: false })
    const runtime = await getOrCreateRuntimeForSessionPath(persistedSessionPath, {
      suspendDisposal: true,
      settingsCwd: request.composerSessionDir ?? null,
      chatGroupId: request.chatGroupId ?? null,
    })
    const model = runtime.session.modelRegistry.find(provider, modelId)
    if (!model) throw new Error(`Unknown Pi model: ${provider}/${modelId}`)
    await runtime.session.setModel(model)
    scheduleRuntimeDisposal(persistedSessionPath)
    await emitComposerUpdate({ ...request, sessionPath: persistedSessionPath })
  })
  return { ok: true as const }
}

export async function setComposerThinkingLevel(
  request: ComposerStateRequest,