Function startKiloRuntime

services/cloud-agent-next/wrapper/src/main.ts:321–508

(
    workspacePath: string,
    expectedSessionId?: string,
    forceRestart = false
  )

        `post-bootstrap kilo session lookup end runtime=${runtimeKind} outcome=ok expectedSessionId=${expectedSessionId} returnedSessionId=${session.id} elapsedMs=${Date.now() - lookupStartedAt}`
      );
    } catch (error) {
      logToFile(
        `post-bootstrap kilo session lookup end runtime=${runtimeKind} outcome=error expectedSessionId=${expectedSessionId} elapsedMs=${Date.now() - lookupStartedAt}`
      );
      throw error;
    }
  }

  const globalFeedManager = createGlobalFeedManager({
    canOpen: () => Boolean(runtime.kiloClient && state.currentSession),
    open: () => {
      const kiloClient = runtime.kiloClient;
      if (!kiloClient) {
        throw new Error('Cannot open Kilo global feed: no Kilo client');
      }
      return openKiloGlobalFeed({ state, kiloClient });
    },
    onConnectionError: () => {
      logToFile('kilo global feed failed');
    },
    onOpenError: () => {
      logToFile('failed to start kilo global feed');
    },
  });

  // Runtime transitions must not interleave: readySession, updateRuntimeEnvironment
  // and restartKiloRuntime can each request one concurrently, and two bodies racing
  // through the awaits in the runtime start would overwrite each other's
  // connectionManager/lifecycleManager bindings, orphaning one of the freshly
  // spawned kilo server processes.
  runtime = createKiloRuntimeLifecycle({
    createKilo,
    bindClient: (result, workspacePath) =>
      createWrapperKiloClient(result.client as SDKClient, result.server.url, workspacePath),
    captureEnv: () => process.env,
    getPlatform: () => serverConfig.platform,
    log: logToFile,
    chdir: workspacePath => process.chdir(workspacePath),
    assignProcessEnv: env => {
      Object.assign(process.env, env);
    },
    isShuttingDown: () => isShuttingDown,
    getKiloSessionId: () => kiloSessionId,
    applyKiloSessionId: sessionId => {
      kiloSessionId = sessionId;
      serverConfig.sessionId = sessionId;
    },
    verifyExistingKiloSession,
    onBeforeSpawnTeardown: async () => {
      globalFeedManager.close();
      lifecycleManager?.stop();
      await connectionManager?.close();
      serverDeps.kiloClient = unavailableKiloClient;
    },
    onRuntimeStarted: ({ client, workspacePath, kiloSessionId: startedSessionId }) => {
      serverDeps.kiloClient = client;
      serverConfig.workspacePath = workspacePath;
      serverConfig.sessionId = startedSessionId;