langfuse_client_base/apis/
mod.rs

1use std::error;
2use std::fmt;
3
4#[derive(Debug, Clone)]
5pub struct ResponseContent<T> {
6    pub status: reqwest::StatusCode,
7    pub content: String,
8    pub entity: Option<T>,
9}
10
11#[derive(Debug)]
12pub enum Error<T> {
13    Reqwest(reqwest::Error),
14    ReqwestMiddleware(reqwest_middleware::Error),
15    Serde(serde_json::Error),
16    Io(std::io::Error),
17    ResponseError(ResponseContent<T>),
18}
19
20impl<T> fmt::Display for Error<T> {
21    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
22        let (module, e) = match self {
23            Error::Reqwest(e) => ("reqwest", e.to_string()),
24            Error::ReqwestMiddleware(e) => ("reqwest-middleware", e.to_string()),
25            Error::Serde(e) => ("serde", e.to_string()),
26            Error::Io(e) => ("IO", e.to_string()),
27            Error::ResponseError(e) => ("response", format!("status code {}", e.status)),
28        };
29        write!(f, "error in {}: {}", module, e)
30    }
31}
32
33impl<T: fmt::Debug> error::Error for Error<T> {
34    fn source(&self) -> Option<&(dyn error::Error + 'static)> {
35        Some(match self {
36            Error::Reqwest(e) => e,
37            Error::ReqwestMiddleware(e) => e,
38            Error::Serde(e) => e,
39            Error::Io(e) => e,
40            Error::ResponseError(_) => return None,
41        })
42    }
43}
44
45impl<T> From<reqwest::Error> for Error<T> {
46    fn from(e: reqwest::Error) -> Self {
47        Error::Reqwest(e)
48    }
49}
50
51impl<T> From<reqwest_middleware::Error> for Error<T> {
52    fn from(e: reqwest_middleware::Error) -> Self {
53        Error::ReqwestMiddleware(e)
54    }
55}
56
57impl<T> From<serde_json::Error> for Error<T> {
58    fn from(e: serde_json::Error) -> Self {
59        Error::Serde(e)
60    }
61}
62
63impl<T> From<std::io::Error> for Error<T> {
64    fn from(e: std::io::Error) -> Self {
65        Error::Io(e)
66    }
67}
68
69pub fn urlencode<T: AsRef<str>>(s: T) -> String {
70    ::url::form_urlencoded::byte_serialize(s.as_ref().as_bytes()).collect()
71}
72
73pub fn parse_deep_object(prefix: &str, value: &serde_json::Value) -> Vec<(String, String)> {
74    if let serde_json::Value::Object(object) = value {
75        let mut params = vec![];
76
77        for (key, value) in object {
78            match value {
79                serde_json::Value::Object(_) => params.append(&mut parse_deep_object(
80                    &format!("{}[{}]", prefix, key),
81                    value,
82                )),
83                serde_json::Value::Array(array) => {
84                    for (i, value) in array.iter().enumerate() {
85                        params.append(&mut parse_deep_object(
86                            &format!("{}[{}][{}]", prefix, key, i),
87                            value,
88                        ));
89                    }
90                }
91                serde_json::Value::String(s) => {
92                    params.push((format!("{}[{}]", prefix, key), s.clone()))
93                }
94                _ => params.push((format!("{}[{}]", prefix, key), value.to_string())),
95            }
96        }
97
98        return params;
99    }
100
101    unimplemented!("Only objects are supported with style=deepObject")
102}
103
104/// Internal use only
105/// A content type supported by this client.
106#[allow(dead_code)]
107enum ContentType {
108    Json,
109    Text,
110    Unsupported(String),
111}
112
113impl From<&str> for ContentType {
114    fn from(content_type: &str) -> Self {
115        if content_type.starts_with("application") && content_type.contains("json") {
116            return Self::Json;
117        } else if content_type.starts_with("text/plain") {
118            return Self::Text;
119        } else {
120            return Self::Unsupported(content_type.to_string());
121        }
122    }
123}
124
125pub mod annotation_queues_api;
126pub mod blob_storage_integrations_api;
127pub mod comments_api;
128pub mod dataset_items_api;
129pub mod dataset_run_items_api;
130pub mod datasets_api;
131pub mod health_api;
132pub mod ingestion_api;
133pub mod llm_connections_api;
134pub mod media_api;
135pub mod metrics_api;
136pub mod models_api;
137pub mod observations_api;
138pub mod opentelemetry_api;
139pub mod organizations_api;
140pub mod projects_api;
141pub mod prompt_version_api;
142pub mod prompts_api;
143pub mod scim_api;
144pub mod score_api;
145pub mod score_configs_api;
146pub mod score_v2_api;
147pub mod sessions_api;
148pub mod trace_api;
149
150pub mod configuration;
langfuse_client_base/apis/mod.rs

langfuse_client_base/apis/
mod.rs
