shipper 0.3.0-rc.1

Core library for reliable, resumable Rust workspace publishing
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

//! path_edge_case_tests for the `state::store` module.
//! Absorbed from former `shipper-store` crate.

use super::*;
use crate::types::{PackageProgress, PackageState, Registry};
use chrono::Utc;
use std::collections::BTreeMap;
use std::path::PathBuf;
use tempfile::tempdir;

fn sample_state() -> ExecutionState {
    let mut packages = BTreeMap::new();
    packages.insert(
        "demo@0.1.0".to_string(),
        PackageProgress {
            name: "demo".to_string(),
            version: "0.1.0".to_string(),
            attempts: 1,
            state: PackageState::Pending,
            last_updated_at: Utc::now(),
        },
    );
    ExecutionState {
        state_version: crate::state::execution_state::CURRENT_STATE_VERSION.to_string(),
        plan_id: "p1".to_string(),
        registry: Registry::crates_io(),
        created_at: Utc::now(),
        updated_at: Utc::now(),
        packages,
    }
}

// ── Path with spaces ────────────────────────────────────────────

#[test]
fn file_store_path_with_spaces() {
    let td = tempdir().expect("tempdir");
    let dir = td.path().join("my state dir");
    std::fs::create_dir_all(&dir).expect("mkdir");
    let store = FileStore::new(dir.clone());

    store.save_state(&sample_state()).expect("save");
    let loaded = store.load_state().expect("load");
    assert!(loaded.is_some());
    assert_eq!(loaded.unwrap().plan_id, "p1");
}

// ── Path with Unicode characters ────────────────────────────────

#[test]
fn file_store_path_with_unicode() {
    let td = tempdir().expect("tempdir");
    let dir = td.path().join("日本語パス");
    std::fs::create_dir_all(&dir).expect("mkdir");
    let store = FileStore::new(dir);

    store.save_state(&sample_state()).expect("save");
    let loaded = store.load_state().expect("load");
    assert!(loaded.is_some());
}

// ── Path with emoji ─────────────────────────────────────────────

#[test]
fn file_store_path_with_emoji() {
    let td = tempdir().expect("tempdir");
    let dir = td.path().join("📦release");
    std::fs::create_dir_all(&dir).expect("mkdir");
    let store = FileStore::new(dir);

    store.save_state(&sample_state()).expect("save");
    let loaded = store.load_state().expect("load");
    assert!(loaded.is_some());
}

// ── Deeply nested path ──────────────────────────────────────────

#[test]
fn file_store_deeply_nested_path() {
    let td = tempdir().expect("tempdir");
    let dir = td.path().join("a").join("b").join("c").join("d").join("e");
    std::fs::create_dir_all(&dir).expect("mkdir");
    let store = FileStore::new(dir);

    store.save_state(&sample_state()).expect("save");
    let loaded = store.load_state().expect("load");
    assert!(loaded.is_some());
}

// ── Load from non-existent directory returns None ────────────────

#[test]
fn file_store_load_nonexistent_dir_returns_none() {
    let td = tempdir().expect("tempdir");
    let dir = td.path().join("does_not_exist");
    let store = FileStore::new(dir);

    let loaded = store.load_state().expect("load");
    assert!(loaded.is_none());
}

// ── Clear on empty directory succeeds ────────────────────────────

#[test]
fn file_store_clear_empty_dir_succeeds() {
    let td = tempdir().expect("tempdir");
    let store = FileStore::new(td.path().to_path_buf());
    store.clear().expect("clear on empty dir should succeed");
}

// ── state_dir accessor returns correct path ─────────────────────

#[test]
fn file_store_state_dir_accessor() {
    let dir = PathBuf::from("some/path with spaces/dir");
    let store = FileStore::new(dir.clone());
    assert_eq!(store.state_dir(), &dir);
}