aboutsummaryrefslogtreecommitdiff
path: root/src/router.rs
diff options
context:
space:
mode:
authorFuwn <[email protected]>2023-03-29 07:58:05 +0000
committerFuwn <[email protected]>2023-03-29 08:34:11 +0000
commit05f29bb19fcd1d3e7e12393ccfeb3c4f725e4b66 (patch)
treef9a9dfd15946c9d5429b23b182ec6cbae7073fd6 /src/router.rs
parentci(check): use table toolchain (diff)
downloadwindmark-05f29bb19fcd1d3e7e12393ccfeb3c4f725e4b66.tar.xz
windmark-05f29bb19fcd1d3e7e12393ccfeb3c4f725e4b66.zip
refactor(returnable): unify callback context
Diffstat (limited to 'src/router.rs')
-rw-r--r--src/router.rs22
1 files changed, 14 insertions, 8 deletions
diff --git a/src/router.rs b/src/router.rs
index 6d2737e..dc81d40 100644
--- a/src/router.rs
+++ b/src/router.rs
@@ -316,9 +316,12 @@ impl Router {
));
}
- (*self.pre_route_callback).lock().unwrap()(stream.get_ref(), &url, {
- route.as_ref().map_or(None, |route| Some(&route.params))
- });
+ (*self.pre_route_callback).lock().unwrap()(CallbackContext::new(
+ stream.get_ref(),
+ &url,
+ route.as_ref().map_or(None, |route| Some(&route.params)),
+ &stream.ssl().peer_certificate(),
+ ));
let content = if let Ok(ref route) = route {
let footers_length = (*self.footers.lock().unwrap()).len();
@@ -418,9 +421,12 @@ impl Router {
));
}
- (*self.post_route_callback).lock().unwrap()(stream.get_ref(), &url, {
- route.as_ref().map_or(None, |route| Some(&route.params))
- });
+ (*self.post_route_callback).lock().unwrap()(CallbackContext::new(
+ stream.get_ref(),
+ &url,
+ route.as_ref().map_or(None, |route| Some(&route.params)),
+ &stream.ssl().peer_certificate(),
+ ));
stream.shutdown().await?;
@@ -756,8 +762,8 @@ impl Default for Router {
),
#[cfg(feature = "logger")]
default_logger: false,
- pre_route_callback: Arc::new(Mutex::new(Box::new(|_, _, _| {}))),
- post_route_callback: Arc::new(Mutex::new(Box::new(|_, _, _| {}))),
+ pre_route_callback: Arc::new(Mutex::new(Box::new(|_| {}))),
+ post_route_callback: Arc::new(Mutex::new(Box::new(|_| {}))),
charset: "utf-8".to_string(),
language: "en".to_string(),
port: 1965,