southesk 0.0.9

A Rust client library for the Montrose MCP API.
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

// Copyright 2026 Thomas Axelsson
// SPDX-License-Identifier: MIT

use std::time::Duration;

use southesk::ClientBuilder;
use tokio::time::sleep;
#[cfg(feature = "__dev")]
use tokio::time::timeout;
use tracing::warn;

#[tokio::test]
#[ignore = "takes very long time"]
async fn access_token_timeout() -> anyhow::Result<()> {
    // TODO: Read the actual timeout time from the token and use it.

    tracing_subscriber::fmt().init();

    let montrose = ClientBuilder::new("southesk tests")
        .cred_user("access_token_timeout_test")
        .build()
        .await?
        .connect()
        .await?;
    warn!("MCP use attempt 1: Instantly");
    montrose.get_user_accounts().await?;

    sleep(Duration::from_hours(1)).await;

    warn!("MCP use attempt 2: After 1 hour");
    montrose.get_user_accounts().await?;

    sleep(Duration::from_hours(25)).await;

    warn!("MCP use attempt 3: After 25 hours");
    montrose.get_user_accounts().await?;

    Ok(())
}

#[cfg(feature = "__dev")]
#[tokio::test]
#[ignore = "takes very long time"]
async fn force_token_refresh() -> anyhow::Result<()> {
    tracing_subscriber::fmt().init();

    // Make sure we have a valid token
    let montrose = ClientBuilder::new("southesk tests")
        .cred_user("token_refresh_test")
        .build()
        .await?
        .connect()
        .await?;

    // Test that the token works
    montrose.get_user_accounts().await?;

    sleep(Duration::from_secs(1)).await;

    // Refresh the token
    let montrose = ClientBuilder::new("southesk tests")
        .cred_user("token_refresh_test")
        // Don't wait for any interactive auth
        .no_auth()
        .dev_force_token_refresh()
        .build()
        .await?;

    warn!("Connecting to MCP with forced token refresh");
    let montrose = timeout(Duration::from_secs(5), montrose.connect()).await??;

    // Test that the refreshed token works
    montrose.get_user_accounts().await?;

    Ok(())
}