obscura-server 0.3.12

A server for relaying secure messages using the Signal Protocol
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

use crate::domain::user::User;
use crate::error::{AppError, Result};
use sqlx::{Executor, Postgres};

#[derive(Clone)]
pub struct IdentityService {
    repo: crate::storage::user_repo::UserRepository,
}

impl IdentityService {
    pub fn new(repo: crate::storage::user_repo::UserRepository) -> Self {
        Self { repo }
    }

    #[tracing::instrument(err, skip(self, executor, password_hash))]
    pub async fn create_user<'e, E>(&self, executor: E, username: &str, password_hash: &str) -> Result<User>
    where
        E: Executor<'e, Database = Postgres>,
    {
        self.repo.create(executor, username, password_hash).await.map_err(|e| {
            if let AppError::Database(sqlx::Error::Database(db_err)) = &e
                && db_err.code().as_deref() == Some("23505")
            {
                return AppError::Conflict("Username already exists".into());
            }
            e
        })
    }

    #[tracing::instrument(err, skip(self, executor))]
    pub async fn find_by_username<'e, E>(&self, executor: E, username: &str) -> Result<Option<User>>
    where
        E: Executor<'e, Database = Postgres>,
    {
        self.repo.find_by_username(executor, username).await
    }
}