hopr_db_sql/
errors.rs

1use hopr_crypto_packet::errors::TicketValidationError;
2use hopr_crypto_types::{prelude::CryptoError, types::Hash};
3use hopr_db_entity::errors::DbEntityError;
4use hopr_internal_types::errors::CoreTypesError;
5use hopr_internal_types::tickets::Ticket;
6use sea_orm::TransactionError;
7use std::sync::Arc;
8use thiserror::Error;
9
10#[derive(Debug, Error)]
11pub enum DbSqlError {
12    #[error("failed to construct the database, {0}")]
13    Construction(String),
14
15    #[error("log status not found")]
16    MissingLogStatus,
17
18    #[error("log not found")]
19    MissingLog,
20
21    #[error("list of logs is empty")]
22    EmptyLogsList,
23
24    #[error("log status could not be updated")]
25    UpdateLogStatusError,
26
27    #[error("account entry for announcement not found")]
28    MissingAccount,
29
30    #[error("channel not found: {0}")]
31    ChannelNotFound(Hash),
32
33    #[error("missing fixed entry in table {0}")]
34    MissingFixedTableEntry(String),
35
36    #[error("ticket aggregation error: {0}")]
37    TicketAggregationError(String),
38
39    #[error("ticket validation error for {}: {}", .0.0, .0.1)]
40    TicketValidationError(Box<(Ticket, String)>),
41
42    #[error("transaction error: {0}")]
43    TransactionError(Box<dyn std::error::Error + Send + Sync>),
44
45    #[error("error while decoding db entity")]
46    DecodingError,
47
48    #[error("logical error: {0}")]
49    LogicalError(String),
50
51    #[error("ack validation error: {0}")]
52    AcknowledgementValidationError(String),
53
54    #[error(transparent)]
55    BackendError(#[from] sea_orm::DbErr),
56
57    #[error(transparent)]
58    CoreTypesError(#[from] CoreTypesError),
59
60    #[error(transparent)]
61    CryptoError(#[from] CryptoError),
62
63    #[error(transparent)]
64    EntityError(#[from] DbEntityError),
65
66    #[error("error while inserting into cache: {0}")]
67    CacheError(#[from] Arc<Self>),
68
69    #[error(transparent)]
70    NonSpecificError(#[from] hopr_primitive_types::errors::GeneralError),
71
72    #[error(transparent)]
73    ApiError(#[from] hopr_db_api::errors::DbError),
74}
75
76impl From<TicketValidationError> for DbSqlError {
77    fn from(value: TicketValidationError) -> Self {
78        DbSqlError::TicketValidationError(Box::new((*value.ticket, value.reason)))
79    }
80}
81
82impl From<DbSqlError> for hopr_db_api::errors::DbError {
83    fn from(value: DbSqlError) -> Self {
84        hopr_db_api::errors::DbError::General(value.to_string())
85    }
86}
87
88impl<E: std::error::Error + Send + Sync + 'static> From<TransactionError<E>> for DbSqlError {
89    fn from(value: TransactionError<E>) -> Self {
90        match value {
91            TransactionError::Connection(e) => Self::BackendError(e),
92            TransactionError::Transaction(e) => Self::TransactionError(e.into()),
93        }
94    }
95}
96
97pub type Result<T> = std::result::Result<T, DbSqlError>;
hopr_db_sql/errors.rs

hopr_db_sql/
errors.rs
