Function mock_response

crates/openshell-router/src/mock.rs:20–49

Generate a canned HTTP response appropriate for the route's protocol. The response is protocol-aware: for `openai_chat_completions` it returns a valid `OpenAI` chat completion JSON, for `anthropic_messages` a valid Anthropic response, etc. The route's `model` field is echoed in the response.

(route: &ResolvedRoute, source_protocol: &str)

/// a valid `OpenAI` chat completion JSON, for `anthropic_messages` a valid
/// Anthropic response, etc. The route's `model` field is echoed in the response.
pub fn mock_response(route: &ResolvedRoute, source_protocol: &str) -> ProxyResponse {
    tracing::warn!(
        endpoint = %route.endpoint,
        "Serving mock response — mock:// routes should only be used in development/testing"
    );

    let protocol = if route.protocols.iter().any(|p| p == source_protocol) {
        source_protocol
    } else {
        route.protocols.first().map_or("", String::as_str)
    };

    let body = match protocol {
        "openai_chat_completions" => openai_chat_completion_body(&route.model),
        "openai_completions" => openai_completion_body(&route.model),
        "openai_embeddings" => openai_embeddings_body(&route.model),
        "anthropic_messages" => anthropic_messages_body(&route.model),
        _ => generic_body(&route.model),
    };

    let body_bytes = bytes::Bytes::from(body);
    ProxyResponse {
        status: 200,
        headers: vec![
            ("content-type".to_string(), "application/json".to_string()),
            ("x-openshell-mock".to_string(), "true".to_string()),
        ],
        body: body_bytes,
    }
}

fn openai_chat_completion_body(model: &str) -> Vec<u8> {
    serde_json::to_vec(&serde_json::json!({