oxideav-source 0.1.1

Generic source registry: opens URIs (file://, future http://) into Read+Seek; prefetch buffer wrapper
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

//! File-driver round-trip tests.

use std::io::{Read, Seek, SeekFrom};

use oxideav_source::SourceRegistry;

#[test]
fn open_bare_path_reads_first_bytes() {
    let reg = oxideav_source::with_defaults();
    let mut f = reg.open("Cargo.toml").expect("open");
    let mut head = [0u8; 4];
    f.read_exact(&mut head).expect("read");
    assert_eq!(&head, b"[pac"); // start of a Cargo.toml: "[package]"
}

#[test]
fn open_file_url_reads_first_bytes() {
    let reg = oxideav_source::with_defaults();
    let cwd = std::env::current_dir().unwrap();
    let url = format!("file://{}/Cargo.toml", cwd.display());
    let mut f = reg.open(&url).expect("open");
    let mut head = [0u8; 4];
    f.read_exact(&mut head).expect("read");
    assert_eq!(&head, b"[pac");
}

#[test]
fn open_supports_seek() {
    let reg = oxideav_source::with_defaults();
    let mut f = reg.open("Cargo.toml").unwrap();
    let end = f.seek(SeekFrom::End(0)).unwrap();
    assert!(end > 0);
    f.seek(SeekFrom::Start(0)).unwrap();
    let pos = f.stream_position().unwrap();
    assert_eq!(pos, 0);
}

#[test]
fn unknown_scheme_with_no_driver_errors() {
    let mut reg = SourceRegistry::new();
    reg.register("file", oxideav_source::open_file);
    let r = reg.open("https://example.com/x");
    // No https driver registered — falls through to file driver, which
    // will then fail to open a file with that path.
    assert!(r.is_err());
}