Function startInternalServer

apps/desktop/main/internal-api.ts:84–291

(pathProvider: PathProvider)

 * Must be called before createWindow() so the Renderer can retrieve the endpoint.
 */
export async function startInternalServer(pathProvider: PathProvider): Promise<InternalEndpoint> {
  if (server) return endpoint!

  let newServer: FastifyInstance | null = null
  let newDbManager: DatabaseManager | null = null
  let newSemanticIndexService: SemanticIndexRuntime | null = null

  try {
    const token = `int_${randomBytes(32).toString('hex')}`
    const { app } = await import('electron')
    const runtime = assertDesktopDataDirCompatible(pathProvider, getDesktopAppVersion(app.getVersion()))

    newDbManager = new DatabaseManager(pathProvider, { runtime })
    const sessionAdapter = createDatabaseManagerAdapter(newDbManager)

    const aiDataDir = pathProvider.getAiDataDir()
    const llmConfigStore = new LLMConfigStore(createFileConfigStorage(aiDataDir), {
      resolveApiKey: (provider, authProfile) => resolveApiKey(provider, authProfile) || undefined,
      onApiKeyCreated: (config, apiKey) => {
        const profileName = config.name?.toLowerCase().replace(/\s+/g, '-') || config.provider
        writeAuthProfile(profileName, { type: 'api_key', provider: config.provider, key: apiKey })
        return profileName
      },
      onApiKeyDeleted: (config) => {
        const profileName = (config as unknown as Record<string, unknown>).authProfile as string | undefined
        if (profileName) deleteAuthProfile(profileName)
      },
    })

    const configStorage = createFileConfigStorage(aiDataDir)

    const newMergeCache = new MergeSessionCache(pathProvider)
    newMergeCache.cleanupOrphans()

    // 语义索引 worker client：启动 internal server 时不拉起 worker；状态/构建/检索按需 lazy start。
    try {
      newSemanticIndexService = createSemanticIndexWorkerRuntimeClient({
        pathProvider,
        runtime,
        sqliteVecLoadablePath: getSqliteVecLoadablePath().replace('app.asar', 'app.asar.unpacked'),
        getModelDownloadProxyUrl: resolveModelDownloadProxyUrl,
        workerEntryUrl: import.meta.url.endsWith('.ts')
          ? undefined
          : new URL('./semantic-index-worker.js', import.meta.url),
      })
    } catch (err) {
      console.warn('[semantic-index] worker client unavailable:', err instanceof Error ? err.message : String(err))
      newSemanticIndexService = null
    }

    const electronStreamImport = async (dm: DatabaseManager, filePath: string) => {
      const deps: StreamImportDeps = {
        openDatabase(sessionId: string) {
          return dm.openRawSessionDatabase(sessionId, { create: true, initializeChatTables: true })
        },
        deleteDatabase(sessionId: string) {
          dm.deleteSessionDatabaseFiles(sessionId)
        },