rusty-cat 0.2.2

Async HTTP client for resumable file upload and download.
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

use super::constants::PART_NUMBER_PROVIDER_ID_RADIX;
use crate::presigned::PresignedUploadPart;

/// Creates one Aliyun `UploadPart` entry.
pub fn upload_part(
    part_number: u64,
    offset: u64,
    size: u64,
    url: impl Into<String>,
) -> PresignedUploadPart {
    PresignedUploadPart::put(part_number, offset, size, url)
        .with_provider_part_id(provider_part_id(part_number))
}

/// Creates one Aliyun `UploadPart` entry with URL expiration metadata.
pub fn upload_part_with_expiry(
    part_number: u64,
    offset: u64,
    size: u64,
    url: impl Into<String>,
    expires_at_unix_secs: u64,
) -> PresignedUploadPart {
    upload_part(part_number, offset, size, url).with_expires_at_unix_secs(expires_at_unix_secs)
}

fn provider_part_id(part_number: u64) -> String {
    match PART_NUMBER_PROVIDER_ID_RADIX {
        10 => part_number.to_string(),
        radix => format_radix(part_number, radix),
    }
}

fn format_radix(mut value: u64, radix: u32) -> String {
    const DIGITS: &[u8; 36] = b"0123456789abcdefghijklmnopqrstuvwxyz";
    debug_assert!((2..=36).contains(&radix));
    if value == 0 {
        return "0".to_string();
    }
    let radix = u64::from(radix);
    let mut out = Vec::new();
    while value > 0 {
        out.push(DIGITS[(value % radix) as usize] as char);
        value /= radix;
    }
    out.iter().rev().collect()
}