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

use crate::repository::AuthRepositoryManager;
use c3p0::sqlx::{migrate::Migrator, *};
use c3p0::*;
use lightspeed_core::error::LsError;
use mysql_auth_account::MySqlAuthAccountRepository;
use mysql_token::MySqlTokenRepository;

pub mod mysql_auth_account;
pub mod mysql_token;

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

#[derive(Clone)]
pub struct MySqlAuthRepositoryManager {
    c3p0: MySqlC3p0Pool,
}

impl MySqlAuthRepositoryManager {
    pub fn new(c3p0: MySqlC3p0Pool) -> MySqlAuthRepositoryManager {
        MySqlAuthRepositoryManager { c3p0 }
    }
}

impl AuthRepositoryManager for MySqlAuthRepositoryManager {
    type DB = MySql;
    type C3P0 = MySqlC3p0Pool;
    type AuthAccountRepo = MySqlAuthAccountRepository;
    type TokenRepo = MySqlTokenRepository;

    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!("MySqlAuthRepositoryManager - db migration failed: {err:?}"),
        })
    }

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

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