middlewares/
middlewares.rs

1extern crate rs_jsonrpc_core;
2
3use std::time::Instant;
4use std::sync::atomic::{self, AtomicUsize};
5use rs_jsonrpc_core::*;
6use rs_jsonrpc_core::futures::Future;
7
8#[derive(Clone, Default, Debug)]
9struct Meta(usize);
10impl Metadata for Meta {}
11
12#[derive(Default)]
13struct MyMiddleware(AtomicUsize);
14impl Middleware<Meta> for MyMiddleware {
15	type Future = FutureResponse;
16
17	fn on_request<F, X>(&self, request: Request, meta: Meta, next: F) -> FutureResponse where
18		F: FnOnce(Request, Meta) -> X + Send,
19		X: Future<Item=Option<Response>, Error=()> + Send + 'static,
20	{
21		let start = Instant::now();
22		let request_number = self.0.fetch_add(1, atomic::Ordering::SeqCst);
23		println!("Processing request {}: {:?}, {:?}", request_number, request, meta);
24
25		Box::new(next(request, meta).map(move |res| {
26			println!("Processing took: {:?}", start.elapsed());
27			res
28		}))
29	}
30}
31
32pub fn main() {
33	let mut io = MetaIoHandler::with_middleware(MyMiddleware::default());
34
35	io.add_method_with_meta("say_hello", |_params: Params, meta: Meta| {
36		Ok(Value::String(format!("Hello World: {}", meta.0)))
37	});
38
39	let request = r#"{"jsonrpc": "2.0", "method": "say_hello", "params": [42, 23], "id": 1}"#;
40	let response = r#"{"jsonrpc":"2.0","result":"Hello World: 5","id":1}"#;
41
42	let headers = 5;
43	assert_eq!(
44		io.handle_request(request, Meta(headers)).wait().unwrap(),
45		Some(response.to_owned())
46	);
47}
middlewares/middlewares.rs

middlewares/
middlewares.rs
