txline 0.3.3

Devnet-only Rust SDK for TxLINE.
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

//! Legacy `/api/scores/stat-validation` response types.

use serde::{Deserialize, Serialize};

use super::proof::{Hash32, ProofNode};
use crate::http::models::UpdateStats;
use crate::{Result, TxlineError};

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct ScoreStat {
    pub key: u32,
    pub value: i32,
    pub period: i32,
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ScoresBatchSummary {
    pub fixture_id: i64,
    pub update_stats: UpdateStats,
    pub event_stats_sub_tree_root: Hash32,
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ScoresStatValidation {
    pub ts: i64,
    pub stat_to_prove: ScoreStat,
    pub event_stat_root: Hash32,
    pub summary: ScoresBatchSummary,
    #[serde(default)]
    pub stat_proof: Vec<ProofNode>,
    #[serde(default)]
    pub sub_tree_proof: Vec<ProofNode>,
    #[serde(default)]
    pub main_tree_proof: Vec<ProofNode>,
    #[serde(default)]
    pub stat_to_prove2: Option<ScoreStat>,
    #[serde(default)]
    pub stat_proof2: Option<Vec<ProofNode>>,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct FixtureSummaryInput {
    pub fixture_id: i64,
    pub update_count: i32,
    pub min_timestamp: i64,
    pub max_timestamp: i64,
    pub events_sub_tree_root: [u8; 32],
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct StatTermInput {
    pub stat_to_prove: ScoreStat,
    pub event_stat_root: [u8; 32],
    pub stat_proof: Vec<ProofNode>,
}

impl ScoresStatValidation {
    pub fn fixture_summary_input(&self) -> FixtureSummaryInput {
        FixtureSummaryInput {
            fixture_id: self.summary.fixture_id,
            update_count: self.summary.update_stats.update_count,
            min_timestamp: self.summary.update_stats.min_timestamp,
            max_timestamp: self.summary.update_stats.max_timestamp,
            events_sub_tree_root: self.summary.event_stats_sub_tree_root.to_bytes(),
        }
    }

    pub fn primary_stat_term(&self) -> StatTermInput {
        StatTermInput {
            stat_to_prove: self.stat_to_prove.clone(),
            event_stat_root: self.event_stat_root.to_bytes(),
            stat_proof: self.stat_proof.clone(),
        }
    }

    pub fn secondary_stat_term(&self) -> Result<Option<StatTermInput>> {
        match (&self.stat_to_prove2, &self.stat_proof2) {
            (Some(stat_to_prove), Some(stat_proof)) => Ok(Some(StatTermInput {
                stat_to_prove: stat_to_prove.clone(),
                event_stat_root: self.event_stat_root.to_bytes(),
                stat_proof: stat_proof.clone(),
            })),
            (None, None) => Ok(None),
            _ => Err(TxlineError::validation(
                "legacy response contains only one of statToProve2/statProof2",
            )),
        }
    }

    pub fn epoch_day(&self) -> Result<u16> {
        timestamp_ms_to_epoch_day(self.summary.update_stats.min_timestamp)
    }
}

pub(crate) fn ensure_positive_seq(seq: i32) -> Result<()> {
    if seq <= 0 {
        return Err(TxlineError::invalid_input(
            "score stat validation seq must be greater than zero and must come from a real score record",
        ));
    }
    Ok(())
}

pub fn timestamp_ms_to_epoch_day(timestamp_ms: i64) -> Result<u16> {
    if timestamp_ms < 0 {
        return Err(TxlineError::validation(
            "validation timestamp must not be negative",
        ));
    }
    let epoch_day = timestamp_ms / 86_400_000;
    u16::try_from(epoch_day)
        .map_err(|_| TxlineError::validation("epoch day does not fit into u16 PDA seed"))
}