jutty/en
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Replace logging function with a macro

Browse source
This commit is contained in:
Juno Takano 2025-12-18 02:19:55 -03:00
commit 0d66b1ee7c
5 changed files with 44 additions and 44 deletions
Download patch file Download diff file Expand all files Collapse all files

27
src/dev.rs
View file

@ -1,7 +1,22 @@
pub fn log<F>(function: &F, message: &str) { pub fn elog(function: &str, message: &str) {
eprintln!( eprintln!("{:?} [{function}] {message}", crate::ONSET.elapsed());
"{:?} [{}] {message}", }
crate::ONSET.elapsed(),
std::any::type_name_of_val(function).replace("en::", ""), #[macro_export]
); macro_rules! log {
($fmt:expr $(, $($arg:tt)+ )? ) => {{
let mut scope = std::any::type_name_of_val(&|| {})
.to_string().replace("::{{closure}}", "");
if scope.matches("::").count() > 3 {
let parts: Vec<&str> = scope.split("::").collect();
if let (Some(module) , Some(caller)) =
(parts.get(parts.len().saturating_sub(1)),
parts.get(parts.len().saturating_sub(2))) {
scope = format!("{module}::{caller}");
}
}
$crate::dev::elog(&scope, &format!($fmt $(, $($arg)+ )?));
}};
} }

17
src/handlers/fixed.rs
View file

@ -3,6 +3,7 @@ use axum::{
http::{Response, StatusCode, header, HeaderValue}, http::{Response, StatusCode, header, HeaderValue},
}; };
use crate::prelude::*;
use crate::{ use crate::{
formats::{Format, populate_graph, serialize_graph}, formats::{Format, populate_graph, serialize_graph},
}; };
@ -24,22 +25,12 @@ pub async fn file(file_path: &str, content_type: &str) -> Response<Body> {
if let Ok(header_value) = HeaderValue::from_str(content_type) { if let Ok(header_value) = HeaderValue::from_str(content_type) {
if let Some(h) = response.headers_mut().insert(header, header_value) { if let Some(h) = response.headers_mut().insert(header, header_value) {
crate::dev::log( log!(
&file, "Overwrote existing header {h:?} because a header for the same key existed"
&format!(
"Overwrote existing header {h:?} because a header for \
the same key existed"
),
); );
} }
} else { } else {
crate::dev::log( log!("Failed to create content type header value from {content_type}");
&file,
&format!(
"Failed to create content type \
header value from {content_type}"
),
);
} }
response response

12
src/handlers/raw.rs
View file

@ -3,6 +3,8 @@ use axum::{
http::{header, HeaderValue, Response, StatusCode}, http::{header, HeaderValue, Response, StatusCode},
}; };
use crate::prelude::*;
pub(in crate::handlers) fn make_response( pub(in crate::handlers) fn make_response(
body: &str, body: &str,
status_code: u16, status_code: u16,
@ -18,20 +20,14 @@ pub(in crate::handlers) fn make_response(
if let Some(overwritten) = if let Some(overwritten) =
response.headers_mut().insert(header.0.clone(), wrapped) response.headers_mut().insert(header.0.clone(), wrapped)
{ {
crate::dev::log( log!(
&make_response,
&format!(
"Overwrote header {overwritten:?} \ "Overwrote header {overwritten:?} \
because another for key {} already existed", because another for key {} already existed",
header.0 header.0
),
); );
} }
} else { } else {
crate::dev::log( log!("Failed to wrap header value {}", header.1);
&make_response,
&format!("Failed to wrap header value {}", header.1),
);
} }
} }

4
src/lib.rs
View file

@ -1,5 +1,9 @@
use std::{sync, time}; use std::{sync, time};
pub mod prelude {
pub use crate::log;
}
pub mod formats; pub mod formats;
pub mod types; pub mod types;
pub mod router; pub mod router;

14
src/main.rs
View file

@ -1,6 +1,6 @@
use std::{backtrace, io, panic}; use std::{backtrace, io, panic};
use en::{ONSET, dev, formats::populate_graph, syntax}; use en::{prelude::*, ONSET, formats::populate_graph, syntax};
#[tokio::main] #[tokio::main]
async fn main() -> io::Result<()> { async fn main() -> io::Result<()> {
@ -30,26 +30,20 @@ async fn main() -> io::Result<()> {
let listener = let listener =
tokio::net::TcpListener::bind(&address).await.map_err(|e| { tokio::net::TcpListener::bind(&address).await.map_err(|e| {
dev::log( log!("Failed to create listener at {address}: {e:#?}");
&main,
&format!("Failed to create listener at {address}: {e:#?}"),
);
e e
})?; })?;
dev::log( log!(
&main,
&format!(
"Listening on {}", "Listening on {}",
listener listener
.local_addr() .local_addr()
.map(|s| s.to_string()) .map(|s| s.to_string())
.unwrap_or("<unknown>".to_string()) .unwrap_or("<unknown>".to_string())
),
); );
axum::serve(listener, app).await.map_err(|e| { axum::serve(listener, app).await.map_err(|e| {
dev::log(&main, &format!("Failed to serve application: {e:#?}")); log!("Failed to serve application: {e:#?}");
io::Error::other(e) io::Error::other(e)
})?; })?;