summaryrefslogtreecommitdiff
path: root/src/login/repo.rs
blob: d1a02c465353d06a7bc25af165c6fc99779b9492 (plain)
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 sqlx::{sqlite::Sqlite, SqliteConnection, Transaction};

use crate::login::{password::StoredHash, Id, Login};

pub trait Provider {
    fn logins(&mut self) -> Logins;
}

impl<'c> Provider for Transaction<'c, Sqlite> {
    fn logins(&mut self) -> Logins {
        Logins(self)
    }
}

pub struct Logins<'t>(&'t mut SqliteConnection);

impl<'c> Logins<'c> {
    pub async fn create(
        &mut self,
        name: &str,
        password_hash: &StoredHash,
    ) -> Result<Login, sqlx::Error> {
        let id = Id::generate();

        let login = sqlx::query_as!(
            Login,
            r#"
                insert or fail
                into login (id, name, password_hash)
                values ($1, $2, $3)
                returning
                    id as "id: Id",
                    name
            "#,
            id,
            name,
            password_hash,
        )
        .fetch_one(&mut *self.0)
        .await?;

        Ok(login)
    }
}

impl<'t> From<&'t mut SqliteConnection> for Logins<'t> {
    fn from(tx: &'t mut SqliteConnection) -> Self {
        Self(tx)
    }
}