cdk-axum 0.5.0

Cashu CDK axum webserver
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

use cdk::pub_sub::SubId;

use super::handler::WsHandle;
use super::{WsContext, WsError};

#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
pub struct Method {
    #[serde(rename = "subId")]
    pub sub_id: SubId,
}

#[derive(Debug, Clone, serde::Serialize)]
pub struct Response {
    status: String,
    sub_id: SubId,
}

#[async_trait::async_trait]
impl WsHandle for Method {
    type Response = Response;

    async fn handle(self, context: &mut WsContext) -> Result<Self::Response, WsError> {
        if context.subscriptions.remove(&self.sub_id).is_some() {
            Ok(Response {
                status: "OK".to_string(),
                sub_id: self.sub_id,
            })
        } else {
            Err(WsError::InvalidParams)
        }
    }
}