diff --git a/ingest/src/main.rs b/ingest/src/main.rs index 255ad49..4650572 100644 --- a/ingest/src/main.rs +++ b/ingest/src/main.rs @@ -17,11 +17,11 @@ pub struct RawRequest { host: String, user_agent: String, referrer: String, - secure: bool, + secure: String, timestamp: String, } -//#[derive(Serialize)] +#[derive(Debug)] pub struct Request { size: i32, path: String, @@ -93,8 +93,12 @@ async fn receive_message(pool: &PgPool, message: &[u8]) -> Result<(), Box true, + "" => false, + _ => return Err(String::from("Unexpected content in $https").into()), + }, + timestamp: OffsetDateTime::parse(req.timestamp, "%d/%b/%Y:%T %z")? }; db::insert(pool, req).await?; Ok(())