gproxy-protocol 4.0.0

GPROXY v4 connection modelling, operation declarations, vendor wire types and pairwise conversion
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

use crate::{
    transform::TransformError,
    wire::{
        DeclaredFields,
        openai::{compact::ClientCompactResponseBody, guardian as c},
    },
};

/// Construct the exact client response envelope consumed by CompactClient.
/// The caller replaces history with this full array; no native encrypted block
/// is invented and retained tail items are preserved in their original order.
pub fn replacement_history(
    summary: Option<String>,
    retained_tail: Vec<c::ClientResponseItem>,
) -> Result<ClientCompactResponseBody, TransformError> {
    let mut output = Vec::with_capacity(retained_tail.len() + usize::from(summary.is_some()));
    if let Some(summary) = summary {
        if summary.trim().is_empty() {
            return Err(TransformError::invalid_result(
                "compact.summary",
                "empty summary",
            ));
        }
        output.push(c::ClientResponseItem::Message(
            c::ClientMessage::builder(
                "assistant".into(),
                vec![c::ContentItem::OutputText(
                    c::ContentItemOutputText::builder(summary).build(),
                )],
            )
            .build(),
        ));
    }
    output.extend(retained_tail.into_declared());
    Ok(ClientCompactResponseBody::builder(output).build())
}