summaryrefslogtreecommitdiff
path: root/src/event
diff options
context:
space:
mode:
authorOwen Jacobson <owen@grimoire.ca>2024-10-02 01:02:58 -0400
committerOwen Jacobson <owen@grimoire.ca>2024-10-02 01:02:58 -0400
commit5d3392799f88c5a3d3f9c656c73d6e8ac5c4d793 (patch)
tree426c568d82b67a98095d25952d2b5b2345a6545b /src/event
parent357116366c1307bedaac6a3dfe9c5ed8e0e0c210 (diff)
Split login and token handling.
Diffstat (limited to 'src/event')
-rw-r--r--src/event/routes.rs5
-rw-r--r--src/event/routes/test.rs4
2 files changed, 4 insertions, 5 deletions
diff --git a/src/event/routes.rs b/src/event/routes.rs
index 77761ca..50ac435 100644
--- a/src/event/routes.rs
+++ b/src/event/routes.rs
@@ -15,8 +15,7 @@ use crate::{
app::App,
error::{Internal, Unauthorized},
event::Sequence,
- login::app::ValidateError,
- token::extract::Identity,
+ token::{app::ValidateError, extract::Identity},
};
#[cfg(test)]
@@ -42,7 +41,7 @@ async fn events(
.or(query.resume_point);
let stream = app.events().subscribe(resume_at).await?;
- let stream = app.logins().limit_stream(identity.token, stream).await?;
+ let stream = app.tokens().limit_stream(identity.token, stream).await?;
Ok(Events(stream))
}
diff --git a/src/event/routes/test.rs b/src/event/routes/test.rs
index 9a3b12a..d1ac3b4 100644
--- a/src/event/routes/test.rs
+++ b/src/event/routes/test.rs
@@ -371,7 +371,7 @@ async fn terminates_on_token_expiry() {
// Verify the resulting stream's behaviour
- app.logins()
+ app.tokens()
.expire(&fixtures::now())
.await
.expect("expiring tokens succeeds");
@@ -418,7 +418,7 @@ async fn terminates_on_logout() {
// Verify the resulting stream's behaviour
- app.logins()
+ app.tokens()
.logout(&subscriber.token)
.await
.expect("expiring tokens succeeds");