rusty_dropbox_sdk 0.8.2

Unofficial SDK for dropbox in Rust
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
105
106

//! Behavioural tests for `implement_service!` paths that the per-endpoint
//! `implement_tests!` blocks don't exercise: retry on 429 and 5xx,
//! Unauthorized branching, typed-error downcast.

#![cfg(all(test, feature = "test-utils"))]

use crate::api;
use crate::api::Service;
use crate::tests_utils::with_test_server_async;

const RAW_FILE_METADATA: &str = r#"{".tag":"file","name":"f.txt","id":"id:abc","client_modified":"2025-01-01T00:00:00Z","server_modified":"2025-01-01T00:00:00Z","rev":"r1","size":1,"path_lower":"/f.txt","path_display":"/f.txt","is_downloadable":true}"#;

fn build_get_metadata_request<'a>(
    token: &'a str,
) -> api::files::get_metadata::GetMetadataRequest<'a> {
    api::files::get_metadata::GetMetadataRequest {
        access_token: token,
        payload: Some(api::files::GetMetadataArgs {
            path: "/f.txt".to_string(),
            include_media_info: None,
            include_deleted: None,
            include_has_explicit_shared_members: None,
            include_property_groups: None,
        }),
    }
}

#[tokio::test]
async fn retries_on_429_then_succeeds() {
    with_test_server_async(|mut server| async move {
        let m429 = server
            .mock("POST", "/2/files/get_metadata")
            .with_status(429)
            .with_header("Retry-After", "1")
            .with_body("")
            .expect(1)
            .create_async()
            .await;
        let m200 = server
            .mock("POST", "/2/files/get_metadata")
            .with_status(200)
            .with_header("Content-Type", "application/json")
            .with_body(RAW_FILE_METADATA)
            .expect(1)
            .create_async()
            .await;
        let req = build_get_metadata_request("test");
        let resp = req.call().await.expect("retry path failed");
        assert!(resp.is_some());
        m429.assert();
        m200.assert();
    })
    .await;
}

#[tokio::test]
async fn retries_on_503_then_succeeds() {
    with_test_server_async(|mut server| async move {
        let m503 = server
            .mock("POST", "/2/files/get_metadata")
            .with_status(503)
            .with_body("")
            .expect(1)
            .create_async()
            .await;
        let m200 = server
            .mock("POST", "/2/files/get_metadata")
            .with_status(200)
            .with_header("Content-Type", "application/json")
            .with_body(RAW_FILE_METADATA)
            .expect(1)
            .create_async()
            .await;
        let req = build_get_metadata_request("test");
        let resp = req.call().await.expect("5xx retry failed");
        assert!(resp.is_some());
        m503.assert();
        m200.assert();
    })
    .await;
}

#[tokio::test]
async fn unauthorized_returns_typed_error_variant() {
    with_test_server_async(|mut server| async move {
        let mock401 = server
            .mock("POST", "/2/files/get_metadata")
            .with_status(401)
            .with_body(
                r#"{"error_summary":"expired_access_token/.","error":{".tag":"expired_access_token"}}"#,
            )
            .expect(1)
            .create_async()
            .await;
        let req = build_get_metadata_request("test");
        let err = req.call().await.expect_err("expected 401 error");
        let downcast = err.downcast_ref::<crate::errors::ApiError>();
        assert!(
            matches!(downcast, Some(crate::errors::ApiError::Unauthorized(_))),
            "expected ApiError::Unauthorized, got: {:?}",
            err
        );
        mock401.assert();
    })
    .await;
}