shardline-server 1.0.1

HTTP server boundary, runtime, and operator workflows for Shardline.
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

use crate::ServerError;
use crate::app::protocol_routes::oci::path::{OciPath, parse_oci_path};
use axum::http::Uri;

#[test]
fn oci_path_parser_accepts_supported_routes() {
    assert!(matches!(
        parse_oci_path("team/assets/blobs/sha256:0123456789abcdef0123456789abcdef0123456789abcdef0123456789abcdef"),
        Ok(OciPath::Blob { repository, digest_hex })
            if repository == "team/assets"
                && digest_hex
                    == "0123456789abcdef0123456789abcdef0123456789abcdef0123456789abcdef"
    ));
    assert!(matches!(
        parse_oci_path("team/assets/blobs/uploads"),
        Ok(OciPath::BlobUploads { repository }) if repository == "team/assets"
    ));
    assert!(matches!(
        parse_oci_path("team/assets/blobs/uploads/0000000000000001"),
        Ok(OciPath::BlobUploadSession { repository, session_id })
            if repository == "team/assets" && session_id == "0000000000000001"
    ));
    assert!(matches!(
        parse_oci_path("team/assets/manifests/v1"),
        Ok(OciPath::Manifest { repository, reference })
            if repository == "team/assets" && reference == "v1"
    ));
    assert!(matches!(
        parse_oci_path("team/assets/tags/list"),
        Ok(OciPath::TagsList { repository }) if repository == "team/assets"
    ));
}

#[test]
fn oci_path_parser_rejects_invalid_repository_and_digest_inputs() {
    assert!(matches!(
        parse_oci_path("Team/assets/tags/list"),
        Err(ServerError::InvalidRepositoryName)
    ));
    assert!(matches!(
        parse_oci_path("team/assets/blobs/sha256:not-a-digest"),
        Err(ServerError::InvalidDigest)
    ));
    assert!(matches!(
        parse_oci_path("team/assets/unknown"),
        Err(ServerError::NotFound)
    ));
}

#[test]
fn upload_content_range_parser_accepts_common_client_formats() {
    assert_eq!(
        super::parse_upload_content_range("0-9")
            .ok()
            .map(|range| (range.start(), range.end_inclusive())),
        Some((0, 9))
    );
    assert_eq!(
        super::parse_upload_content_range("bytes 10-19/20")
            .ok()
            .map(|range| (range.start(), range.end_inclusive())),
        Some((10, 19))
    );
    assert_eq!(
        super::parse_upload_content_range("bytes 20-29/*")
            .ok()
            .map(|range| (range.start(), range.end_inclusive())),
        Some((20, 29))
    );
}

#[test]
fn protocol_query_parser_rejects_oversized_inputs() {
    let uri = Uri::builder()
        .path_and_query(format!(
            "/v2/team/assets/blobs/uploads?mount={}",
            "a".repeat(super::MAX_PROTOCOL_QUERY_BYTES + 1)
        ))
        .build();
    assert!(uri.is_ok());
    let Ok(uri) = uri else {
        return;
    };

    assert!(matches!(
        super::parse_query_map(&uri),
        Err(ServerError::RequestQueryTooLarge)
    ));
    assert!(matches!(
        super::parse_query_values(&uri, "mount"),
        Err(ServerError::RequestQueryTooLarge)
    ));
}