wdpe 0.4.2

WebDynpro Parse Engine
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

use crate::body::Body;
use crate::error::ClientError;
use crate::state::SapSsrClient;
use crate::{body::BodyUpdate, requests::WebDynproRequests};
use reqwest::header::{ACCEPT, CONTENT_TYPE, HeaderMap, HeaderValue};
use url::Url;

/// Helper function to create headers for XHR requests
pub fn wd_xhr_header() -> HeaderMap {
    let mut headers = HeaderMap::new();
    headers.insert(ACCEPT, HeaderValue::from_static("*/*"));
    headers.insert(
        CONTENT_TYPE,
        HeaderValue::from_static("application/x-www-form-urlencoded; charset=UTF-8"),
    );
    headers.insert(
        "X-Requested-With",
        HeaderValue::from_static("XMLHttpRequest"),
    );
    headers
}

impl WebDynproRequests for reqwest::Client {
    async fn navigate(&self, base_url: &Url, name: &str) -> Result<Body, ClientError> {
        let url = super::build_navigation_url(base_url, name);

        let response = self
            .get(&url)
            .send()
            .await
            .map_err(|e| ClientError::FailedRequest(e.to_string()))?;

        if !response.status().is_success() {
            return Err(ClientError::InvalidResponse(response.status().to_string()));
        }

        Ok(Body::new(
            response
                .text()
                .await
                .map_err(|e| ClientError::FailedRequest(e.to_string()))?,
        )?)
    }

    async fn send_events(
        &self,
        base_url: &Url,
        ssr_client: &SapSsrClient,
        serialized_events: &str,
    ) -> Result<BodyUpdate, ClientError> {
        let url = ssr_client.build_action_url(base_url)?;
        let params = [
            ("sap-charset", ssr_client.charset.as_str()),
            ("sap-wd-secure-id", ssr_client.wd_secure_id.as_str()),
            ("fesrAppName", ssr_client.app_name.as_str()),
            (
                "fesrUseBeacon",
                if ssr_client.use_beacon {
                    "true"
                } else {
                    "false"
                },
            ),
            ("SAPEVENTQUEUE", serialized_events),
        ];

        let response = self
            .post(url)
            .headers(wd_xhr_header())
            .form(&params)
            .send()
            .await
            .map_err(|e| ClientError::FailedRequest(e.to_string()))?;

        if !response.status().is_success() {
            return Err(ClientError::InvalidResponse(response.status().to_string()));
        }

        let response_text = response
            .text()
            .await
            .map_err(|e| ClientError::FailedRequest(e.to_string()))?;
        Ok(BodyUpdate::new(&response_text)?)
    }
}