Lines
6 %
Functions
3.88 %
Branches
100 %
use std::fmt::Display;
use std::sync::Arc;
use bonsaidb_core::permissions::PermissionDenied;
use bonsaidb_core::schema::InsertError;
use bonsaidb_core::{schema, AnyError};
use schema::InvalidNameError;
/// An error occurred while interacting with a [`Server`](crate::Server).
#[derive(Debug, thiserror::Error)]
pub enum Error {
#[cfg(feature = "websockets")]
/// An error occurred from the Websocket transport layer.
#[error("a websocket error occurred: '{0}'")]
WebSocket(#[from] tokio_tungstenite::tungstenite::Error),
/// An error occurred from IO
#[error("a networking error occurred: '{0}'")]
Io(#[from] tokio::io::Error),
/// An error occurred while processing a request
#[error("an error occurred processing a request: '{0}'")]
Request(Arc<dyn AnyError>),
/// An error occurred from within the schema.
#[error("error from core {0}")]
Core(#[from] bonsaidb_core::Error),
/// An internal error occurred while waiting for a message.
#[error("error while waiting for a message")]
InternalCommunication,
/// An error occurred while interacting with a local database.
#[error("an error occurred interacting with a database: {0}")]
Database(#[from] bonsaidb_local::Error),
/// An error occurred with a certificate.
#[error("a certificate error: {0}")]
Certificate(#[from] fabruic::error::Certificate),
/// An error occurred parsing a PEM file.
#[error("an invalid PEM file: {0}")]
#[cfg(feature = "pem")]
Pem(#[from] pem::PemError),
/// An error occurred requesting an ACME certificate.
#[error("an error requesting an ACME certificate: {0}")]
#[cfg(feature = "acme")]
Acme(#[from] async_acme::acme::AcmeError),
/// An error occurred while processing an ACME order.
#[error("an error occurred while processing an ACME order: {0}")]
AcmeOrder(#[from] async_acme::rustls_helper::OrderError),
/// An error occurred during tls signing.
#[error("an error occurred during tls signing")]
TlsSigningError,
}
impl Error {
pub(crate) fn other(origin: impl Display, error: impl Display) -> Self {
Self::Core(bonsaidb_core::Error::other(origin, error))
impl From<Error> for bonsaidb_core::Error {
fn from(other: Error) -> Self {
// without it, there's no way to get this to_string() easily.
match other {
Error::Core(core) | Error::Database(bonsaidb_local::Error::Core(core)) => core,
Error::Database(storage) => Self::from(storage),
Error::Io(io) => Self::other("io", io),
Error::WebSocket(err) => Self::other("bonsaidb-server websockets", err),
err => Self::other("bonsaidb-server", err),
impl From<flume::RecvError> for Error {
fn from(_: flume::RecvError) -> Self {
Self::InternalCommunication
impl<T> From<flume::SendError<T>> for Error {
fn from(_: flume::SendError<T>) -> Self {
impl From<tokio::sync::oneshot::error::RecvError> for Error {
fn from(_: tokio::sync::oneshot::error::RecvError) -> Self {
impl From<tokio::sync::oneshot::error::TryRecvError> for Error {
fn from(_: tokio::sync::oneshot::error::TryRecvError) -> Self {
impl From<PermissionDenied> for Error {
fn from(err: PermissionDenied) -> Self {
Self::Core(bonsaidb_core::Error::PermissionDenied(err))
impl From<InvalidNameError> for Error {
fn from(err: InvalidNameError) -> Self {
Self::Core(bonsaidb_core::Error::InvalidName(err))
impl From<rustls::sign::SignError> for Error {
fn from(_: rustls::sign::SignError) -> Self {
Self::TlsSigningError
impl<T> From<InsertError<T>> for Error {
fn from(error: InsertError<T>) -> Self {
Self::from(error.error)
pub trait ResultExt<R> {
fn map_err_to_core(self) -> Result<R, bonsaidb_core::Error>
where
Self: Sized;
impl<R> ResultExt<R> for Result<R, Error> {
Self: Sized,
{
self.map_err(bonsaidb_core::Error::from)
impl From<pot::Error> for Error {
fn from(other: pot::Error) -> Self {
Self::Core(bonsaidb_core::Error::from(other))
impl From<bincode::Error> for Error {
fn from(other: bincode::Error) -> Self {
Self::Core(bonsaidb_core::Error::other("bincode", other))
macro_rules! impl_from_fabruic {
($error:ty) => {
impl From<$error> for Error {
fn from(other: $error) -> Self {
Self::Core(bonsaidb_core::Error::other("bonsaidb-server quic", other))
};
impl_from_fabruic!(fabruic::error::CertificateChain);
impl_from_fabruic!(fabruic::error::Receiver);
impl_from_fabruic!(fabruic::error::Connecting);
impl_from_fabruic!(fabruic::error::PrivateKey);
impl_from_fabruic!(fabruic::error::KeyPair);
impl_from_fabruic!(fabruic::error::Connection);
impl_from_fabruic!(fabruic::error::Incoming);
impl_from_fabruic!(fabruic::error::AlreadyClosed);
impl_from_fabruic!(fabruic::error::Config);
impl_from_fabruic!(fabruic::error::Builder);