lfspull 0.4.2

A simple git lfs file pulling implementation in pure rust. Can only pull files / folders and only support token-auth for now.
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use cucumber::{given, then, when, World};
use lfspull::prelude::*;
use std::env::temp_dir;
use std::fs;
use std::path::PathBuf;
use uuid::Uuid;

#[derive(Debug, World, Default)]
pub struct LFSWorld {
    current_fake_repo: Option<PathBuf>,
    pull_result: Option<FilePullMode>,
}

const TEST_GIT_CONFIG: &str = r#"[core]
        repositoryformatversion = 0
        filemode = true
        bare = false
        logallrefupdates = true
[remote "origin"]
        url = https://dev.azure.com/buildvgmpsmi/buildvg/_git/git-lfs-test
        fetch = +refs/heads/*:refs/remotes/origin/*
[branch "main"]
        remote = origin
        merge = refs/heads/main
[lfs]
        repositoryformatversion = 0
"#;

const TEST_LFS_FILE: &str = r#"version https://git-lfs.github.com/spec/v1
oid sha256:0fae26606afd128d4d2f730462c8451b90931d25813e06e55239a2ca00e74c74
size 226848
"#;

const TEST_LFS_FILE_NAME: &str = "beer_tornado.mp4";

#[given(expr = "the test-repository is correctly setup")]
fn setup_fake_git_repo(world: &mut LFSWorld) {
    let temp_folder = temp_dir().join(Uuid::new_v4().to_string());
    world.current_fake_repo = Some(temp_folder);
    let repo_base = world.current_fake_repo.as_ref().unwrap();
    fs::create_dir_all(repo_base).expect("could not create temp-dir");
    fs::write(repo_base.join(TEST_LFS_FILE_NAME), TEST_LFS_FILE).expect("Unable to write file");
    fs::create_dir_all(repo_base.join(".git")).expect("could not create .git inside temp folder");
    fs::write(repo_base.join(".git").join("config"), TEST_GIT_CONFIG)
        .expect("Unable to write file");
}

#[given(expr = "the file was pulled already")]
#[when(expr = "pulling the file")]
async fn pull_file_step(world: &mut LFSWorld) {
    let file_path = world
        .current_fake_repo
        .as_ref()
        .unwrap()
        .clone()
        .join(TEST_LFS_FILE_NAME);
    world.pull_result = Some(
        lfspull::pull_file(file_path, None, 3, Some(5), Some(0))
            .await
            .expect("Could not pull file"),
    );
}

#[when(expr = "pulling the complete directory")]
async fn pull_directory(world: &mut LFSWorld) {
    let fake_repo = world.current_fake_repo.as_ref().unwrap().to_string_lossy();
    let pattern = format!("{}/**/*", fake_repo);
    let recurse_pull = lfspull::glob_recurse_pull_directory(&pattern, None, 3, Some(5), Some(0))
        .await
        .expect("Could not pull directory")
        .into_iter()
        .find(|(i, _)| i.contains(TEST_LFS_FILE_NAME))
        .expect("did not pull desired file");
    world.pull_result = Some(recurse_pull.1);
}

#[when(expr = "resetting the file")]
fn resetting_the_file(world: &mut LFSWorld) {
    let file_path = world
        .current_fake_repo
        .as_ref()
        .unwrap()
        .join(TEST_LFS_FILE_NAME);
    fs::remove_file(&file_path).ok();
    fs::write(file_path, TEST_LFS_FILE).expect("Unable to write file");
}

#[then(expr = "the file was pulled from origin")]
fn assert_origin_pull(world: &mut LFSWorld) {
    let last_result = world.pull_result.as_ref().expect("not pulled anything yet");
    assert_eq!(last_result, &FilePullMode::DownloadedFromRemote);
}

#[then(expr = "the file was pulled from local cache")]
fn assert_cached_pull(world: &mut LFSWorld) {
    let last_result = world.pull_result.as_ref().expect("not pulled anything yet");
    assert_eq!(last_result, &FilePullMode::UsedLocalCache);
}

#[then(expr = "the file was already there")]
fn assert_already_pulled(world: &mut LFSWorld) {
    let last_result = world.pull_result.as_ref().expect("not pulled anything yet");
    assert_eq!(last_result, &FilePullMode::WasAlreadyPresent);
}

#[then(expr = "the file size is {int}")]
fn check_file_size(world: &mut LFSWorld, size: u64) {
    let metadata = std::fs::metadata(
        world
            .current_fake_repo
            .as_ref()
            .unwrap()
            .join(TEST_LFS_FILE_NAME),
    )
    .expect("Could not get target file metadata");
    assert_eq!(metadata.len(), size);
}

#[tokio::main]
async fn main() {
    LFSWorld::run("tests/features").await;
}