rust-car 0.1.4

This crate is the ipfs car file reader writer and utils.
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

use std::collections::{VecDeque, HashMap};

use cid::Cid;
use ipld::raw::RawCodec;

use crate::{reader::CarReader, Ipld, unixfs::{UnixFs, FileType}, error::CarError};

/// walk the node and print the files in the directory.
fn walk<F>(
    vecq: &mut VecDeque<Cid>, 
    reader: &mut impl CarReader,
    list_f: &F
) -> Result<(), CarError> 
where
    F: Fn(&Cid, &str)
{
    let mut cache: HashMap<Cid, String> = HashMap::new();
    let raw_code: u64 = RawCodec.into();
    while let Some(file_cid) = vecq.pop_front() {
        let codec = file_cid.codec();
        let file_n = cache.get(&file_cid).map_or(file_cid.to_string(), |c| c.to_string());
        list_f(&file_cid, &file_n);
        // if the codec is RawCodec, the block is the file content block, 
        // it don't conatian the file info. we don't need walk continue.
        if codec == raw_code {
            continue;
        }
        let file_ipld: Ipld = reader.ipld(&file_cid)?;
        if let m @  Ipld::Map(_) = file_ipld {
            let unixfs: UnixFs = m.try_into()?;
            match unixfs.file_type() {
                FileType::Directory => {},
                _=> continue,
            }
            for n in unixfs.links().into_iter() {
                let cid = n.hash();
                cache.insert(cid, file_n.clone() + "/" + n.name_ref());
                vecq.push_back(cid);
            }
        }
    }
    Ok(())
}

/// the list file_name from car file  by reader.
pub fn list(reader: &mut impl CarReader)  -> Result<(), CarError> {
    list_call(reader, |_, file_n| println!("{file_n}"))
}

/// the list_cid file_name from car file  by reader.
pub fn list_cid(reader: &mut impl CarReader)  -> Result<(), CarError> {
    list_call(reader, |cid, _| println!("{cid}"))
}

/// the list car file  by reader.
/// `reader` is the CarReader
/// `list_f` is the list call function, first parameter is cid, the second is cid path.
pub fn list_call<F>(
    reader: &mut impl CarReader,
    list_f: F
)  -> Result<(), CarError> 
where
    F: Fn(&Cid, &str)
{
    let roots = reader.header().roots();
    let mut queue: VecDeque<Cid> = VecDeque::new();
    for r in roots.iter() {
        queue.push_front(*r);
        walk(&mut queue, reader, &list_f)?;
    }
    Ok(())
}