gproxy-protocol 1.0.20

Wire-format types and cross-protocol transforms for Claude, OpenAI, and Gemini LLM 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
76
77
78
79
80
81
82
83
84
85
86

use serde::{Deserialize, Serialize};

use crate::claude::create_message::types::{
    BetaContainer, BetaContentBlock, BetaContextManagementResponse, BetaIterationsUsage,
    BetaMessage, BetaServerToolUsage, BetaStopReason, BetaTextCitation,
};
use crate::claude::types::BetaError;

/// Stream event payload for Claude Messages SSE responses.
///
/// Each SSE `data:` line deserializes to one of these variants,
/// discriminated by the `type` field in JSON.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(tag = "type")]
pub enum ClaudeStreamEvent {
    #[serde(rename = "message_start")]
    MessageStart { message: BetaMessage },
    #[serde(rename = "content_block_start")]
    ContentBlockStart {
        content_block: BetaContentBlock,
        index: u64,
    },
    #[serde(rename = "content_block_delta")]
    ContentBlockDelta {
        delta: BetaRawContentBlockDelta,
        index: u64,
    },
    #[serde(rename = "content_block_stop")]
    ContentBlockStop { index: u64 },
    #[serde(rename = "message_delta")]
    MessageDelta {
        #[serde(default)]
        context_management: Option<BetaContextManagementResponse>,
        delta: BetaRawMessageDelta,
        usage: BetaMessageDeltaUsage,
    },
    #[serde(rename = "message_stop")]
    MessageStop {},
    #[serde(rename = "ping")]
    Ping {},
    #[serde(rename = "error")]
    Error { error: BetaError },
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(tag = "type")]
pub enum BetaRawContentBlockDelta {
    #[serde(rename = "text_delta")]
    Text { text: String },
    #[serde(rename = "input_json_delta")]
    InputJson { partial_json: String },
    #[serde(rename = "citations_delta")]
    Citations { citation: BetaTextCitation },
    #[serde(rename = "thinking_delta")]
    Thinking { thinking: String },
    #[serde(rename = "signature_delta")]
    Signature { signature: String },
    #[serde(rename = "compaction_delta")]
    Compaction { content: Option<String> },
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, Default)]
pub struct BetaRawMessageDelta {
    #[serde(default)]
    pub container: Option<BetaContainer>,
    #[serde(default)]
    pub stop_reason: Option<BetaStopReason>,
    #[serde(default)]
    pub stop_sequence: Option<String>,
}

/// Cumulative usage counters carried in stream `message_delta` events.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, Default)]
pub struct BetaMessageDeltaUsage {
    #[serde(default)]
    pub cache_creation_input_tokens: Option<u64>,
    #[serde(default)]
    pub cache_read_input_tokens: Option<u64>,
    #[serde(default)]
    pub input_tokens: Option<u64>,
    #[serde(default)]
    pub iterations: Option<BetaIterationsUsage>,
    pub output_tokens: u64,
    #[serde(default)]
    pub server_tool_use: Option<BetaServerToolUsage>,
}