atproto-devtool 0.1.1

A multitool for the atproto developer ecosystem
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162

//! Integration tests for the labeler HTTP stage using snapshot tests.

mod common;

use atproto_devtool::commands::test::labeler::http::run;
use common::FakeRawHttpTee;

/// Helper to render a report to a string for snapshot testing.
fn render_report_to_string(
    report: &atproto_devtool::commands::test::labeler::report::LabelerReport,
) -> String {
    let mut buf = Vec::new();
    report
        .render(
            &mut buf,
            &atproto_devtool::commands::test::labeler::report::RenderConfig { no_color: true },
        )
        .expect("render failed");
    String::from_utf8(buf).expect("invalid utf-8")
}

#[tokio::test]
async fn http_healthy_renders_all_ok() {
    let tee = FakeRawHttpTee::new();
    // Load fixture pages with real labels and pagination.
    let first_page = include_bytes!("fixtures/labeler/http/healthy/first_page.json").to_vec();
    let second_page = include_bytes!("fixtures/labeler/http/healthy/second_page.json").to_vec();

    tee.add_response(None, 200, first_page);
    tee.add_response(Some("cursor1"), 200, second_page);

    let output = run(&tee).await;

    // Build a minimal report for snapshot testing.
    let mut report = atproto_devtool::commands::test::labeler::report::LabelerReport::new(
        atproto_devtool::commands::test::labeler::report::ReportHeader {
            target: "https://example.com".to_string(),
            resolved_did: None,
            pds_endpoint: None,
            labeler_endpoint: Some("https://example.com".to_string()),
        },
    );

    for result in output.results {
        report.record(result);
    }
    report.finish();

    let rendered = render_report_to_string(&report);
    insta::assert_snapshot!(rendered);
}

#[tokio::test]
async fn http_empty_labeler_emits_advisory() {
    let tee = FakeRawHttpTee::new();
    let empty_page = include_bytes!("fixtures/labeler/http/empty/first_page.json").to_vec();

    tee.add_response(None, 200, empty_page);

    let output = run(&tee).await;

    let mut report = atproto_devtool::commands::test::labeler::report::LabelerReport::new(
        atproto_devtool::commands::test::labeler::report::ReportHeader {
            target: "https://example.com".to_string(),
            resolved_did: None,
            pds_endpoint: None,
            labeler_endpoint: Some("https://example.com".to_string()),
        },
    );

    for result in output.results {
        report.record(result);
    }
    report.finish();

    let rendered = render_report_to_string(&report);
    insta::assert_snapshot!(rendered);
}

#[tokio::test]
async fn http_malformed_schema_fails_with_source_span() {
    let tee = FakeRawHttpTee::new();
    let malformed = include_bytes!("fixtures/labeler/http/malformed/first_page.json").to_vec();

    tee.add_response(None, 200, malformed.clone());

    let output = run(&tee).await;

    let mut report = atproto_devtool::commands::test::labeler::report::LabelerReport::new(
        atproto_devtool::commands::test::labeler::report::ReportHeader {
            target: "https://example.com".to_string(),
            resolved_did: None,
            pds_endpoint: None,
            labeler_endpoint: Some("https://example.com".to_string()),
        },
    );

    for result in output.results {
        report.record(result);
    }
    report.finish();

    let rendered = render_report_to_string(&report);
    insta::assert_snapshot!(rendered);
}

#[tokio::test]
async fn http_ignored_cursor_fails() {
    let tee = FakeRawHttpTee::new();
    // Load fixture with identical pages (cursor ignored).
    let first_page =
        include_bytes!("fixtures/labeler/http/ignored_cursor/first_page.json").to_vec();
    let second_page =
        include_bytes!("fixtures/labeler/http/ignored_cursor/second_page.json").to_vec();

    tee.add_response(None, 200, first_page);
    tee.add_response(Some("cursor1"), 200, second_page);

    let output = run(&tee).await;

    let mut report = atproto_devtool::commands::test::labeler::report::LabelerReport::new(
        atproto_devtool::commands::test::labeler::report::ReportHeader {
            target: "https://example.com".to_string(),
            resolved_did: None,
            pds_endpoint: None,
            labeler_endpoint: Some("https://example.com".to_string()),
        },
    );

    for result in output.results {
        report.record(result);
    }
    report.finish();

    let rendered = render_report_to_string(&report);
    insta::assert_snapshot!(rendered);
}

#[tokio::test]
async fn http_transport_error_renders_network_error() {
    let tee = FakeRawHttpTee::new();
    tee.set_transport_error();

    let output = run(&tee).await;

    let mut report = atproto_devtool::commands::test::labeler::report::LabelerReport::new(
        atproto_devtool::commands::test::labeler::report::ReportHeader {
            target: "https://example.com".to_string(),
            resolved_did: None,
            pds_endpoint: None,
            labeler_endpoint: Some("https://example.com".to_string()),
        },
    );

    for result in output.results {
        report.record(result);
    }
    report.finish();

    let rendered = render_report_to_string(&report);
    insta::assert_snapshot!(rendered);
}