claude-codes 2.1.310

Typed Rust SDK for the Claude Code agent CLI: serde models of its JSON-Lines (stream-json) protocol with streaming parsing, plus sync and async (Tokio) clients for driving Claude Code sessions, tools, and subagents.
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

//! Coverage for the CLI 2.1.310 stream-json drift.
//!
//! 2.1.309 → 2.1.310 added two optional fields, no new message types and no
//! removals: each `rate_limit_info.unifiedWindows` entry now carries the
//! server's per-window `status` and `surpassedThreshold`.
//!
//! The frame below carries the new fields and is asserted **fully wrapped** —
//! the typed model captures every wire field with nothing left in an untyped
//! escape hatch.

use claude_codes::io::RateLimitStatus;
use claude_codes::{assert_fully_wrapped, ClaudeOutput};
use serde_json::json;

/// A rate limit event reports a per-window status and threshold, which can
/// differ from the top-level status of the currently limiting window.
#[test]
fn unified_windows_carry_status_and_surpassed_threshold() {
    let frame = json!({
        "type": "rate_limit_event",
        "session_id": "s1",
        "uuid": "u1",
        "rate_limit_info": {
            "status": "allowed",
            "resetsAt": 1788441600u64,
            "rateLimitType": "five_hour",
            "isUsingOverage": false,
            "unifiedWindows": {
                "five_hour": {
                    "resetsAt": 1788441600u64,
                    "utilization": 0.3,
                    "status": "allowed"
                },
                "seven_day": {
                    "resetsAt": 1788872400u64,
                    "utilization": 0.82,
                    "status": "allowed_warning",
                    "surpassedThreshold": 0.75
                },
                "seven_day_overage_included": {
                    "resetsAt": 1788872400u64,
                    "utilization": 1.02,
                    "status": "rejected",
                    "surpassedThreshold": 1.0
                }
            }
        }
    });
    assert_fully_wrapped(&frame);

    let ClaudeOutput::RateLimitEvent(evt) = serde_json::from_value(frame).unwrap() else {
        panic!("expected rate_limit_event");
    };
    let windows = evt.rate_limit_info.unified_windows.unwrap();
    let five_hour = windows.five_hour.unwrap();
    assert_eq!(five_hour.status, Some(RateLimitStatus::Allowed));
    assert_eq!(five_hour.surpassed_threshold, None);
    let seven_day = windows.seven_day.unwrap();
    assert_eq!(seven_day.status, Some(RateLimitStatus::AllowedWarning));
    assert_eq!(seven_day.surpassed_threshold, Some(0.75));
    let overage = windows.seven_day_overage_included.unwrap();
    assert_eq!(overage.status, Some(RateLimitStatus::Rejected));
    assert_eq!(overage.surpassed_threshold, Some(1.0));
}

/// Windows from older CLIs, without the new fields, still deserialize.
#[test]
fn unified_window_without_status_still_parses() {
    let frame = json!({
        "type": "rate_limit_event",
        "session_id": "s1",
        "rate_limit_info": {
            "status": "allowed",
            "unifiedWindows": {
                "five_hour": {"resetsAt": 1788441600u64, "utilization": 0.01}
            }
        }
    });

    let ClaudeOutput::RateLimitEvent(evt) = serde_json::from_value(frame).unwrap() else {
        panic!("expected rate_limit_event");
    };
    let five_hour = evt
        .rate_limit_info
        .unified_windows
        .unwrap()
        .five_hour
        .unwrap();
    assert_eq!(five_hour.status, None);
    assert_eq!(five_hour.surpassed_threshold, None);
}