link-assistant-router 1.6.0

Link.Assistant.Router — Claude MAX OAuth proxy and token gateway for Anthropic APIs
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

use super::*;

/// Hand-written Claude credentials may use the legacy flat `snake_case` shape.
#[test]
fn write_token_preserves_the_flat_snake_case_claude_layout() {
    let dir = tempfile::tempdir().expect("credential home");
    let path = dir.path().join(".credentials.json");
    std::fs::write(
        &path,
        r#"{"access_token":"old","refresh_token":"old-r","expires_at":1,"marker":true}"#,
    )
    .expect("credential file");
    let reader = SubscriptionReader::new(SubscriptionProvider::Claude, dir.path());
    reader
        .write_token(&SubscriptionToken {
            access_token: "fresh".into(),
            refresh_token: Some("fresh-r".into()),
            expires_at_ms: Some(9_000),
            account_id: None,
            resource_url: None,
        })
        .expect("flat Claude refresh");
    let written: serde_json::Value =
        serde_json::from_str(&std::fs::read_to_string(path).unwrap()).unwrap();
    assert_eq!(written["access_token"], "fresh");
    assert_eq!(written["refresh_token"], "fresh-r");
    assert_eq!(written["expires_at"], 9_000);
    assert_eq!(written["marker"], true);
    assert!(written.get("accessToken").is_none());
}

#[test]
fn a_named_home_candidate_is_never_shadowed_by_the_platform_store() {
    let dir = tempfile::tempdir().expect("named account home");
    let reader = SubscriptionReader::new(SubscriptionProvider::Claude, dir.path());
    let candidate = SubscriptionToken {
        access_token: "candidate".into(),
        refresh_token: Some("candidate-refresh".into()),
        expires_at_ms: Some(1),
        account_id: None,
        resource_url: None,
    };
    assert!(!reader.candidate_is_shadowed_by_platform_store(&candidate));
}

#[test]
fn write_token_reports_an_unreadable_credential_path() {
    let dir = tempfile::tempdir().expect("credential home");
    let path = dir.path().join("oauth_creds.json");
    std::fs::create_dir(&path).expect("blocking directory");
    let reader = SubscriptionReader::new(SubscriptionProvider::Gemini, dir.path());
    let fresh = SubscriptionToken {
        access_token: "fresh".into(),
        refresh_token: Some("fresh-refresh".into()),
        expires_at_ms: Some(1_000),
        account_id: None,
        resource_url: None,
    };
    assert!(matches!(
        reader.write_token(&fresh),
        Err(SubscriptionError::ReadError(_))
    ));
    assert!(path.is_dir());
}

#[test]
fn clearing_credentials_reports_an_unremovable_credential_path() {
    let dir = tempfile::tempdir().expect("credential home");
    let path = dir.path().join("oauth_creds.json");
    std::fs::create_dir(&path).expect("blocking directory");
    let reader = SubscriptionReader::new(SubscriptionProvider::Qwen, dir.path());
    let error = reader
        .clear_credentials()
        .expect_err("an occupied credential path must be reported");
    assert!(error.contains(&path.display().to_string()), "{error}");
    assert!(path.is_dir());
}