mistral_openapi_client/apis/
agents_api.rs1use reqwest;
13use serde::{Deserialize, Serialize, de::Error as _};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration, ContentType};
16
17
18#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum AgentsCompletionV1AgentsCompletionsPostError {
22 Status422(models::HttpValidationError),
23 UnknownValue(serde_json::Value),
24}
25
26
27pub async fn agents_completion_v1_agents_completions_post(configuration: &configuration::Configuration, agents_completion_request: models::AgentsCompletionRequest) -> Result<models::ChatCompletionResponse, Error<AgentsCompletionV1AgentsCompletionsPostError>> {
28 let p_body_agents_completion_request = agents_completion_request;
30
31 let uri_str = format!("{}/v1/agents/completions", configuration.base_path);
32 let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
33
34 if let Some(ref user_agent) = configuration.user_agent {
35 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
36 }
37 if let Some(ref token) = configuration.bearer_access_token {
38 req_builder = req_builder.bearer_auth(token.to_owned());
39 };
40 req_builder = req_builder.json(&p_body_agents_completion_request);
41
42 let req = req_builder.build()?;
43 let resp = configuration.client.execute(req).await?;
44
45 let status = resp.status();
46 let content_type = resp
47 .headers()
48 .get("content-type")
49 .and_then(|v| v.to_str().ok())
50 .unwrap_or("application/octet-stream");
51 let content_type = super::ContentType::from(content_type);
52
53 if !status.is_client_error() && !status.is_server_error() {
54 let content = resp.text().await?;
55 match content_type {
56 ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
57 ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::ChatCompletionResponse`"))),
58 ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::ChatCompletionResponse`")))),
59 }
60 } else {
61 let content = resp.text().await?;
62 let entity: Option<AgentsCompletionV1AgentsCompletionsPostError> = serde_json::from_str(&content).ok();
63 Err(Error::ResponseError(ResponseContent { status, content, entity }))
64 }
65}
66