From 155f6f2556b21e6b25afe096b19adcde1255c598 Mon Sep 17 00:00:00 2001
From: Owen Jacobson <owen@grimoire.ca>
Date: Fri, 27 Sep 2024 23:46:55 -0400
Subject: Expire channels, too.

---
 src/expire.rs | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)
 create mode 100644 src/expire.rs

(limited to 'src/expire.rs')

diff --git a/src/expire.rs b/src/expire.rs
new file mode 100644
index 0000000..16006d1
--- /dev/null
+++ b/src/expire.rs
@@ -0,0 +1,20 @@
+use axum::{
+    extract::{Request, State},
+    middleware::Next,
+    response::Response,
+};
+
+use crate::{app::App, clock::RequestedAt, error::Internal};
+
+// Expires messages and channels before each request.
+pub async fn middleware(
+    State(app): State<App>,
+    RequestedAt(expired_at): RequestedAt,
+    req: Request,
+    next: Next,
+) -> Result<Response, Internal> {
+    app.logins().expire(&expired_at).await?;
+    app.events().expire(&expired_at).await?;
+    app.channels().expire(&expired_at).await?;
+    Ok(next.run(req).await)
+}
-- 
cgit v1.2.3