activityforge 0.1.0-pre-alpha.2

use activitystreams_vocabulary::Error as ActivityStreamsError;

/// Represents the error variants for the library.
#[derive(Clone, Debug, Eq, PartialEq)]
pub enum Error {
    Vocabulary(String),
    Commit(String),
    Content(String),
    Hash(String),
    Activity(String),
    Actor(String),
    Object(String),
    ActivityStreams(ActivityStreamsError),
    Sql(String),
    Io(String),
    Uuid(String),
    Crypto(String),
    Http(String),
    Db(String),
}

impl Error {
    /// Creates a new [Vocabulary](Self::Vocabulary) error.
    pub fn vocabulary<I: Into<String>>(err: I) -> Self {
        Self::Vocabulary(err.into())
    }

    /// Creates a new [Commit](Self::Commit) error.
    pub fn commit<I: Into<String>>(err: I) -> Self {
        Self::Commit(err.into())
    }

    /// Creates a new [Content](Self::Content) error.
    pub fn content<I: Into<String>>(err: I) -> Self {
        Self::Content(err.into())
    }

    /// Creates a new [Hash](Self::Hash) error.
    pub fn hash<I: Into<String>>(err: I) -> Self {
        Self::Hash(err.into())
    }

    /// Creates a new [Activity](Self::Activity) error.
    pub fn activity<I: Into<String>>(err: I) -> Self {
        Self::Activity(err.into())
    }

    /// Creates a new [Actor](Self::Actor) error.
    pub fn actor<I: Into<String>>(err: I) -> Self {
        Self::Actor(err.into())
    }

    /// Creates a new [Object](Self::Object) error.
    pub fn object<I: Into<String>>(err: I) -> Self {
        Self::Object(err.into())
    }

    /// Creates a new [ActivityStreams](Self::ActivityStreams) error.
    pub fn activity_streams<I: Into<ActivityStreamsError>>(err: I) -> Self {
        Self::ActivityStreams(err.into())
    }

    /// Creates a new I/O error.
    pub fn io<I: Into<String>>(err: I) -> Self {
        Self::Io(err.into())
    }

    /// Creates a new SQL error.
    pub fn sql<I: Into<String>>(err: I) -> Self {
        Self::Sql(err.into())
    }

    /// Creates a new UUID error.
    pub fn uuid<I: Into<String>>(err: I) -> Self {
        Self::Uuid(err.into())
    }

    /// Creates a new cryptography error.
    pub fn crypto<I: Into<String>>(err: I) -> Self {
        Self::Crypto(err.into())
    }

    /// Creates a new HTTP error.
    pub fn http<I: Into<String>>(err: I) -> Self {
        Self::Http(err.into())
    }

    /// Creates a new database error.
    pub fn db<I: Into<String>>(err: I) -> Self {
        Self::Db(err.into())
    }
}

impl From<ActivityStreamsError> for Error {
    fn from(err: ActivityStreamsError) -> Self {
        Self::ActivityStreams(err)
    }
}

impl From<std::io::Error> for Error {
    fn from(err: std::io::Error) -> Self {
        Self::Io(err.to_string())
    }
}

impl From<sqlx::Error> for Error {
    fn from(err: sqlx::Error) -> Self {
        Self::sql(err.to_string())
    }
}

impl From<sqlx::migrate::MigrateError> for Error {
    fn from(err: sqlx::migrate::MigrateError) -> Self {
        Self::sql(err.to_string())
    }
}

impl From<uuid::Error> for Error {
    fn from(err: uuid::Error) -> Self {
        Self::uuid(err.to_string())
    }
}

impl From<tokio::task::JoinError> for Error {
    fn from(err: tokio::task::JoinError) -> Self {
        Self::io(format!("async join error: {err}"))
    }
}

impl From<argon2::Error> for Error {
    fn from(err: argon2::Error) -> Self {
        Self::crypto(err.to_string())
    }
}

impl From<chacha20::Error> for Error {
    fn from(err: chacha20::Error) -> Self {
        Self::crypto(err.to_string())
    }
}

impl From<sha3::digest::InvalidLength> for Error {
    fn from(err: sha3::digest::InvalidLength) -> Self {
        Self::crypto(err.to_string())
    }
}

impl From<tokio::sync::TryLockError> for Error {
    fn from(err: tokio::sync::TryLockError) -> Self {
        Self::io(err.to_string())
    }
}

impl From<http::header::ToStrError> for Error {
    fn from(err: http::header::ToStrError) -> Self {
        Self::io(err.to_string())
    }
}

impl From<httpsig::prelude::HttpSigError> for Error {
    fn from(err: httpsig::prelude::HttpSigError) -> Self {
        Self::crypto(format!("httpsig: {err}"))
    }
}

impl From<rsa::pkcs1::Error> for Error {
    fn from(err: rsa::pkcs1::Error) -> Self {
        Self::crypto(format!("pkcs1: {err}"))
    }
}

impl From<std::string::FromUtf8Error> for Error {
    fn from(err: std::string::FromUtf8Error) -> Self {
        Self::io(err.to_string())
    }
}

impl From<std::str::Utf8Error> for Error {
    fn from(err: std::str::Utf8Error) -> Self {
        Self::io(err.to_string())
    }
}

impl From<axum::Error> for Error {
    fn from(err: axum::Error) -> Self {
        Self::http(format!("axum: {err}"))
    }
}

impl From<reqwest::Error> for Error {
    fn from(err: reqwest::Error) -> Self {
        Self::http(format!("reqwest: {err}"))
    }
}

impl From<http::Error> for Error {
    fn from(err: http::Error) -> Self {
        Self::http(format!("{err}"))
    }
}

impl From<serde_json::Error> for Error {
    fn from(err: serde_json::Error) -> Self {
        Self::http(format!("json: {err}"))
    }
}

impl From<ecdsa::Error> for Error {
    fn from(err: ecdsa::Error) -> Self {
        Self::crypto(format!("ecdsa: {err}"))
    }
}

impl core::fmt::Display for Error {
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        match self {
            Self::Vocabulary(err) => write!(f, "vocabulary: {err}"),
            Self::Commit(err) => write!(f, "commit: {err}"),
            Self::Content(err) => write!(f, "content: {err}"),
            Self::Hash(err) => write!(f, "hash: {err}"),
            Self::Activity(err) => write!(f, "activity: {err}"),
            Self::Actor(err) => write!(f, "actor: {err}"),
            Self::Object(err) => write!(f, "object: {err}"),
            Self::ActivityStreams(err) => write!(f, "activitystreams_vocabulary: {err}"),
            Self::Sql(err) => write!(f, "sql: {err}"),
            Self::Io(err) => write!(f, "io: {err}"),
            Self::Uuid(err) => write!(f, "uuid: {err}"),
            Self::Crypto(err) => write!(f, "crypto: {err}"),
            Self::Http(err) => write!(f, "http: {err}"),
            Self::Db(err) => write!(f, "db: {err}"),
        }
    }
}

impl core::error::Error for Error {}

/// Convenience alias for the crate [Result](core::result::Result) type.
pub type Result<T> = core::result::Result<T, Error>;