adobe 0.1.0

Adobe Document Services API client for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

//! https://developer.adobe.com/document-services/docs/apis/#tag/Assets/operation/asset.uploadpresignedurl

use reqwest::{Client, header::HeaderMap};
use serde::{Deserialize, Serialize};
use url::Url;

use crate::{ApiHttpRequest, Error};

#[derive(Clone, Debug, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct GetUploadPresignedUri {
    /// An asset ID identifying an asset that is globally unique and never reused.
    #[serde(rename = "assetID")]
    pub asset_id: String,
    /// The URL used to upload the Resource directly to the cloud provider.
    pub upload_uri: Url,
}

#[derive(Clone, Debug, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct GetUploadPresignedUriParams {
    /// The content type of the file to be stored. For e.g: application/pdf.
    pub media_type: String,
}

impl ApiHttpRequest for GetUploadPresignedUri {
    type Response = Self;
    type Params = (HeaderMap, GetUploadPresignedUriParams);

    async fn send(base_url: &Url, params: Self::Params) -> Result<Self::Response, Error> {
        let url = base_url.join("/assets")?;
        let client = Client::new();
        let resp = client
            .post(url)
            .json(&params.1)
            .headers(params.0)
            .send()
            .await?;

        if resp.status().is_success() {
            let resp: Self = resp.json().await?;
            return Ok(resp);
        }

        let status = resp.status();
        let text = resp.text().await.unwrap_or_default();
        Err(Error::ApiError(format!(
            "Status: {}, Response: {}",
            status, text
        )))
    }
}