Delete expired messages out of band.

Trying to reliably do expiry mid-request was causing some anomalies:

* Creating a channel with a dup name would fail, then succeed after listing channels.

It was very hard to reason about which operations needed to trigger expiry, to fix this "correctly," so now expiry runs on every request.

1 files changed, 2 insertions, 3 deletions

diff --git a/src/events/routes.rs b/src/events/routes.rs
index 3f70dcd..89c942c 100644
--- a/src/events/routes.rs
+++ b/src/events/routes.rs
@@ -13,7 +13,7 @@ use super::{
     extract::LastEventId,
     types::{self, ResumePoint},
 };
-use crate::{app::App, clock::RequestedAt, error::Internal, repo::login::Login};
+use crate::{app::App, error::Internal, repo::login::Login};
 
 #[cfg(test)]
 mod test;
@@ -24,7 +24,6 @@ pub fn router() -> Router<App> {
 
 async fn events(
     State(app): State<App>,
-    RequestedAt(subscribed_at): RequestedAt,
     _: Login, // requires auth, but doesn't actually care who you are
     last_event_id: Option<LastEventId<ResumePoint>>,
 ) -> Result<Events<impl Stream<Item = types::ResumableEvent> + std::fmt::Debug>, Internal> {
@@ -32,7 +31,7 @@ async fn events(
         .map(LastEventId::into_inner)
         .unwrap_or_default();
 
-    let stream = app.events().subscribe(&subscribed_at, resume_at).await?;
+    let stream = app.events().subscribe(resume_at).await?;
 
     Ok(Events(stream))
 }