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
49

use log::*;

use crate::workflow::filter::{AdminFilter, FilterError};
use crate::workflow::context::Context;
use crate::message::stomp_message::StompMessage;
use crate::workflow::filter::admin::shutdown::ShutdownFilter;

// route /virt/admin/ SEND messages through the application

lazy_static! {

    pub static ref FILTER_CHAIN_STATIC: FilterChain = FilterChain {
        chain: build_filter_chain()
    };

}

pub struct FilterChain {
    chain: Vec<Box<dyn AdminFilter + Sync>>,
}

pub fn build_filter_chain() -> Vec<Box<dyn AdminFilter + Sync>> {
    let mut route: Vec<Box<dyn AdminFilter + Sync>> = vec![
        Box::new(ShutdownFilter::new()),
    ];

    for filter in route.iter_mut() {
        filter.init();
    }

    debug!("init finished");
    route
}

/// route incoming messages
pub fn route_admin(mut ctx: &mut Context, message: &mut StompMessage) -> Result<bool, FilterError> {

    for f in &FILTER_CHAIN_STATIC.chain {
        match f.do_filter(&mut ctx, message) {
            Ok(false) => {}, // loop
            Ok(true) => return Ok(true),
            Err(fe) => return Err(fe),
        }
    }

    Ok(false)
}