snops-common 0.1.0

Common types and utilities for snops
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

use std::sync::Arc;

use chrono::Utc;
use serde::{Deserialize, Serialize};

use super::LatestBlockInfo;

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum SnarkOSStatus {
    /// Initial node status
    Starting,
    /// Node is loading the ledger
    LedgerLoading,
    /// Failure to load the ledger
    LedgerFailure(String),
    /// Node is running
    Started,
    /// Node crashed
    Halted(Option<String>),
}

/// Messages from snarkos to the agent, containing information about the status
/// of the node
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub struct SnarkOSBlockInfo {
    pub height: u32,
    pub state_root: String,
    pub block_hash: String,
    pub previous_hash: String,
    pub block_timestamp: i64,
}

/// Messages from snarkos to the agent, containing information about the status
/// of the node
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub struct SnarkOSLiteBlock {
    pub info: SnarkOSBlockInfo,
    pub transactions: Vec<String>,
}

impl SnarkOSLiteBlock {
    pub fn split(self) -> (LatestBlockInfo, Vec<Arc<str>>) {
        (
            LatestBlockInfo {
                height: self.info.height,
                state_root: self.info.state_root,
                block_hash: self.info.block_hash,
                previous_hash: self.info.previous_hash,
                block_timestamp: self.info.block_timestamp,
                update_time: Utc::now(),
            },
            self.transactions.into_iter().map(Arc::from).collect(),
        )
    }
}