obscura-server 0.2.6

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

use crate::api::AppState;
use crate::api::middleware::AuthUser;
use crate::core::message_service::MessageService;
use crate::core::notification::UserEvent;
use crate::error::{AppError, Result};
use crate::proto::obscura::v1::EncryptedMessage;
use crate::storage::message_repo::MessageRepository;
use axum::{
    body::Bytes,
    extract::{Path, State},
    http::StatusCode,
    response::IntoResponse,
};
use prost::Message;
use uuid::Uuid;

pub async fn send_message(
    auth_user: AuthUser,
    State(state): State<AppState>,
    Path(recipient_id): Path<Uuid>,
    body: Bytes,
) -> Result<impl IntoResponse> {
    let service = MessageService::new(MessageRepository::new(state.pool), state.config.clone());

    // Decode the EncryptedMessage protobuf to get type and content
    let msg = EncryptedMessage::decode(body)
        .map_err(|_| AppError::BadRequest("Invalid EncryptedMessage protobuf".into()))?;

    // Store raw body directly (blind relay)
    service.enqueue_message(auth_user.user_id, recipient_id, msg.r#type, msg.content).await?;

    // Notify the user if they are connected
    state.notifier.notify(recipient_id, UserEvent::MessageReceived);

    Ok(StatusCode::CREATED)
}