openai_interface/responses/
input_items.rs1use url::Url;
13
14use crate::{
15 errors::OapiError,
16 rest::get::{Get, GetNoStream},
17};
18
19#[derive(Debug, Clone, Default)]
21pub struct ListInputItemsRequest<'a> {
22 pub response_id: &'a str,
24 pub after: Option<&'a str>,
26 pub before: Option<&'a str>,
28 pub limit: Option<u32>,
30 pub order: Option<InputItemsOrder>,
32 pub extra_query: Option<std::collections::HashMap<String, String>>,
34}
35
36#[derive(Debug, Clone, Copy, PartialEq, Eq)]
38pub enum InputItemsOrder {
39 Asc,
41 Desc,
43}
44
45impl InputItemsOrder {
46 fn as_str(self) -> &'static str {
47 match self {
48 InputItemsOrder::Asc => "asc",
49 InputItemsOrder::Desc => "desc",
50 }
51 }
52}
53
54impl Get for ListInputItemsRequest<'_> {
55 fn build_url(&self, base_url: &str) -> Result<String, OapiError> {
59 let mut url = Url::parse(base_url.trim_end_matches('/')).map_err(OapiError::UrlError)?;
60 url.path_segments_mut()
61 .map_err(|_| OapiError::UrlCannotBeBase(base_url.to_string()))?
62 .push("responses")
63 .push(self.response_id)
64 .push("input_items");
65
66 let mut query_pairs: Vec<(&str, &str)> = Vec::new();
67 if let Some(after) = self.after {
68 query_pairs.push(("after", after));
69 }
70 if let Some(before) = self.before {
71 query_pairs.push(("before", before));
72 }
73 if let Some(limit) = self.limit {
74 query_pairs.push(("limit", Box::leak(limit.to_string().into_boxed_str())));
75 }
76 if let Some(order) = self.order {
77 query_pairs.push(("order", order.as_str()));
78 }
79
80 if !query_pairs.is_empty() {
81 {
82 let mut pairs = url.query_pairs_mut();
83 for (key, value) in query_pairs {
84 pairs.append_pair(key, value);
85 }
86 }
87 }
88 if let Some(extra_query) = &self.extra_query {
89 let mut pairs = url.query_pairs_mut();
90 for (key, value) in extra_query {
91 pairs.append_pair(key, value);
92 }
93 }
94
95 Ok(url.to_string())
96 }
97}
98
99impl GetNoStream for ListInputItemsRequest<'_> {
100 type Response = ListResponseInputItems;
101}
102
103#[derive(Debug, Clone, serde::Deserialize)]
105pub struct ListResponseInputItems {
106 #[serde(default)]
110 pub data: Vec<crate::responses::ResponseOutputItem>,
111 #[serde(default)]
113 pub has_more: Option<bool>,
114 #[serde(default)]
116 pub first_id: Option<String>,
117 #[serde(default)]
119 pub object: Option<String>,
120}
121
122crate::impl_from_str!(ListResponseInputItems);