abs-data 0.2.2

DEPRECATED AND NO LONGER MAINTAINED DO NOT USE
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

#[cfg(test)]
mod tests {
    use abs_data::{
        builders::{
            dataflow_identifier_builder::DataflowIdentifierBuilder,
            datakey_builder::DataKeyBuilder, sdmx_data_request_builder::SdmxDataRequestBuilder,
            sdmx_meta_request_builder::SdmxMetaRequestBuilder,
        },
        models::typed::{
            datakey::DataKey, datakey_dimension::DataKeyDimension, detail::Detail, period::Period,
            structure_type::StructureType,
        },
        result::Result,
    };

    #[tokio::test]
    async fn get_dynamic_meta_and_use_for_request() -> Result<()> {
        let meta_response = SdmxMetaRequestBuilder::new(&StructureType::DataFlow)
            .build()
            .send()
            .await?;

        let dataflow = &meta_response.data.dataflows.unwrap()[10]; // Select desired dataflow

        let dataflow_identifier = DataflowIdentifierBuilder::new(&dataflow.id)
            .agency_id(&dataflow.agency_id)
            .version(&dataflow.version)
            .build();

        let _response = SdmxDataRequestBuilder::new(&dataflow_identifier)
            .detail(&Detail::DataOnly)
            .start_period(&Period::Year(2012))
            .end_period(&Period::Year(2022))
            .build()
            .send()
            .await?;

        Ok(())
    }

    #[tokio::test]
    async fn get_all_data_for_structure_id_without_filter() -> Result<()> {
        let dataflow_identifier = DataflowIdentifierBuilder::new("CPI").build();

        let _response = SdmxDataRequestBuilder::new(&dataflow_identifier) // Avoid 500 response with data only detail (issue with beta api)
            .build()
            .send()
            .await?;

        Ok(())
    }

    #[tokio::test]
    async fn get_datakeys_for_structure_id() -> Result<()> {
        let dataflow_identifier = DataflowIdentifierBuilder::new("CPI").build();

        let _response = SdmxDataRequestBuilder::new(&dataflow_identifier)
            .detail(&Detail::SeriesKeysOnly)
            .build()
            .send()
            .await?;

        Ok(())
    }

    #[tokio::test]
    async fn get_data_with_custom_datakey() -> Result<()> {
        let dataflow_identifier = DataflowIdentifierBuilder::new("CPI").build();

        let _response = SdmxDataRequestBuilder::new(&dataflow_identifier)
            .data_key(&DataKey::parse("1.40066.10.8.Q")?)
            .detail(&Detail::DataOnly)
            .build()
            .send()
            .await?;

        Ok(())
    }

    #[tokio::test]
    async fn get_data_with_datakey_builder_validation() -> Result<()> {
        let dataflow_identifier = DataflowIdentifierBuilder::new("CPI").build();

        let key = DataKeyBuilder::new(&dataflow_identifier)
            .add(&DataKeyDimension::new("MEASURE", "1"))
            .add(&DataKeyDimension::new("INDEX", "40066"))
            .add(&DataKeyDimension::new("REGION", "8"))
            .add(&DataKeyDimension::new("FREQ", "Q"))
            .add(&DataKeyDimension::new("TSEST", "10"))
            .build()
            .await?;

        assert_eq!(key, DataKey::parse("1.40066.10.8.Q")?);

        let _response = SdmxDataRequestBuilder::new(&dataflow_identifier)
            .data_key(&key)
            .detail(&Detail::DataOnly)
            .build()
            .send()
            .await?;

        Ok(())
    }
}