amazon-sp-api 0.1.16

A library to make working with Amazon SP-API a bit easier.
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

use std::collections::HashMap;
use reqwest::{Method, Response};
use serde::{Deserialize, Serialize};
use serde_json::json;
use crate::error_handling::Errors;
use crate::general::{Client, CountryMarketplace};
pub enum CompetitiveSummaryIncludedData {
    FeaturedBuyingOptions,
    ReferencePrices,
    LowestPricedOffers
}
impl CompetitiveSummaryIncludedData {
    fn to_string(&self) -> String {
        match self {
            CompetitiveSummaryIncludedData::FeaturedBuyingOptions => "featuredBuyingOptions".to_string(),
            CompetitiveSummaryIncludedData::ReferencePrices => "referencePrices".to_string(),
            CompetitiveSummaryIncludedData::LowestPricedOffers => "lowestPricedOffers".to_string()
        }
    }
}
#[allow(non_snake_case)]
#[derive(Debug, Deserialize, Serialize, Clone)]
struct CompetitiveSummaryData {
    method: String,
    uri: String,
    marketplaceId: String,
    asin: String,
    includedData: Vec<String>,
}
pub struct ProductPricing;
impl ProductPricing {
    /// **DEV NOTE:** This will internally use the Vec of sku to make it as a batch
    /// the set of responses for a batch of Featured Offer Expected Price (FOEP) requests.
    ///
    /// Rate (requests per second): 0.033
    /// Burst: 1
    ///
    /// # Parameters
    /// - `client`: Reference to the HTTP client.
    /// - `requests`: A vector of individual FOEP request parameters.
    /// - `uri`: The URI associated with the requests. Default: `/products/pricing/2022-05-01/offer/featuredOfferExpectedPrice`.
    ///
    /// # Responses
    /// - **200 (Success):** Returns a `GetFeaturedOfferExpectedPriceBatchResponse` object.
    pub async fn get_featured_offer_expected_price_batch(
        client: &mut Client,
        //requests: Vec<(String, String)>, // Tuple (marketplace_id, sku)
        uri: Option<String>, // Optional custom URI
        method: String,
        body: Option<String>,
        headers: Option<HashMap<String, String>>,
        market_place: crate::general::CountryMarketplace,
        sku: Vec<String>,
    ) -> Result<Response, Errors> {
        const URL: &str = "/batches/products/pricing/2022-05-01/offer/featuredOfferExpectedPrice";
        const DEFAULT_URI: &str = "/products/pricing/2022-05-01/offer/featuredOfferExpectedPrice";

        let uri = uri.unwrap_or(DEFAULT_URI.to_string());
        let mut params: HashMap<String, String> = HashMap::from([("uri".to_string(),uri.clone()), ("method".to_string(), method), ("marketplaceId".to_string(), market_place.details().0.to_string())]);
        if let Some(o) = body {
            params.insert("body".to_string(), o);
        }
        if let Some(h) = headers {
            params.insert("headers".to_string(), h.iter().map(|s| serde_json::to_string(&s).unwrap()).collect());
        }
        let final_params: Vec<HashMap<String,String>> = sku.iter().map(|small_sku| {
            let mut ff = params.clone();
            ff.insert(String::from("sku"), small_sku.clone());
            ff
        }).collect();

        client
            .make_request_w_body(URL, Method::POST, None::<Vec<(String, String)>>, serde_json::to_string(&HashMap::from([("requests".to_string(),final_params)]))?)
            .await
    }

    /// Returns the competitive summary for a batch of ASIN and marketplaceId combinations.
    /// With number of items between 1 and 20.
    ///
    /// Rate (requests per second): 0.033
    /// Burst: 1
    ///
    /// # Parameters
    /// - `client`: Reference to the HTTP client.
    /// - `requests`: A vector of individual request parameters.
    /// - `uri`: The URI associated with the requests. Default: `/products/pricing/2022-05-01/items/competitiveSummary`.
    ///
    /// # Responses
    /// - **200 (Success):** Returns a `CompetitiveSummaryBatchResponse` object.
    pub async fn get_competitive_summary(
        client: &mut Client,
        asin: Vec<String>,
        market_place: CountryMarketplace,
        included_data: Vec<CompetitiveSummaryIncludedData>,
        method: String,
        uri: Option<String>, // Optional custom URI
    ) -> Result<Response, Errors> {
        const URL: &str = "/batches/products/pricing/2022-05-01/items/competitiveSummary";
        const DEFAULT_URI: &str = "/products/pricing/2022-05-01/items/competitiveSummary";

        let uri = uri.unwrap_or(DEFAULT_URI.to_string());
        let data = &included_data.iter().map(|s| s.to_string()).collect::<Vec<String>>();

        let final_result = asin.iter().map(|a| {
            CompetitiveSummaryData {
                method: method.clone(),
                uri: uri.clone(),
                marketplaceId: market_place.details().0.to_string(),
                asin: a.clone(),
                includedData: data.clone(),
            }
        }).collect::<Vec<CompetitiveSummaryData>>();
        let to_send = json!({"requests": final_result});
        client
            .make_request_w_body(URL, Method::POST, None::<Vec<(String, String)>>, serde_json::to_string(&to_send)?)
            .await

    }


}