fedimint_client_module/

error.rs

//! Error types shared between the client and its modules.
//!
//! The client implements the traits in [`crate::module`] and [`crate`] for its
//! modules, so the failures those traits report have to be nameable from both
//! sides; they live here rather than in `fedimint-client`, which the modules do
//! not depend on.

use fedimint_core::Amount;
use fedimint_core::config::{FederationId, ModuleConfigError};
use fedimint_core::core::{ModuleInstanceId, ModuleKind, OperationId};
use fedimint_core::db::DatabaseError;
use fedimint_core::module::AmountUnit;
use thiserror::Error;

/// The primary module cannot fund a transaction: the balance it holds is
/// below what the transaction needs.
#[derive(Debug, Clone, Copy, Eq, PartialEq, Error)]
pub struct InsufficientBalanceError {
    /// The amount the transaction needed the primary module to fund.
    pub requested_amount: Amount,
    /// The total amount the primary module actually holds.
    pub total_amount: Amount,
}

impl std::fmt::Display for InsufficientBalanceError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(
            f,
            "Insufficient balance: requested {} but only {} available",
            self.requested_amount, self.total_amount
        )
    }
}

/// A failure to add state machines to the client's executor.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum AddStateMachinesError {
    /// One of the states is already in the database.
    #[error("State already exists in database")]
    StateAlreadyExists,

    /// A state belongs to a module instance the executor does not know.
    #[error("Unknown module instance {module_instance_id}")]
    UnknownModule {
        /// The instance the state claims to belong to.
        module_instance_id: ModuleInstanceId,
    },

    /// A state that can no longer transition was handed to the executor,
    /// which would never make progress on it.
    #[error("State is already terminal, adding it to the executor does not make sense")]
    StateAlreadyTerminal,

    /// The database write failed.
    #[error("Database error")]
    Database(#[from] DatabaseError),
}

/// An operation with the same id already exists in the operation log.
#[derive(Debug, Error)]
#[error("An operation with id {} already exists", .operation_id.fmt_short())]
pub struct OperationAlreadyExistsError {
    /// The id that is already taken.
    pub operation_id: OperationId,
}

/// No operation with the requested id exists in the operation log.
#[derive(Debug, Error)]
#[error("No operation with id {}", .operation_id.fmt_short())]
pub struct OperationNotFoundError {
    /// The id that was looked up.
    pub operation_id: OperationId,
}

/// A failure to look up one of a module's own operations.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum OperationLookupError {
    /// The operation log has no entry with this id.
    #[error("The operation does not exist")]
    NotFound(#[from] OperationNotFoundError),

    /// The operation exists, but was started by a different module.
    #[error(
        "Operation {} was started by module {found}, not {expected}",
        .operation_id.fmt_short()
    )]
    WrongModuleKind {
        /// The operation that was looked up.
        operation_id: OperationId,
        /// The kind of the module doing the lookup.
        expected: ModuleKind,
        /// The kind of the module that started the operation.
        found: String,
    },
}

/// A failure to build, submit or complete a client transaction.
///
/// Covers the whole path a transaction takes on the client: balancing it with
/// the primary module, recording its operation, registering its state machines,
/// and waiting for the primary module's outputs to finalize. Submission to the
/// federation itself is driven by a state machine and is not reported here.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum TransactionSubmitError {
    /// The operation the transaction would be recorded under already exists.
    #[error("The operation already exists")]
    OperationAlreadyExists(#[from] OperationAlreadyExistsError),

    /// The finalized transaction is larger than the federation accepts.
    #[error("The transaction is {size} bytes, over the limit of {max}")]
    TransactionTooLarge {
        /// The size of the encoded transaction.
        size: usize,
        /// The largest transaction the federation accepts.
        max: usize,
    },

    /// No primary module can hold funds of this unit, so the transaction
    /// cannot be balanced.
    #[error("No primary module for unit {unit}")]
    NoPrimaryModule {
        /// The unit that could not be balanced.
        unit: AmountUnit,
    },

    /// The primary module failed to balance the transaction or to complete
    /// its outputs. An insufficient balance reported while balancing the
    /// transaction is reported as [`Self::InsufficientFunds`] instead.
    #[error("The primary module failed")]
    PrimaryModule(#[source] ClientModuleError),

    /// Writing the transaction to the database failed.
    #[error("Database error")]
    Database(#[from] DatabaseError),

    /// The transaction's state machines could not be registered.
    #[error("Failed to add the transaction's state machines")]
    StateMachines(#[from] AddStateMachinesError),

    /// The primary module holds too little balance to fund the transaction.
    #[error("Insufficient funds")]
    InsufficientFunds(#[from] InsufficientBalanceError),

    /// Calculating the transaction balance or fees overflowed.
    #[error("Transaction amounts or fees overflowed")]
    AmountOverflow,
}

impl TransactionSubmitError {
    /// Whether this failure means the primary module cannot fund the
    /// transaction, as opposed to a failure of the client, the database or
    /// the federation.
    pub fn is_insufficient_funds(&self) -> bool {
        matches!(self, Self::InsufficientFunds(_))
    }
}

/// A primary module's failure to balance a transaction, as the failure of
/// that transaction: a balance too low to fund it becomes
/// [`TransactionSubmitError::InsufficientFunds`], so callers can tell it apart
/// from any other failure of the module, which becomes
/// [`TransactionSubmitError::PrimaryModule`].
impl From<ClientModuleError> for TransactionSubmitError {
    fn from(error: ClientModuleError) -> Self {
        match error {
            ClientModuleError::InsufficientBalance(error) => Self::InsufficientFunds(error),
            other => Self::PrimaryModule(other),
        }
    }
}

/// A failure a client module reports to the client.
///
/// The methods a module implements for the client in [`ClientModule`],
/// [`ClientModuleInit`] and [`RecoveryFromHistory`] report this type, and so
/// do the type-erased wrappers the client calls them through. The client wraps
/// it in the error of the operation that needed the module; the JSON command
/// handlers `handle_cli_command` and `handle_rpc` hand it to the command-line
/// or RPC caller as it is.
///
/// [`ClientModule`]: crate::module::ClientModule
/// [`ClientModuleInit`]: crate::module::init::ClientModuleInit
/// [`RecoveryFromHistory`]: crate::module::init::recovery::RecoveryFromHistory
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum ClientModuleError {
    /// The primary module's balance cannot fund the transaction it was asked
    /// to balance.
    ///
    /// A primary module reports this from `create_final_inputs_and_outputs`,
    /// and the client passes it on as
    /// [`TransactionSubmitError::InsufficientFunds`].
    #[error("The primary module's balance cannot fund the transaction")]
    InsufficientBalance(#[from] InsufficientBalanceError),

    /// The module does not implement the operation.
    ///
    /// The default bodies of `backup`, `create_final_inputs_and_outputs`,
    /// `await_primary_module_output`, `leave` and `ClientModuleInit::recover`
    /// report this. The client only asks a module for an operation the module
    /// declares support for, through `supports_backup`,
    /// `supports_being_primary` or `recovery_mode`, so the client sees this
    /// only from a module that declares support it does not implement.
    /// Calling the operation on a module directly can see it too. The default
    /// bodies of `handle_cli_command` and `handle_rpc` report it as well, to a
    /// caller that sends a command or a request to a module that has none.
    #[error("Module {kind} does not implement {operation}")]
    Unsupported {
        /// The kind of the module.
        kind: ModuleKind,
        /// The name of the trait method the module does not implement.
        operation: &'static str,
    },

    /// Any other failure, kept whole: the module's own error or the error of a
    /// library it builds on, such as a federation, database or Bitcoin
    /// backend failure. Its `Display` and `source()` are those of the error it
    /// carries.
    #[error(transparent)]
    Other(Box<dyn std::error::Error + Send + Sync>),
}

impl ClientModuleError {
    /// Wraps a failure the other variants do not describe. Accepts anything
    /// convertible into a boxed error, which includes an `anyhow::Error` and a
    /// plain message.
    ///
    /// A primary module's shortfall must be [`Self::InsufficientBalance`]
    /// instead: the client does not look inside the error this carries.
    pub fn other<E>(error: E) -> Self
    where
        E: Into<Box<dyn std::error::Error + Send + Sync>>,
    {
        Self::Other(error.into())
    }
}

/// A failure to find a module able to serve a request.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum ModuleLookupError {
    /// The client was not built with a module of this kind, or the federation
    /// does not offer one.
    #[error("No module of kind {kind} found")]
    NoModuleOfKind {
        /// The kind that was asked for.
        kind: ModuleKind,
    },

    /// The client has no module with this instance id.
    #[error("Unknown module instance {instance_id}")]
    UnknownInstance {
        /// The instance id that was asked for.
        instance_id: ModuleInstanceId,
    },

    /// The module instance exists, but is not of the requested type.
    #[error("Module instance {instance_id} is not of type {expected}")]
    WrongModuleType {
        /// The instance that was asked for.
        instance_id: ModuleInstanceId,
        /// The Rust type the caller asked the instance to be.
        expected: &'static str,
    },

    /// No primary module can hold funds of this unit.
    #[error("No primary module for unit {unit}")]
    NoPrimaryModule {
        /// The unit that has no primary module.
        unit: AmountUnit,
    },

    /// None of the primary modules for this unit is of the requested kind.
    #[error("No primary {kind} module for unit {unit}")]
    NoPrimaryModuleOfKind {
        /// The kind of module that was asked for.
        kind: ModuleKind,
        /// The unit whose primary modules were searched.
        unit: AmountUnit,
    },
}

/// The client and the federation's peers share no core API version.
///
/// Module version mismatches are not an error: a module whose versions do not
/// line up is left out of the negotiated set and stays unusable until one side
/// is upgraded.
#[derive(Debug, Error)]
#[error("Could not find a common core API version")]
pub struct ApiVersionDiscoveryError;

/// A failure to fetch the federation's meta fields.
///
/// The built-in sources produce the specific variants. A [`MetaSource`]
/// implemented elsewhere reports anything they do not describe through
/// [`Custom`].
///
/// [`MetaSource`]: crate::meta::MetaSource
/// [`Custom`]: MetaFetchError::Custom
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum MetaFetchError {
    /// The meta override URL could not be read from the client config.
    #[error("Failed to read the meta override URL from the client config")]
    Config(#[from] ModuleConfigError),

    /// The meta override source could not be reached, or its body could not
    /// be read.
    #[error("The meta override source could not be fetched")]
    Http(#[from] reqwest::Error),

    /// The meta override source answered with a non-success status.
    #[error("The meta override source answered with status {status}")]
    Status {
        /// The status the source answered with.
        status: reqwest::StatusCode,
    },

    /// The meta override source's body is not the expected JSON.
    #[error("The meta override source returned invalid JSON")]
    Json(#[from] serde_json::Error),

    /// The meta override source has no entry for this federation.
    #[error("The meta override source has no entry for federation {federation_id}")]
    NoEntry {
        /// The federation that was looked up.
        federation_id: FederationId,
    },

    /// A meta source implemented outside this crate failed in a way the other
    /// variants do not describe.
    #[error("The meta source failed")]
    Custom(#[source] Box<dyn std::error::Error + Send + Sync>),
}

#[cfg(test)]
mod tests;