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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139

use std::fmt::Debug;
use std::marker::PhantomData;

use async_trait::async_trait;
use bonsaidb_core::api::{self, Api, ApiError, Infallible};
use bonsaidb_core::arc_bytes::serde::Bytes;
use bonsaidb_core::permissions::PermissionDenied;
use bonsaidb_core::schema::{InsertError, InvalidNameError};

use crate::{Backend, ConnectedClient, CustomServer, Error, NoBackend};

/// A trait that can dispatch requests for a [`Api`].
#[async_trait]
pub trait Handler<Api: api::Api, B: Backend = NoBackend>: Send + Sync {
    /// Returns a dispatcher to handle custom api requests. The parameters are
    /// provided so that they can be cloned if needed during the processing of
    /// requests.
    async fn handle(session: HandlerSession<'_, B>, request: Api) -> HandlerResult<Api>;
}

/// A session for a [`Handler`], providing ways to access the server and
/// connected client.
pub struct HandlerSession<'a, B: Backend = NoBackend> {
    /// The [`Handler`]'s server reference. This server instance is not limited
    /// to the permissions of the connected user.
    pub server: &'a CustomServer<B>,
    /// The connected client's server reference. This server instance will
    /// reject any database operations that the connected client is not
    /// explicitly authorized to perform based on its authentication state.
    pub as_client: CustomServer<B>,
    /// The connected client making the API request.
    pub client: &'a ConnectedClient<B>,
}

#[async_trait]
pub(crate) trait AnyHandler<B: Backend>: Send + Sync + Debug {
    async fn handle(&self, session: HandlerSession<'_, B>, request: &[u8]) -> Result<Bytes, Error>;
}

pub(crate) struct AnyWrapper<D: Handler<A, B>, B: Backend, A: Api>(
    pub(crate) PhantomData<(D, B, A)>,
);

impl<D, B, A> Debug for AnyWrapper<D, B, A>
where
    D: Handler<A, B>,
    B: Backend,
    A: Api,
{
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_tuple("AnyWrapper").finish()
    }
}

#[async_trait]
impl<T, B, A> AnyHandler<B> for AnyWrapper<T, B, A>
where
    B: Backend,
    T: Handler<A, B>,
    A: Api,
{
    async fn handle(&self, client: HandlerSession<'_, B>, request: &[u8]) -> Result<Bytes, Error> {
        let request = pot::from_slice(request)?;
        let response = match T::handle(client, request).await {
            Ok(response) => Ok(response),
            Err(HandlerError::Api(err)) => Err(err),
            Err(HandlerError::Server(err)) => return Err(err),
        };
        Ok(Bytes::from(pot::to_vec(&response)?))
    }
}

/// An error that can occur inside of a [`Backend`] function.
#[derive(thiserror::Error, Debug)]
pub enum HandlerError<E: ApiError = Infallible> {
    /// An api-related error.
    #[error("api error: {0}")]
    Api(E),
    /// A server-related error.
    #[error("server error: {0}")]
    Server(#[from] Error),
}

impl<E: ApiError> From<PermissionDenied> for HandlerError<E> {
    fn from(permission_denied: PermissionDenied) -> Self {
        Self::Server(Error::from(permission_denied))
    }
}

impl<E: ApiError> From<bonsaidb_core::Error> for HandlerError<E> {
    fn from(err: bonsaidb_core::Error) -> Self {
        Self::Server(Error::from(err))
    }
}

impl<E: ApiError> From<bonsaidb_local::Error> for HandlerError<E> {
    fn from(err: bonsaidb_local::Error) -> Self {
        Self::Server(Error::from(err))
    }
}

impl<E: ApiError> From<InvalidNameError> for HandlerError<E> {
    fn from(err: InvalidNameError) -> Self {
        Self::Server(Error::from(err))
    }
}

#[cfg(feature = "websockets")]
impl<E: ApiError> From<bincode::Error> for HandlerError<E> {
    fn from(other: bincode::Error) -> Self {
        Self::Server(Error::from(bonsaidb_local::Error::from(other)))
    }
}

impl<E: ApiError> From<pot::Error> for HandlerError<E> {
    fn from(other: pot::Error) -> Self {
        Self::Server(Error::from(other))
    }
}

impl<E: ApiError> From<std::io::Error> for HandlerError<E> {
    fn from(err: std::io::Error) -> Self {
        Self::Server(Error::from(err))
    }
}

impl<T, E> From<InsertError<T>> for HandlerError<E>
where
    E: ApiError,
{
    fn from(error: InsertError<T>) -> Self {
        Self::Server(Error::from(error.error))
    }
}

/// The return type from a [`Handler`]'s [`handle()`](Handler::handle)
/// function.
pub type HandlerResult<Api> =
    Result<<Api as api::Api>::Response, HandlerError<<Api as api::Api>::Error>>;