Function createPromptHandler

services/cloud-agent-next/wrapper/src/server.ts:400–512

(config: ServerConfig, deps: ServerDependencies)

      `session binding refreshed: generation=${binding.wrapperGeneration ?? 'none'} connectionId=${binding.wrapperConnectionId ?? 'none'}`
    );
    if (state.isConnected) {
      await deps.closeConnection();
    }
    deps.resetLifecycle();
    if (feedPolicy === 'restart') {
      await notifySessionBound(deps, feedPolicy);
    }
  }
  return null;
}

// ---------------------------------------------------------------------------
// Route Handlers
// ---------------------------------------------------------------------------

function createHealthHandler(
  config: ServerConfig,
  state: WrapperState,
  toolCgroupHealth?: () => ToolCgroupHealth | null
) {
  return (): Response => {
    const toolCgroup = toolCgroupHealth?.() ?? null;
    return jsonResponse({
      healthy: true,
      state: state.isActive ? 'active' : 'idle',
      version: config.version,
      sessionId: config.sessionId,
      ...(config.wrapperInstanceId ? { wrapperInstanceId: config.wrapperInstanceId } : {}),
      ...(config.wrapperInstanceGeneration !== undefined
        ? { wrapperInstanceGeneration: config.wrapperInstanceGeneration }
        : {}),
      pendingMessages: state.pendingMessageIds.length,
      ...(toolCgroup ? { toolCgroup } : {}),
    });
  };
}

function createStatusHandler(state: WrapperState) {
  return (): Response => {
    return jsonResponse(state.getStatus());
  };
}

/**
 * When a kilo client call fails because the server process itself is gone,
 * proactively restart the runtime so the next attempt hits a live server
 * instead of repeating the same connection failure. Fire-and-forget from the
 * caller's perspective — the restart can take as long as a full kilo server
 * startup, and the failing HTTP response should not wait on it. `restartKiloRuntime`
 * is responsible for deduping concurrent calls into a single in-flight restart.
 */
function restartRuntimeIfServerUnreachable(
  error: unknown,
  deps: ServerDependencies,
  logContext: string
): void {
  if (!isKiloServerUnreachableError(error)) return;
  logToFile(`${logContext}: kilo server appears unreachable, restarting runtime`);