romp 0.5.2

STOMP server and WebSockets platform
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
37
38
39
40
41
42
43
44
45
46
47
48

//! Internal API contains methods that are only useful in the context of bespoke filters.


use crate::init::SERVER;
use crate::message::stomp_message::StompMessage;
use crate::errors::ServerError;
use std::sync::{Arc, RwLock};
use crate::session::subscription::{Subscription, Ack};
use crate::session::stomp_session::StompSession;
use crate::message::response::get_http_ok_text_content;
use crate::workflow::context::Context;

/// internal API

/// publish a message to a destination
pub fn romp_pub_message(destination: &str, message: StompMessage) -> Result<usize, ServerError> {
    return match SERVER.find_destination(destination) {
        Some(destination) => {
            destination.write().unwrap().push(&message)
        },
        _ => Err(ServerError::DestinationUnknown)
    }
}

pub fn romp_subscribe(destination: &str) -> Result<Arc<RwLock<StompSession>>, ServerError> {
    return match SERVER.find_destination(destination) {
        Some(destination) => {
            let session = StompSession::new();
            let arc_session = Arc::new(RwLock::new(session));
            let sub = Arc::new(RwLock::new(Subscription::new(arc_session.clone(), destination.clone(), 0, Ack::Auto, None, false)));
            let mut dest = destination.write().unwrap();
            match dest.subscribe(sub) {
                Err(e) => Err(e),
                Ok(_) => {
                    Ok(arc_session)
                }
            }
        },
        _ => Err(ServerError::DestinationUnknown)
    }
}

pub fn romp_http_response(context: Context, text: String, content_type: &'static str) {
    if let Ok(session) = context.session.read() {
        let message = get_http_ok_text_content(text, content_type);
        session.send_message(message);
    }
}