lightspeed_auth 0.66.0

LightSpeed
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

use crate::repository::AuthRepositoryManager;
use c3p0::{
    SqliteC3p0Pool,
    sqlx::{migrate::Migrator, *},
};
use lightspeed_core::error::LsError;
use sqlite_auth_account::SqliteAuthAccountRepository;
use sqlite_token::SqliteTokenRepository;

pub mod sqlite_auth_account;
pub mod sqlite_token;

static MIGRATOR: Migrator = ::sqlx::migrate!("src_resources/db/sqlite/migrations");

#[derive(Clone)]
pub struct SqliteAuthRepositoryManager {
    c3p0: SqliteC3p0Pool,
}

impl SqliteAuthRepositoryManager {
    pub fn new(c3p0: SqliteC3p0Pool) -> SqliteAuthRepositoryManager {
        SqliteAuthRepositoryManager { c3p0 }
    }
}

impl AuthRepositoryManager for SqliteAuthRepositoryManager {
    type DB = Sqlite;
    type C3P0 = SqliteC3p0Pool;
    type AuthAccountRepo = SqliteAuthAccountRepository;
    type TokenRepo = SqliteTokenRepository;

    fn c3p0(&self) -> &Self::C3P0 {
        &self.c3p0
    }

    async fn start(&self) -> Result<(), LsError> {
        MIGRATOR.run(self.c3p0.pool()).await.map_err(|err| LsError::ModuleStartError {
            message: format!("SqliteAuthRepositoryManager - db migration failed: {err:?}"),
        })
    }

    fn auth_account_repo(&self) -> Self::AuthAccountRepo {
        SqliteAuthAccountRepository::new()
    }

    fn token_repo(&self) -> Self::TokenRepo {
        SqliteTokenRepository::new()
    }
}