urma-runtime 0.3.0

URMA publication planning, network transports and recovery
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

use crate::error::{Error, ensure};
use bitcoin::Txid;
use urma_core::{format::RecordKind, multipart::MultipartConsistency};

pub(crate) struct Order {
    consistency: MultipartConsistency,
    leaves: bool,
    root: bool,
}

impl Order {
    pub(crate) fn new() -> Self {
        Self {
            consistency: MultipartConsistency::new(),
            leaves: false,
            root: false,
        }
    }

    pub(crate) fn append(&mut self, bytes: &[u8], txid: Txid) -> Result<(), Error> {
        ensure!(!self.root, "record follows publication root");
        let kind = RecordKind::parse(bytes)?;
        if kind == RecordKind::DataPart {
            ensure!(!self.leaves, "noncanonical data publication order");
        }
        self.consistency.accept(bytes, txid)?;
        self.leaves |= kind == RecordKind::LeafManifest;
        self.root = kind == RecordKind::RootManifest;
        Ok(())
    }

    pub(crate) fn finish(&self, count: u32) -> Result<(), Error> {
        ensure!(self.root, "publication root or geometry missing");
        Ok(self.consistency.validate_count(count)?)
    }
}