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

pub mod response;

use urlencoding::decode;

use crate::{
    endpoints::NOTION_URI,
    objects::{page::Page, Response},
    NotionClientError,
};

use self::response::RetrieveAPagePropertyItemResponse;

use super::PagesEndpoint;

impl PagesEndpoint {
    pub async fn retrieve_a_page(
        &self,
        page_id: &str,
        filter_properties: Option<Vec<&str>>,
    ) -> Result<Page, NotionClientError> {
        let filter_properties: Vec<_> = filter_properties
            .iter()
            .flatten()
            .map(|p| ("filter_properties", decode(p).unwrap()))
            .collect();

        let result = self
            .client
            .get(format!(
                "{notion_uri}/pages/{page_id}",
                notion_uri = NOTION_URI,
                page_id = page_id
            ))
            .query(&filter_properties)
            .send()
            .await
            .map_err(|e| NotionClientError::FailedToRequest { source: e })?;

        let body = result
            .text()
            .await
            .map_err(|e| NotionClientError::FailedToText { source: e })?;

        let response = serde_json::from_str(&body)
            .map_err(|e| NotionClientError::FailedToDeserialize { source: e, body })?;

        match response {
            Response::Success(r) => Ok(r),
            Response::Error(e) => Err(NotionClientError::InvalidStatusCode { error: e }),
        }
    }

    pub async fn retrieve_a_page_property_item(
        &self,
        page_id: &str,
        property_id: &str,
        page_size: Option<u32>,
        start_cursor: Option<&str>,
    ) -> Result<RetrieveAPagePropertyItemResponse, NotionClientError> {
        let mut query = vec![];
        let page_size = page_size.map(|p| p.to_string());
        if let Some(start_cursor) = start_cursor {
            query.insert(0, ("start_cursor", start_cursor));
        }
        if let Some(page_size) = &page_size {
            query.insert(0, ("page_size", page_size));
        }

        let result = self
            .client
            .get(format!(
                "{notion_uri}/pages/{page_id}/properties/{property_id}",
                notion_uri = NOTION_URI,
                page_id = page_id,
                property_id = property_id,
            ))
            .query(&query)
            .send()
            .await
            .map_err(|e| NotionClientError::FailedToRequest { source: e })?;

        let body = result
            .text()
            .await
            .map_err(|e| NotionClientError::FailedToText { source: e })?;

        let response = serde_json::from_str(&body)
            .map_err(|e| NotionClientError::FailedToDeserialize { source: e, body })?;

        match response {
            Response::Success(r) => Ok(r),
            Response::Error(e) => Err(NotionClientError::InvalidStatusCode { error: e }),
        }
    }
}