box_open_sdk/managers/
webhooks.rs

1// Code generated by box-gantry. DO NOT EDIT.
2
3use crate::internal::path_escape;
4use crate::runtime::{self, Error};
5
6/// Optional parameters for [`WebhooksManager::list`].
7#[derive(Clone, Debug, Default)]
8pub struct WebhooksListOptions {
9    pub marker: Option<String>,
10    pub limit: Option<i64>,
11}
12
13/// Async paginator over [`WebhooksManager::list`], yielding one `crate::models::schemas::WebhookMini`
14/// per item across pages (FR-7.3).
15pub struct WebhooksListPaginator {
16    manager: WebhooksManager,
17    options: WebhooksListOptions,
18    buffer: std::vec::IntoIter<crate::models::schemas::WebhookMini>,
19    done: bool,
20}
21
22impl WebhooksListPaginator {
23    /// The next item, advancing pages as needed; `None` at the end.
24    /// An error is yielded once, then iteration stops.
25    pub async fn next(&mut self) -> Option<Result<crate::models::schemas::WebhookMini, Error>> {
26        loop {
27            if let Some(item) = self.buffer.next() {
28                return Some(Ok(item));
29            }
30            if self.done {
31                return None;
32            }
33            let page = match self.manager.list_page(Some(self.options.clone())).await {
34                Ok(page) => page,
35                Err(err) => {
36                    self.done = true;
37                    return Some(Err(err));
38                }
39            };
40            self.buffer = page.entries.unwrap_or_default().into_iter();
41            match page.next_marker.flatten() {
42                Some(cursor) if !cursor.is_empty() => self.options.marker = Some(cursor),
43                _ => self.done = true,
44            }
45        }
46    }
47}
48
49/// Operations for the "webhooks" API area.
50pub struct WebhooksManager {
51    session: std::sync::Arc<runtime::Client>,
52}
53
54impl WebhooksManager {
55    pub(crate) fn new(session: std::sync::Arc<runtime::Client>) -> Self {
56        Self { session }
57    }
58
59    async fn list_page(
60        &self,
61        opts: Option<WebhooksListOptions>,
62    ) -> Result<crate::models::schemas::Webhooks, Error> {
63        let mut url = self.session.base_url("api");
64        url.push_str("/webhooks");
65        let mut req = self.session.new_request("GET", &url);
66        let opts = opts.unwrap_or_default();
67        if let Some(value) = opts.marker {
68            req = runtime::with_query(req, "marker", &value);
69        }
70        if let Some(value) = opts.limit {
71            req = runtime::with_query(req, "limit", &value.to_string());
72        }
73        let resp = self.session.fetch(req).await?;
74        let data = runtime::response_bytes(&resp)?;
75        Ok(serde_json::from_slice(&data)?)
76    }
77
78    /// Iterate every `crate::models::schemas::WebhookMini` across pages, threading the cursor.
79    pub fn list(&self, opts: Option<WebhooksListOptions>) -> WebhooksListPaginator {
80        WebhooksListPaginator {
81            manager: WebhooksManager::new(self.session.clone()),
82            options: opts.unwrap_or_default(),
83            buffer: Vec::new().into_iter(),
84            done: false,
85        }
86    }
87
88    pub async fn create(
89        &self,
90        body: crate::models::schemas::WebhookCreateRequest,
91    ) -> Result<crate::models::schemas::Webhook, Error> {
92        let mut url = self.session.base_url("api");
93        url.push_str("/webhooks");
94        let mut req = self.session.new_request("POST", &url);
95        let payload = serde_json::to_vec(&body)?;
96        req = runtime::with_json_body(req, &payload);
97        let resp = self.session.fetch(req).await?;
98        let data = runtime::response_bytes(&resp)?;
99        Ok(serde_json::from_slice(&data)?)
100    }
101
102    pub async fn get(&self, webhook_id: String) -> Result<crate::models::schemas::Webhook, Error> {
103        let mut url = self.session.base_url("api");
104        url.push_str("/webhooks");
105        url.push('/');
106        let seg = path_escape(&webhook_id);
107        url.push_str(&seg);
108        let req = self.session.new_request("GET", &url);
109        let resp = self.session.fetch(req).await?;
110        let data = runtime::response_bytes(&resp)?;
111        Ok(serde_json::from_slice(&data)?)
112    }
113
114    pub async fn update(
115        &self,
116        webhook_id: String,
117        body: crate::models::schemas::WebhookUpdateRequest,
118    ) -> Result<crate::models::schemas::Webhook, Error> {
119        let mut url = self.session.base_url("api");
120        url.push_str("/webhooks");
121        url.push('/');
122        let seg = path_escape(&webhook_id);
123        url.push_str(&seg);
124        let mut req = self.session.new_request("PUT", &url);
125        let payload = serde_json::to_vec(&body)?;
126        req = runtime::with_json_body(req, &payload);
127        let resp = self.session.fetch(req).await?;
128        let data = runtime::response_bytes(&resp)?;
129        Ok(serde_json::from_slice(&data)?)
130    }
131
132    pub async fn delete(&self, webhook_id: String) -> Result<(), Error> {
133        let mut url = self.session.base_url("api");
134        url.push_str("/webhooks");
135        url.push('/');
136        let seg = path_escape(&webhook_id);
137        url.push_str(&seg);
138        let req = self.session.new_request("DELETE", &url);
139        let _ = self.session.fetch(req).await?;
140        Ok(())
141    }
142}
box_open_sdk/managers/webhooks.rs

box_open_sdk/managers/
webhooks.rs
