gproxy-file 4.1.2

Optional local filesystem and S3/R2 storage for GPROXY, powered by OpenDAL
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

#![cfg(all(feature = "fs", not(target_arch = "wasm32")))]

use gproxy_file::{Buffer, ErrorKind, filesystem};

#[tokio::test]
async fn local_files_roundtrip_overwrite_list_and_delete() {
    let directory = tempfile::tempdir().unwrap();
    let files = filesystem(directory.path().to_str().unwrap()).unwrap();
    let data: Vec<u8> = (0..=255).collect();
    files.write("nested/中文.bin", data.clone()).await.unwrap();
    assert_eq!(files.read("nested/中文.bin").await.unwrap().to_vec(), data);
    assert_eq!(
        files
            .stat("nested/中文.bin")
            .await
            .unwrap()
            .content_length(),
        256
    );
    let entries = files.list("nested/").await.unwrap();
    assert!(
        entries
            .iter()
            .any(|entry| entry.path() == "nested/中文.bin")
    );
    files.write("nested/中文.bin", Buffer::new()).await.unwrap();
    assert!(files.read("nested/中文.bin").await.unwrap().is_empty());
    files.delete("nested/中文.bin").await.unwrap();
    assert_eq!(
        files.read("nested/中文.bin").await.unwrap_err().kind(),
        ErrorKind::NotFound
    );
}

#[tokio::test]
async fn streaming_writer_and_range_reader_use_the_same_store() {
    let directory = tempfile::tempdir().unwrap();
    let files = filesystem(directory.path().to_str().unwrap()).unwrap();
    let mut writer = files.writer("stream.bin").await.unwrap();
    writer.write("abc").await.unwrap();
    writer.write("def").await.unwrap();
    writer.close().await.unwrap();
    assert_eq!(
        files
            .read_with("stream.bin")
            .range(1..5)
            .await
            .unwrap()
            .to_vec(),
        b"bcde"
    );
}