everruns-contracts 0.44.0

Shared runtime, provider, capability, and model profile contracts for Everruns
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

//! Stateless endpoints require a valid completion or an explicit terminal error.
use crate::{LlmStreamError, LlmStreamEvent};
use serde_json::Value;

pub(super) fn terminal(frame: &Value) -> Option<LlmStreamEvent> {
    match frame["type"].as_str()? {
        "response.completed"
            if frame["response"]["status"] == "completed"
                && frame["response"]["output"].is_array() =>
        {
            None
        }
        "response.failed" | "error" => {
            let error = frame
                .pointer("/response/error")
                .or_else(|| frame.get("error"))
                .unwrap_or(frame);
            Some(LlmStreamEvent::Error(LlmStreamError::provider(
                Some(
                    error["code"]
                        .as_str()
                        .unwrap_or("processing_error")
                        .to_owned(),
                ),
                None,
                error["message"]
                    .as_str()
                    .unwrap_or("The provider failed while processing the response."),
            )))
        }
        "response.completed" | "response.incomplete" | "response.done" => {
            Some(LlmStreamEvent::Error(LlmStreamError::provider(
                Some("malformed_response".to_owned()),
                None,
                "The provider did not return a valid completed response.",
            )))
        }
        _ => None,
    }
}