sevensense-api 0.1.0

REST, GraphQL, and WebSocket API server for 7sense bioacoustics platform
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! WebSocket module for real-time updates.
//!
//! This module provides WebSocket endpoints for:
//! - Real-time processing status updates
//! - Live cluster updates
//! - Streaming search results

pub mod handlers;

use axum::{routing::get, Router};

use crate::AppContext;

/// Create the WebSocket router.
#[must_use]
pub fn create_router(_ctx: AppContext) -> Router<AppContext> {
    Router::new()
        // Recording status updates
        .route("/recordings/:id", get(handlers::recording_status_ws))
        // All events stream (admin)
        .route("/events", get(handlers::events_ws))
}