middlewares/
middlewares.rs

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

middlewares/
middlewares.rs
