mobius 0.16.14

A small, modular Rust framework for building coding agents
Documentation
//! OpenRouter Responses provider.

use std::sync::Arc;

use super::Model;
use super::openai::OpenAi;
use super::provider::HostedWebSearch;
use super::provider::ProviderBuildConfig;
use super::provider::ProviderDefinition;
use super::provider::uses_default_endpoint;
use crate::Error;
use crate::Result;
use crate::protocol::ToolDiscoveryMode;

pub(super) static MANIFEST: std::sync::LazyLock<super::provider::ProviderMetadata> =
    std::sync::LazyLock::new(|| crate::config::embedded(include_str!("openrouter_provider.toml")));

pub(super) fn provider() -> ProviderDefinition {
    ProviderDefinition::from_metadata(
        "openrouter",
        &MANIFEST,
        MANIFEST.api_key_auth(),
        None,
        build_provider,
    )
    .with_image_input()
    .with_image_generation()
    .with_credentialless_endpoints()
}

fn build_provider(config: ProviderBuildConfig) -> Result<Arc<dyn Model>> {
    let tool_discovery = provider().tool_discovery(&config.model, config.base_url.as_deref());
    let base_url = config
        .base_url
        .ok_or_else(|| Error::Config("OpenRouter requires a base URL".into()))?;
    let api_key = config.credential.into_optional_api_key("openrouter")?;
    let native_images = api_key.is_some()
        && uses_default_endpoint(Some(MANIFEST.base_url.as_str()), Some(&base_url));
    let provider = OpenAi::with_client(
        api_key,
        base_url,
        config.model,
        config.http,
        config.transport,
    )?
    .with_service_tier(config.service_tier)
    .with_image_api(native_images.then_some(&super::image_generation::IMAGE_APIS["openrouter"]));
    let provider = match tool_discovery {
        ToolDiscoveryMode::Native => provider.with_openrouter_tool_search(),
        ToolDiscoveryMode::Rebuild => provider.with_tool_discovery(ToolDiscoveryMode::Rebuild),
    };
    let provider = match config.reasoning_effort {
        Some(effort) => provider.with_reasoning_effort(effort)?,
        None => provider,
    };
    let provider = match config.web_search {
        HostedWebSearch::Off => provider,
        HostedWebSearch::Cached => {
            return Err(Error::Config(
                "OpenRouter does not support cached web search".into(),
            ));
        }
        HostedWebSearch::Live => {
            provider.with_hosted_tool(serde_json::json!({"type": "openrouter:web_search"}))
        }
    };
    Ok(Arc::new(provider))
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::backend::model::provider::ProviderCredential;

    #[test]
    fn advertised_web_search_modes_build() {
        let definition = provider();
        for web_search in definition.web_search().iter().copied() {
            let model = definition
                .build(ProviderBuildConfig {
                    credential: ProviderCredential::ApiKey("test-key".into()),
                    model: "test-model".into(),
                    base_url: Some(MANIFEST.base_url.as_str().into()),
                    reasoning_effort: None,
                    service_tier: None,
                    web_search,
                    http: reqwest::Client::new(),
                    transport: crate::backend::model::ModelTransportSettings::default(),
                })
                .expect("advertised web search mode builds");
            assert!(model.supports_image_generation());
        }
    }
}