tembo_api_client/apis/
ai_api.rs1use super::{configuration, Error};
12use crate::{apis::ResponseContent, models};
13use reqwest;
14use serde::{Deserialize, Serialize};
15
16#[derive(Debug, Clone, Serialize, Deserialize)]
18#[serde(untagged)]
19pub enum AskError {
20 Status400(serde_json::Value),
21 Status401(models::ErrorResponseSchema),
22 UnknownValue(serde_json::Value),
23}
24
25#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum SearchError {
29 Status400(serde_json::Value),
30 Status401(models::ErrorResponseSchema),
31 UnknownValue(serde_json::Value),
32}
33
34pub async fn ask(
36 configuration: &configuration::Configuration,
37 query: &str,
38) -> Result<models::AskResult, Error<AskError>> {
39 let p_query = query;
41
42 let uri_str = format!("{}/api/v1/ask/", configuration.base_path);
43 let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
44
45 req_builder = req_builder.query(&[("query", &p_query.to_string())]);
46 if let Some(ref user_agent) = configuration.user_agent {
47 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
48 }
49 if let Some(ref token) = configuration.bearer_access_token {
50 req_builder = req_builder.bearer_auth(token.to_owned());
51 };
52
53 let req = req_builder.build()?;
54 let resp = configuration.client.execute(req).await?;
55
56 let status = resp.status();
57
58 if !status.is_client_error() && !status.is_server_error() {
59 let content = resp.text().await?;
60 serde_json::from_str(&content).map_err(Error::from)
61 } else {
62 let content = resp.text().await?;
63 let entity: Option<AskError> = serde_json::from_str(&content).ok();
64 Err(Error::ResponseError(ResponseContent {
65 status,
66 content,
67 entity,
68 }))
69 }
70}
71
72pub async fn search(
74 configuration: &configuration::Configuration,
75 query: &str,
76 limit: Option<i32>,
77) -> Result<models::SearchResponse, Error<SearchError>> {
78 let p_query = query;
80 let p_limit = limit;
81
82 let uri_str = format!("{}/api/v1/search/", configuration.base_path);
83 let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
84
85 req_builder = req_builder.query(&[("query", &p_query.to_string())]);
86 if let Some(ref param_value) = p_limit {
87 req_builder = req_builder.query(&[("limit", ¶m_value.to_string())]);
88 }
89 if let Some(ref user_agent) = configuration.user_agent {
90 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
91 }
92 if let Some(ref token) = configuration.bearer_access_token {
93 req_builder = req_builder.bearer_auth(token.to_owned());
94 };
95
96 let req = req_builder.build()?;
97 let resp = configuration.client.execute(req).await?;
98
99 let status = resp.status();
100
101 if !status.is_client_error() && !status.is_server_error() {
102 let content = resp.text().await?;
103 serde_json::from_str(&content).map_err(Error::from)
104 } else {
105 let content = resp.text().await?;
106 let entity: Option<SearchError> = serde_json::from_str(&content).ok();
107 Err(Error::ResponseError(ResponseContent {
108 status,
109 content,
110 entity,
111 }))
112 }
113}