cf-modkit 0.6.4

Core ModKit library
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

//! Tests for cursor+orderby policy enforcement

#[cfg(test)]
#[cfg_attr(coverage_nightly, coverage(off))]
mod tests {
    use super::super::odata::*;
    use axum::http::{Uri, request::Parts};
    use modkit_odata::{CursorV1, SortDir};

    fn mock_parts(query_string: &str) -> Parts {
        let uri: Uri = format!("http://example.com/test?{query_string}")
            .parse()
            .unwrap();
        let request = axum::http::Request::builder().uri(uri).body(()).unwrap();
        let (parts, ()) = request.into_parts();
        parts
    }

    #[tokio::test]
    async fn test_cursor_with_orderby_conflict() {
        let mut parts = mock_parts("cursor=dGVzdA%3D%3D&%24orderby=id%20desc");
        let result = extract_odata_query(&mut parts, &()).await;

        assert!(result.is_err());
        let _problem_response = result.unwrap_err();
    }

    #[tokio::test]
    async fn test_cursor_only_success() {
        // Create a valid cursor
        let cursor = CursorV1 {
            k: vec!["test".to_owned()],
            o: SortDir::Desc,
            s: "-id".to_owned(),
            f: None,
            d: "fwd".to_owned(),
        };
        let cursor_encoded = cursor.encode().unwrap();

        let mut parts = mock_parts(&format!("cursor={}", urlencoding::encode(&cursor_encoded)));
        let result = extract_odata_query(&mut parts, &()).await;

        assert!(result.is_ok());
        let query = result.unwrap();
        assert!(query.cursor.is_some());
        assert!(query.order.is_empty()); // Order should be empty when cursor is present
    }

    #[tokio::test]
    async fn test_orderby_only_success() {
        let mut parts = mock_parts("%24orderby=id%20desc%2C%20name%20asc");
        let result = extract_odata_query(&mut parts, &()).await;

        assert!(result.is_ok());
        let query = result.unwrap();
        assert!(query.cursor.is_none());
        assert!(!query.order.is_empty());
        assert_eq!(query.order.0.len(), 2);
        assert_eq!(query.order.0[0].field, "id");
        assert_eq!(query.order.0[0].dir, SortDir::Desc);
        assert_eq!(query.order.0[1].field, "name");
        assert_eq!(query.order.0[1].dir, SortDir::Asc);
    }

    #[tokio::test]
    async fn test_neither_cursor_nor_orderby() {
        let mut parts = mock_parts("limit=10");
        let result = extract_odata_query(&mut parts, &()).await;

        assert!(result.is_ok());
        let query = result.unwrap();
        assert!(query.cursor.is_none());
        assert!(query.order.is_empty());
        assert_eq!(query.limit, Some(10));
    }

    #[tokio::test]
    async fn test_invalid_cursor_error() {
        let mut parts = mock_parts("cursor=invalid_base64");
        let result = extract_odata_query(&mut parts, &()).await;

        assert!(result.is_err());
        let _problem_response = result.unwrap_err();
    }
}