prikk-store 0.24.0

Prikk storage crate scaffold.
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

//! DC-36 publication refusal when immutable object bytes disagree.

use crate::test_support::{
    signed_empty_block_envelope, signed_ref_state_envelope, signed_ref_update_envelope,
    unique_temp_dir,
};
use crate::{
    FileObjectStore, ObjectReader, ObjectWriter, RefPublication, RefStore, RepositoryLayout,
};

#[test]
fn ref_publication_does_not_advance_after_existing_object_mismatch() -> prikk_error::Result<()> {
    let root = unique_temp_dir("ref-object-mismatch");
    let layout = RepositoryLayout::init(root.clone())?;
    let mut objects = FileObjectStore::new(layout.clone());
    let target = objects.write_object(&signed_empty_block_envelope())?;
    let ref_state = signed_ref_state_envelope("heads/main", None, target, 1);
    let ref_state_id = ref_state.object_id();
    let mut different_transport = ref_state.clone();
    let signature_byte = different_transport
        .signatures
        .first_mut()
        .and_then(|signature| signature.signature_bytes.first_mut())
        .ok_or_else(|| {
            prikk_error::PrikkError::Integrity("missing test signature byte".to_string())
        })?;
    *signature_byte ^= 0xff;
    assert_eq!(different_transport.object_id(), ref_state_id);
    // Plant the conflicting transport through the real write path (a container-based equivalent of
    // the pre-Stage-3 raw `std::fs::write` at the RefState's own loose canonical path) -- proves the
    // same-id-different-bytes conflict `index.rs::write_object_to_container` detects.
    objects.write_object(&different_transport)?;

    let publication = RefPublication {
        ref_name: "heads/main".to_string(),
        expected_previous_ref_state_id: None,
        ref_update: signed_ref_update_envelope("heads/main", None, ref_state_id, target, 1),
        ref_state,
    };
    let refs = RefStore::new(layout.clone());
    assert!(refs.publish(&publication).is_err());
    assert_eq!(refs.read_current_ref_state_id("heads/main")?, None);
    assert!(refs.replay_log("heads/main")?.records.is_empty());
    // The already-stored conflicting transport is unchanged by the failed publish attempt.
    assert_eq!(
        objects.read_object(ref_state_id)?,
        Some(different_transport)
    );

    let _ = std::fs::remove_dir_all(root);
    Ok(())
}