Merge branch 'main' into feature-frontend

1 files changed, 3 insertions, 2 deletions

diff --git a/src/events/routes.rs b/src/events/routes.rs
index 89c942c..ec9dae2 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, error::Internal, repo::login::Login};
+use crate::{app::App, error::Internal, login::extract::Identity};
 
 #[cfg(test)]
 mod test;
@@ -24,7 +24,7 @@ pub fn router() -> Router<App> {
 
 async fn events(
     State(app): State<App>,
-    _: Login, // requires auth, but doesn't actually care who you are
+    identity: Identity,
     last_event_id: Option<LastEventId<ResumePoint>>,
 ) -> Result<Events<impl Stream<Item = types::ResumableEvent> + std::fmt::Debug>, Internal> {
     let resume_at = last_event_id
@@ -32,6 +32,7 @@ async fn events(
         .unwrap_or_default();
 
     let stream = app.events().subscribe(resume_at).await?;
+    let stream = app.logins().limit_stream(identity.token, stream);
 
     Ok(Events(stream))
 }