gproxy-transform 2.6.3

Pairwise request/response/stream transforms between the OpenAI, Anthropic Claude, and Google Gemini APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use crate::protocol::{claude, openai};
use crate::transform::{TransformContext, TransformError};

use super::DEFAULT_COMPACT_MAX_TOKENS;
use super::input::openai_input_to_claude_messages;
use super::util::{
    compact_service_tier_to_claude, model_to_string, openai_previous_response_id_to_claude,
};

pub fn request_headers(_: &TransformContext) -> claude::CreateMessageRequestHeaders {
    crate::protocol::wire!(claude::CreateMessageRequestHeaders {
        anthropic_beta: Some(vec![claude::AnthropicBeta::Known(
            claude::AnthropicBetaKnown::ContextManagement20250627,
        )]),
        extra: Default::default(),
    })
}

pub fn request(
    input: openai::CompactResponseRequestBody,
    _: &TransformContext,
) -> Result<claude::CreateMessageRequestBody, TransformError> {
    let model = model_to_string(&input.model);
    // Pre-Opus-4.8 models reject a system-role turn in `messages` — downgrade
    // to assistant there (same gate as the chat→claude mid_conv_system block).
    let system_role = if crate::transform::common::supports_mid_conv_system(&model) {
        claude::MessageRole::Known(claude::MessageRoleKnown::System)
    } else {
        claude::MessageRole::Known(claude::MessageRoleKnown::Assistant)
    };
    #[allow(deprecated)]
    Ok(crate::protocol::wire!(claude::CreateMessageRequestBody {
        model: claude::ClaudeModel::Unknown(model),
        messages: openai_input_to_claude_messages(input.input, system_role),
        max_tokens: DEFAULT_COMPACT_MAX_TOKENS,
        cache_control: None,
        container: None,
        context_management: Some(compact_context_management(input.instructions.as_deref())),
        diagnostics: openai_previous_response_id_to_claude(input.previous_response_id),
        fallback_credit_token: None,
        fallbacks: None,
        inference_geo: None,
        mcp_servers: None,
        metadata: None,
        output_config: None,
        output_format: None,
        service_tier: compact_service_tier_to_claude(input.service_tier),
        speed: None,
        stop_sequences: None,
        stream: None,
        system: input.instructions.map(claude::SystemPrompt::String),
        temperature: None,
        thinking: None,
        tool_choice: None,
        tools: None,
        top_k: None,
        top_p: None,
        user_profile_id: None,
        extra: Default::default(),
    }))
}

fn compact_context_management(instructions: Option<&str>) -> claude::ContextManagementConfig {
    crate::protocol::wire!(claude::ContextManagementConfig {
        edits: Some(vec![claude::ContextEdit::Known(
            claude::KnownContextEdit::Compact {
                instructions: instructions.map(str::to_owned),
                pause_after_compaction: Some(true),
                trigger: None,
                extra: Default::default(),
            },
        )]),
        extra: Default::default(),
    })
}