axum-cometd 0.5.0

Framework for CometD server creation
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

use crate::{error::HandlerResult, messages::Message, LongPollingServiceContext};
use axum::{extract::State, http::StatusCode, Json};
use std::sync::Arc;

pub(crate) async fn disconnect(
    State(context): State<Arc<LongPollingServiceContext>>,
    Json([message]): Json<[Message; 1]>,
) -> HandlerResult<StatusCode> {
    tracing::info!("Got disconnect request: `{message:?}`.");

    let Message {
        id,
        channel,
        client_id,
        ..
    } = message;

    if channel.as_deref() != Some("/meta/disconnect") {
        Err(Message::session_unknown(id, channel, None).into())
    } else {
        let client_id =
            client_id.ok_or_else(|| Message::session_unknown(id.clone(), channel.clone(), None))?;

        context.unsubscribe(client_id).await;

        Ok(StatusCode::BAD_REQUEST)
    }
}