box_open_sdk/managers/
uploads.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 [`UploadsManager::upload_file_version`].
7#[derive(Clone, Debug, Default)]
8pub struct UploadsUploadFileVersionOptions {
9    pub if_match: Option<String>,
10    pub fields: Option<Vec<String>>,
11    pub content_md5: Option<String>,
12}
13
14/// Optional parameters for [`UploadsManager::upload_file`].
15#[derive(Clone, Debug, Default)]
16pub struct UploadsUploadFileOptions {
17    pub fields: Option<Vec<String>>,
18    pub content_md5: Option<String>,
19}
20
21/// Operations for the "uploads" API area.
22pub struct UploadsManager {
23    session: std::sync::Arc<runtime::Client>,
24}
25
26impl UploadsManager {
27    pub(crate) fn new(session: std::sync::Arc<runtime::Client>) -> Self {
28        Self { session }
29    }
30
31    pub async fn upload_file_version(
32        &self,
33        file_id: String,
34        body: crate::models::schemas::CreateFileIdContentRequest,
35        opts: Option<UploadsUploadFileVersionOptions>,
36    ) -> Result<crate::models::schemas::Files, Error> {
37        let mut url = self.session.base_url("upload");
38        url.push_str("/files");
39        url.push('/');
40        let seg = path_escape(&file_id);
41        url.push_str(&seg);
42        url.push_str("/content");
43        let mut req = self.session.new_request("POST", &url);
44        let opts = opts.unwrap_or_default();
45        if let Some(value) = opts.if_match {
46            req = runtime::with_header(req, "if-match", &value);
47        }
48        if let Some(value) = opts.fields {
49            req = runtime::with_query(req, "fields", &value.join(","));
50        }
51        if let Some(value) = opts.content_md5 {
52            req = runtime::with_header(req, "content-md5", &value);
53        }
54        let attributes = serde_json::to_vec(&body)?;
55        req = runtime::with_multipart_body(req, &attributes, "file", runtime::Stream::empty());
56        let resp = self.session.fetch(req).await?;
57        let data = runtime::response_bytes(&resp)?;
58        Ok(serde_json::from_slice(&data)?)
59    }
60
61    pub async fn upload_file(
62        &self,
63        body: crate::models::schemas::CreateFileContentRequest,
64        opts: Option<UploadsUploadFileOptions>,
65    ) -> Result<crate::models::schemas::Files, Error> {
66        let mut url = self.session.base_url("upload");
67        url.push_str("/files");
68        url.push_str("/content");
69        let mut req = self.session.new_request("POST", &url);
70        let opts = opts.unwrap_or_default();
71        if let Some(value) = opts.fields {
72            req = runtime::with_query(req, "fields", &value.join(","));
73        }
74        if let Some(value) = opts.content_md5 {
75            req = runtime::with_header(req, "content-md5", &value);
76        }
77        let attributes = serde_json::to_vec(&body)?;
78        req = runtime::with_multipart_body(req, &attributes, "file", runtime::Stream::empty());
79        let resp = self.session.fetch(req).await?;
80        let data = runtime::response_bytes(&resp)?;
81        Ok(serde_json::from_slice(&data)?)
82    }
83
84    pub async fn option_file_content(
85        &self,
86        body: crate::models::schemas::OptionFileContentRequest,
87    ) -> Result<crate::models::schemas::UploadUrl, Error> {
88        let mut url = self.session.base_url("api");
89        url.push_str("/files");
90        url.push_str("/content");
91        let mut req = self.session.new_request("OPTIONS", &url);
92        let payload = serde_json::to_vec(&body)?;
93        req = runtime::with_json_body(req, &payload);
94        let resp = self.session.fetch(req).await?;
95        let data = runtime::response_bytes(&resp)?;
96        Ok(serde_json::from_slice(&data)?)
97    }
98}
box_open_sdk/managers/uploads.rs

box_open_sdk/managers/
uploads.rs
