kaspa-consensus 0.0.2

Kaspa consensus library
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

mod extensions;
pub mod inquirer;
pub mod interval;
mod reindex;
pub mod tests;
mod tree;

use kaspa_database::prelude::StoreError;
use thiserror::Error;

#[derive(Error, Debug)]
pub enum ReachabilityError {
    #[error("data store error")]
    StoreError(#[from] StoreError),

    #[error("data overflow error")]
    DataOverflow(String),

    #[error("data inconsistency error")]
    DataInconsistency,

    #[error("query is inconsistent")]
    BadQuery,
}

impl ReachabilityError {
    pub fn is_key_not_found(&self) -> bool {
        matches!(self, ReachabilityError::StoreError(e) if matches!(e, StoreError::KeyNotFound(_)))
    }
}

pub type Result<T> = std::result::Result<T, ReachabilityError>;

pub trait ReachabilityResultExtensions<T> {
    /// Unwraps the error into `None` if the internal error is `StoreError::KeyNotFound` or panics otherwise
    fn unwrap_option(self) -> Option<T>;
}

impl<T> ReachabilityResultExtensions<T> for Result<T> {
    fn unwrap_option(self) -> Option<T> {
        match self {
            Ok(value) => Some(value),
            Err(err) if err.is_key_not_found() => None,
            Err(err) => panic!("Unexpected reachability error: {err:?}"),
        }
    }
}