obscura-server 0.8.0

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

use crate::adapters::database::DbPool;
use crate::adapters::database::push_token_repo::PushTokenRepository;
use crate::error::Result;
use uuid::Uuid;

#[derive(Clone, Debug)]
pub struct PushTokenService {
    pool: DbPool,
    repo: PushTokenRepository,
}

impl PushTokenService {
    #[must_use]
    pub const fn new(pool: DbPool, repo: PushTokenRepository) -> Self {
        Self { pool, repo }
    }

    /// Registers or updates a push token for a device.
    ///
    /// # Errors
    /// Returns an error if the database operation fails.
    pub async fn register_token(&self, device_id: Uuid, token: String) -> Result<()> {
        // Here we could add validation (e.g. token format checks)
        let mut conn = self.pool.acquire().await?;
        self.repo.upsert_token(&mut conn, device_id, &token).await
    }
}