codex_helper_core/proxy/

mod.rs

use std::collections::HashMap;
use std::sync::{Arc, Mutex};
use std::time::Duration;

use reqwest::Client;
use tokio::sync::watch;

mod admin;
mod api_responses;
mod attempt_execution;
mod attempt_failures;
mod attempt_health;
mod attempt_request;
mod attempt_response;
mod attempt_selection;
mod attempt_target;
mod attempt_transport;
mod auth_resolution;
mod classify;
mod client_identity;
mod codex_failure;
mod codex_relay_capabilities;
mod codex_relay_evidence;
mod codex_relay_live_smoke;
mod codex_relay_probe;
mod codex_relay_target;
mod concurrency_limits;
mod control_plane;
mod control_plane_manifest;
mod control_plane_routes;
mod control_plane_service;
mod entrypoint;
mod failure_summary;
mod headers;
mod healthcheck_api;
mod http_debug;
mod models_compat;
mod openai_images;
mod passive_health;
mod persisted_registry_api;
mod profile_defaults;
mod provider_evidence;
mod provider_execution;
mod provider_orchestration;
mod providers_api;
mod reasoning_guard;
mod request_body;
mod request_context;
mod request_continuity;
mod request_encoding;
mod request_failures;
mod request_observer;
mod request_preparation;
mod request_routing;
mod response_finalization;
mod response_fixer;
mod response_semantics;
mod responses_websocket;
mod retry;
mod route_affinity;
mod route_attempts;
mod route_executor_runtime;
mod route_metadata;
mod route_provenance;
mod route_target_selection;
mod route_unavailability;
mod router_setup;
mod routing_plan;
mod runtime_admin_api;
mod runtime_config;
mod selected_upstream_request;
mod service_core;
mod session_overrides;
mod stations_api;
mod stream;
mod target_builder;
#[cfg(test)]
mod tests;

use crate::filter::RequestFilter;
use crate::host_local::HostLocalSessionHistoryMode;
use crate::lb::LbState;
use crate::state::{ProviderBalanceSnapshot, ProxyState};
use crate::usage_providers::UsageProviderRefreshSummary;

pub use self::admin::{
    admin_base_url_from_proxy_base_url, admin_loopback_addr_for_proxy_port,
    admin_port_for_proxy_port, local_admin_base_url_for_proxy_port, local_proxy_base_url,
};
pub use self::api_responses::{ProfilesResponse, ReloadResult, RuntimeStatusResponse};
pub use self::codex_relay_capabilities::{
    CodexRelayCapabilitiesObserved, CodexRelayCapabilitiesRequest, CodexRelayCapabilitiesResponse,
    CodexRelayCapabilityMismatch, CodexRelayContinuityDiagnostics,
    CodexRelayContinuityDomainSummary,
};
pub use self::codex_relay_evidence::{
    CodexRelayEvidenceEntry, CodexRelayEvidenceFilters, CodexRelayEvidenceKind,
    codex_relay_evidence_path, read_recent_codex_relay_evidence,
};
pub use self::codex_relay_live_smoke::{
    CODEX_RELAY_LIVE_SMOKE_ACK, CodexRelayLiveSmokeCase, CodexRelayLiveSmokeConfidence,
    CodexRelayLiveSmokeOutcome, CodexRelayLiveSmokeRequest, CodexRelayLiveSmokeResponse,
    CodexRelayLiveSmokeResult, CodexRelayLiveSmokeSideEffect,
};
pub use self::codex_relay_probe::{
    CodexRelayProbeClient, CodexRelayProbeConfidence, CodexRelayProbeKind, CodexRelayProbeResult,
    CodexRelayProbeSideEffect, CodexRelayProbeSpec, CodexRelayProbeSupport,
    classify_codex_relay_probe_response,
};
use self::concurrency_limits::ConcurrencyLimiter;
pub use self::entrypoint::handle_proxy;
pub use self::persisted_registry_api::PersistedRoutingUpsertRequest;
pub use self::router_setup::{
    admin_listener_router, proxy_only_router, proxy_only_router_with_admin_base_url, router,
};
use self::runtime_config::RuntimeConfig;

pub const ADMIN_TOKEN_ENV_VAR: &str = "CODEX_HELPER_ADMIN_TOKEN";
pub const ADMIN_TOKEN_HEADER: &str = "x-codex-helper-admin-token";
pub const CLIENT_NAME_HEADER: &str = "x-codex-helper-client-name";
pub const ADMIN_PORT_OFFSET: u16 = 1000;

#[cfg(test)]
const AUTH_FILE_CACHE_MIN_CHECK_INTERVAL: Duration = Duration::from_millis(20);
#[cfg(not(test))]
const AUTH_FILE_CACHE_MIN_CHECK_INTERVAL: Duration = Duration::from_millis(800);

#[cfg(test)]
fn codex_auth_json_value(key: &str) -> Option<String> {
    auth_resolution::codex_auth_json_value(key)
}

#[cfg(test)]
fn claude_settings_env_value(key: &str) -> Option<String> {
    auth_resolution::claude_settings_env_value(key)
}

/// Generic proxy service; currently used by both Codex and Claude.
#[derive(Clone)]
pub struct ProxyService {
    pub client: Client,
    config: Arc<RuntimeConfig>,
    pub service_name: &'static str,
    lb_states: Arc<Mutex<HashMap<String, LbState>>>,
    concurrency_limiter: Arc<ConcurrencyLimiter>,
    filter: RequestFilter,
    state: Arc<ProxyState>,
    shutdown_tx: Option<watch::Sender<bool>>,
    host_local_session_history_mode: HostLocalSessionHistoryMode,
}

#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
pub struct ProviderBalanceRefreshResponse {
    pub service_name: String,
    pub refresh: UsageProviderRefreshSummary,
    pub provider_balances: HashMap<String, Vec<ProviderBalanceSnapshot>>,
}

#[derive(Debug, Clone)]
pub struct ProxyControlError {
    status: axum::http::StatusCode,
    message: String,
}

impl ProxyControlError {
    pub fn new(status: axum::http::StatusCode, message: impl Into<String>) -> Self {
        Self {
            status,
            message: message.into(),
        }
    }

    pub fn status(&self) -> axum::http::StatusCode {
        self.status
    }

    pub fn message(&self) -> &str {
        self.message.as_str()
    }

    pub fn into_http_error(self) -> (axum::http::StatusCode, String) {
        (self.status, self.message)
    }
}

impl std::fmt::Display for ProxyControlError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "status={}, {}", self.status, self.message)
    }
}

impl std::error::Error for ProxyControlError {}

impl From<(axum::http::StatusCode, String)> for ProxyControlError {
    fn from((status, message): (axum::http::StatusCode, String)) -> Self {
        Self::new(status, message)
    }
}