opencrabs 0.3.58

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Install with: cargo install opencrabs
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

use crate::brain::provider::copilot::*;

#[test]
fn copilot_client_id_is_well_known() {
    assert_eq!(COPILOT_CLIENT_ID, "Iv1.b507a08c87ecfe98");
}

#[test]
fn copilot_urls_are_correct() {
    assert!(COPILOT_CHAT_URL.starts_with("https://api.githubcopilot.com"));
    assert!(COPILOT_MODELS_URL.starts_with("https://api.githubcopilot.com"));
    assert!(COPILOT_TOKEN_URL.contains("copilot_internal"));
    assert!(DEVICE_CODE_URL.contains("login/device"));
    assert!(OAUTH_TOKEN_URL.contains("login/oauth"));
}

#[test]
fn copilot_extra_headers_include_required_fields() {
    let headers = copilot_extra_headers();
    let keys: Vec<&str> = headers.iter().map(|(k, _)| k.as_str()).collect();
    assert!(keys.contains(&"copilot-integration-id"));
    assert!(keys.contains(&"editor-version"));
    assert!(keys.contains(&"user-agent"));
}

#[test]
fn token_manager_starts_with_empty_token() {
    let manager = CopilotTokenManager::new("gho_test".to_string());
    assert!(manager.get_cached_token().is_empty());
}

#[test]
fn oauth_poll_response_handles_pending() {
    let json = r#"{"error": "authorization_pending"}"#;
    let resp: OAuthPollResponse = serde_json::from_str(json).unwrap();
    assert_eq!(resp.error.as_deref(), Some("authorization_pending"));
    assert!(resp.access_token.is_none());
}

#[test]
fn oauth_poll_response_handles_success() {
    let json = r#"{"access_token": "gho_abc123", "token_type": "bearer", "scope": "read:user"}"#;
    let resp: OAuthPollResponse = serde_json::from_str(json).unwrap();
    assert_eq!(resp.access_token.as_deref(), Some("gho_abc123"));
    assert!(resp.error.is_none());
}

#[test]
fn copilot_token_response_deserializes() {
    let json = r#"{"token": "tid=abc;exp=9999999999", "expires_at": 9999999999}"#;
    let resp: CopilotTokenResponse = serde_json::from_str(json).unwrap();
    assert!(resp.token.starts_with("tid="));
    assert_eq!(resp.expires_at, 9999999999);
}

#[test]
fn device_flow_response_deserializes() {
    let json = r#"{
            "device_code": "abc123",
            "user_code": "ABCD-1234",
            "verification_uri": "https://github.com/login/device",
            "expires_in": 900,
            "interval": 5
        }"#;
    let resp: DeviceFlowResponse = serde_json::from_str(json).unwrap();
    assert_eq!(resp.user_code, "ABCD-1234");
    assert_eq!(resp.interval, 5);
    assert_eq!(resp.expires_in, 900);
}