diff options
| author | Fuwn <[email protected]> | 2022-04-25 01:16:37 -0700 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2022-04-25 01:16:37 -0700 |
| commit | 7f60409ed9c193ba6cea957b82afd836d9d6e90d (patch) | |
| tree | 6ddd3c2aed18bb2fc991e0e3c964772cf7593167 /src/main.rs | |
| parent | refactor(router): move error handler to constant (diff) | |
| download | locus-7f60409ed9c193ba6cea957b82afd836d9d6e90d.tar.xz locus-7f60409ed9c193ba6cea957b82afd836d9d6e90d.zip | |
refactor(modules): move complex router setup to modules
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 31 |
1 files changed, 1 insertions, 30 deletions
diff --git a/src/main.rs b/src/main.rs index a1beda9..ef66cf5 100644 --- a/src/main.rs +++ b/src/main.rs @@ -103,36 +103,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> { router.set_private_key_file(".locus/locus_private.pem"); router.set_certificate_file(".locus/locus_public.pem"); - router.set_pre_route_callback(Box::new(|stream, url, _| { - info!( - "accepted connection from {} to {}", - stream.peer_addr().unwrap().ip(), - url.to_string(), - ); - - let url_path = if url.path().is_empty() { - "/" - } else { - url.path() - }; - - let previous_database = (*DATABASE.lock().unwrap()).get::<i32>(url_path); - - match previous_database { - None => { - (*DATABASE.lock().unwrap()) - .set::<i32>(url_path, &0) - .unwrap(); - } - Some(_) => {} - } - - let new_database = (*DATABASE.lock().unwrap()).get::<i32>(url_path); - - (*DATABASE.lock().unwrap()) - .set(url_path, &(new_database.unwrap() + 1)) - .unwrap(); - })); router.set_error_handler(Box::new(|_| { Response::NotFound(ERROR_HANDLER_RESPONSE.into()) })); @@ -152,6 +122,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> { router.attach_stateless(modules::multi_blog::module); router.attach_stateless(modules::random::module); router.attach_stateless(modules::r#static::module); + router.attach_stateless(modules::router::module); }); std::thread::spawn(search::index); |