fakecloud-wafv2 0.19.1

AWS WAF v2 implementation for FakeCloud
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

//! `Wafv2Service` `mobile_sdk` family — extracted from service.rs by audit-2026-05-19.

use super::*;

impl Wafv2Service {
    pub(super) fn generate_mobile_sdk_release_url(
        &self,
        req: &AwsRequest,
    ) -> Result<AwsResponse, AwsServiceError> {
        let body = req.json_body();
        let platform = require_str(&body, "Platform")?;
        validate_enum(&platform, &["IOS", "ANDROID"], "Platform")?;
        let release = require_str_len(&body, "ReleaseVersion", 1, 64)?;
        Ok(AwsResponse::ok_json(json!({
            "Url": format!("https://wafv2-mobile-sdk.{}.amazonaws.com/{}/{}.zip", req.region, platform, release),
        })))
    }

    pub(super) fn get_mobile_sdk_release(
        &self,
        req: &AwsRequest,
    ) -> Result<AwsResponse, AwsServiceError> {
        let body = req.json_body();
        let platform = require_str(&body, "Platform")?;
        validate_enum(&platform, &["IOS", "ANDROID"], "Platform")?;
        let release = require_str_len(&body, "ReleaseVersion", 1, 64)?;
        Ok(AwsResponse::ok_json(json!({
            "MobileSdkRelease": {
                "ReleaseVersion": release,
                "Timestamp": Utc::now().timestamp() as f64,
                "ReleaseNotes": format!("fakecloud {platform} SDK release {release}"),
                "Tags": [],
            },
        })))
    }

    pub(super) fn list_mobile_sdk_releases(
        &self,
        req: &AwsRequest,
    ) -> Result<AwsResponse, AwsServiceError> {
        let body = req.json_body();
        let platform = require_str(&body, "Platform")?;
        validate_enum(&platform, &["IOS", "ANDROID"], "Platform")?;
        validate_opt_limit(&body)?;
        validate_opt_next_marker(&body)?;
        let limit = body.get("Limit").and_then(Value::as_u64).unwrap_or(100) as usize;
        let next_marker = body.get("NextMarker").and_then(Value::as_str).unwrap_or("");
        let all = [
            json!({"ReleaseVersion": "1.0.0", "Timestamp": Utc::now().timestamp() as f64}),
            json!({"ReleaseVersion": "1.1.0", "Timestamp": Utc::now().timestamp() as f64}),
        ];
        // Unknown NextMarker should yield an empty page, not silently
        // restart from offset 0 — falling back duplicates results when
        // the caller resumes from a stale token.
        let start = if next_marker.is_empty() {
            Some(0usize)
        } else {
            all.iter()
                .position(|r| r.get("ReleaseVersion").and_then(Value::as_str) == Some(next_marker))
                .map(|p| p + 1)
        };
        let page: Vec<Value> = match start {
            Some(s) => all.iter().skip(s).take(limit).cloned().collect(),
            None => Vec::new(),
        };
        let start = start.unwrap_or(all.len());
        let next = if start + page.len() < all.len() {
            page.last()
                .and_then(|r| r.get("ReleaseVersion"))
                .and_then(Value::as_str)
                .map(str::to_string)
        } else {
            None
        };
        let mut out = json!({ "ReleaseSummaries": page });
        if let Some(n) = next {
            out["NextMarker"] = json!(n);
        }
        Ok(AwsResponse::ok_json(out))
    }
}