shipper 0.3.0-rc.2

Reliable, resumable `cargo publish` for Rust workspaces. Install with `cargo install shipper --locked`.
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

//! BDD tests for `shipper_core::runtime::execution` (absorbed from the former
//! `shipper-execution-core` crate's `tests/execution_core_bdd.rs`).

use chrono::Utc;
use std::collections::BTreeMap;

use shipper_core::runtime::execution;
use shipper_types::{ExecutionState, PackageProgress, PackageState, Registry};

#[test]
fn bdd_given_existing_pending_package_when_state_is_updated_and_persisted_then_state_is_written() {
    let key = execution::pkg_key("demo", "0.1.0");
    let mut st = ExecutionState {
        state_version: shipper::state::execution_state::CURRENT_STATE_VERSION.to_string(),
        plan_id: "plan-bdd".to_string(),
        registry: Registry::crates_io(),
        created_at: Utc::now(),
        updated_at: Utc::now(),
        packages: BTreeMap::from([(
            key.clone(),
            PackageProgress {
                name: "demo".to_string(),
                version: "0.1.0".to_string(),
                attempts: 0,
                state: PackageState::Pending,
                last_updated_at: Utc::now(),
            },
        )]),
    };

    let temp_dir = tempfile::tempdir().expect("tempdir");

    execution::update_state(&mut st, temp_dir.path(), &key, PackageState::Uploaded)
        .expect("persist state");

    let loaded = shipper::state::execution_state::load_state(temp_dir.path())
        .expect("load state")
        .expect("state exists");
    assert!(matches!(
        loaded.packages.get(&key).expect("pkg").state,
        PackageState::Uploaded
    ));
}

#[test]
fn bdd_given_in_memory_update_then_state_uses_key_lookup_contract() {
    let key = execution::pkg_key("demo", "0.1.0");
    let mut st = ExecutionState {
        state_version: shipper::state::execution_state::CURRENT_STATE_VERSION.to_string(),
        plan_id: "plan-bdd".to_string(),
        registry: Registry::crates_io(),
        created_at: Utc::now(),
        updated_at: Utc::now(),
        packages: BTreeMap::from([(
            key.clone(),
            PackageProgress {
                name: "demo".to_string(),
                version: "0.1.0".to_string(),
                attempts: 0,
                state: PackageState::Pending,
                last_updated_at: Utc::now(),
            },
        )]),
    };

    execution::update_state_locked(
        &mut st,
        &key,
        PackageState::Failed {
            class: shipper_types::ErrorClass::Ambiguous,
            message: "registry check ambiguous".to_string(),
        },
    );

    assert!(matches!(
        st.packages.get(&key).expect("pkg").state,
        PackageState::Failed { .. }
    ));
}