diff options
| author | Owen Jacobson <owen@grimoire.ca> | 2024-10-02 01:02:58 -0400 |
|---|---|---|
| committer | Owen Jacobson <owen@grimoire.ca> | 2024-10-02 01:02:58 -0400 |
| commit | 5d3392799f88c5a3d3f9c656c73d6e8ac5c4d793 (patch) | |
| tree | 426c568d82b67a98095d25952d2b5b2345a6545b /src/event | |
| parent | 357116366c1307bedaac6a3dfe9c5ed8e0e0c210 (diff) | |
Split login and token handling.
Diffstat (limited to 'src/event')
| -rw-r--r-- | src/event/routes.rs | 5 | ||||
| -rw-r--r-- | src/event/routes/test.rs | 4 |
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"); |
