Function readySession

services/cloud-agent-next/wrapper/src/main.ts:531–675

(
    request: WrapperSessionReadyRequest
  )

        onCompletionSignal: () => {
          lifecycleManager?.signalCompletion();
        },
        onSessionIdle: () => {
          lifecycleManager?.onSessionIdle();
        },
        onRootSessionActivity: () => {
          lifecycleManager?.onRootSessionActivity();
        },
        onReconnecting: (attempt: number) => {
          logToFile(`ingest WS reconnecting: attempt ${attempt}`);
        },
        onReconnected: () => {
          logToFile('ingest WS reconnected');
          lifecycleManager?.onConnectionRestored();
          const lastError = state.getLastError();
          if (lastError?.code === 'DISCONNECT') {
            state.clearLastError();
          }
        },
        onSseEvent: () => {
          lifecycleManager?.onSseEvent();
        },
      }
    );

    lifecycleManager = createLifecycleManager(
      { workspacePath },
      {
        state,
        kiloClient: nextKiloClient,
        closeConnections: () => connectionManager?.close() ?? Promise.resolve(),
        isConnected: () => connectionManager?.isConnected() ?? false,
        reconnectEventSubscription: () => connectionManager?.reconnectEventSubscription(),
      }
    );
    lifecycleManager.start();
    globalFeedManager.onRuntimeReady();
  }

  async function updateRuntimeEnvironment(env: Record<string, string>): Promise<void> {
    const environmentChanged = Object.entries(env).some(
      ([name, value]) => process.env[name] !== value
    );
    Object.assign(process.env, env);
    if (runtimeWorkspacePath && (environmentChanged || !kiloClient)) {
      await startKiloRuntime(runtimeWorkspacePath, kiloSessionId || undefined, true);
    }
  }

  function wrapperFinalizingResponse(): WrapperSessionReadyResponse {
    return {
      status: 'error',
      error: {
        code: 'WRAPPER_FINALIZING',
        message: 'Wrapper is shutting down',
        retryable: true,
      },
    };
  }