anzar-shared 0.9.21

Anzar is a lightweight authentication and authorization framework that runs as a separate microservice
Documentation 
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

use async_trait::async_trait;
use serde::{Serialize, de::DeserializeOwned};

use super::query::QueryBuilder;
use crate::error::CoreError;

#[async_trait]
pub trait DatabaseAdapter<T: Send + Sync + Serialize + DeserializeOwned + 'static>:
    Send + Sync
{
    // -- INSERTS
    async fn insert(&self, data: T) -> Result<String, CoreError>;
    async fn insert_many(&self, data: Vec<T>) -> Result<Vec<String>, CoreError>;
    async fn upsert(&self, data: T) -> Result<String, CoreError>;
    async fn upsert_many(&self, data: Vec<T>) -> Result<Vec<String>, CoreError>;

    // -- FINDS
    async fn find_one(&self, filter: QueryBuilder) -> Result<Option<T>, CoreError>;
    async fn find_all(&self, filter: QueryBuilder) -> Result<Vec<T>, CoreError>;

    // -- UPDATES
    async fn find_one_and_update(
        &self,
        filter: QueryBuilder,
        update: QueryBuilder,
    ) -> Result<Option<T>, CoreError>;
    async fn update_many(
        &self,
        filter: QueryBuilder,
        update: QueryBuilder,
    ) -> Result<(), CoreError>;

    // -- DELETES
    async fn delete_one(&self, filter: QueryBuilder) -> Result<(), CoreError>;
    async fn delete_many(&self, filter: QueryBuilder) -> Result<(), CoreError>;

    // transactions as a separate concern
    // async fn begin_transaction(&self) -> Result<Box<dyn Transaction>, Error>;
}

// pub trait Transaction: Send + Sync {
//     fn commit(self) -> impl std::future::Future<Output = Result<(), Error>> + Send;
//     fn rollback(self) -> impl std::future::Future<Output = Result<(), Error>> + Send;
// }

// #[async_trait]
// pub trait Transaction: Send + Sync {
//     async fn commit(self) -> Result<(), Error>;
//     async fn rollback(self) -> Result<(), Error>;
// }