Function forward_oauth_request

src/app.rs:816–1008

(
    state: &AppState,
    method: Method,
    uri: &Uri,
    headers: HeaderMap,
    body_bytes: Bytes,
    provider: Provider,
    oauth_provider_id: &str,
)

}

async fn forward_oauth_request(
    state: &AppState,
    method: Method,
    uri: &Uri,
    headers: HeaderMap,
    body_bytes: Bytes,
    provider: Provider,
    oauth_provider_id: &str,
) -> Result<Response, String> {
    // 1. Inject auth headers
    let mut auth_headers = HeaderMap::new();
    state
        .oauth_registry
        .inject_auth(oauth_provider_id, &mut auth_headers)
        .await
        .map_err(|e| format!("OAuth auth injection failed: {e}"))?;

    // 2. Optionally transform the body
    let body = match state
        .oauth_registry
        .prepare_request_body(oauth_provider_id, &body_bytes)
        .await
        .map_err(|e| format!("OAuth body preparation failed: {e}"))?
    {
        Some(transformed) => Bytes::from(transformed),
        None => body_bytes.clone(),
    };

    // 2b. Check if path needs rewriting (e.g., /v1/chat/completions → /v1/responses)
    let original_path = uri.path().to_string();
    let rewritten_path = state
        .oauth_registry
        .rewrite_request_path(oauth_provider_id, &original_path)
        .map_err(|e| format!("OAuth path rewrite failed: {e}"))?;
    let needs_translation = state
        .oauth_registry
        .needs_response_translation(oauth_provider_id, &original_path)
        .map_err(|e| format!("OAuth translation check failed: {e}"))?;
    let response_format = state
        .oauth_registry
        .response_format(oauth_provider_id, &original_path)
        .map_err(|e| format!("OAuth response format check failed: {e}"))?;
    // Check the transformed body for stream flag (fixups may force stream: true)
    let stream_requested = serde_json::from_slice::<serde_json::Value>(&body)
        .ok()
        .and_then(|v| v.get("stream")?.as_bool())
        .unwrap_or(false);

    let effective_uri = if let Some(ref new_path) = rewritten_path {
        build_rewritten_uri(uri, new_path)?
    } else {
        uri.clone()
    };

    if rewritten_path.is_some() {
        debug!(
            oauth_provider = %oauth_provider_id,
            original_path = %original_path,