liboxen 0.46.7

Oxen is a fast, unstructured data version control, to help version large machine learning datasets written in Rust.
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

//! Helper functions to get metadata from the local filesystem.
//!

use crate::error::OxenError;
use crate::model::entry::metadata_entry::CLIMetadataEntry;
use crate::model::merkle_tree::node::EMerkleTreeNode;
use crate::model::{Commit, LocalRepository};
use crate::repositories;
use crate::util;

use std::path::Path;

use super::index::CommitMerkleTree;

/// Returns metadata with latest commit information. Less efficient than get().
pub fn get_cli(
    repo: &LocalRepository,
    entry_path: impl AsRef<Path>,
    data_path: impl AsRef<Path>,
) -> Result<CLIMetadataEntry, OxenError> {
    let path = data_path.as_ref();
    let entry_path = entry_path.as_ref();
    let base_name = entry_path
        .file_name()
        .ok_or(OxenError::file_has_no_name(path))?;
    let size = repositories::metadata::get_file_size(path)?;
    let hash = util::hasher::hash_file_contents(path)?;
    let mime_type = util::fs::file_mime_type(path);
    let data_type = util::fs::datatype_from_mimetype(path, mime_type.as_str());
    let extension = util::fs::file_extension(path);

    let mut last_updated: Option<Commit> = None;
    if let Ok(head_commit) = repositories::commits::head_commit(repo) {
        let tree = CommitMerkleTree::from_commit(repo, &head_commit)?;
        if let Some(node) = tree.get_by_path(entry_path)? {
            if let EMerkleTreeNode::File(file_node) = &node.node {
                let last_commit_id = file_node.last_commit_id().to_string();
                // this commit is guaranteed to exist because we are iterating through the tree
                let commit = repositories::commits::get_by_id(repo, &last_commit_id)?.unwrap();
                last_updated = Some(commit);
            }
            if let EMerkleTreeNode::Directory(dir_node) = &node.node {
                let last_commit_id = dir_node.last_commit_id().to_string();
                let commit = repositories::commits::get_by_id(repo, &last_commit_id)?.unwrap();
                last_updated = Some(commit);
            }
        }
    }

    Ok(CLIMetadataEntry {
        filename: base_name.to_string_lossy().to_string(),
        last_updated,
        hash,
        size,
        data_type,
        mime_type,
        extension,
    })
}