Handlers are _named operations_, which can be exposed via routes.

Each domain module that exposes handlers does so through a `handlers` child module, ideally as a top-level symbol that can be plugged directly into Axum's `MethodRouter`. Modules could make exceptions to this - kill the doctrinaire inside yourself, after all - but none of the API modules that actually exist need such exceptions, and consistency is useful.

The related details of request types, URL types, response types, errors, &c &c are then organized into modules under `handlers`, along with their respective tests.

1 files changed, 0 insertions, 151 deletions

diff --git a/src/event/routes/test/token.rs b/src/event/routes/test/token.rs
deleted file mode 100644
index a467de5..0000000
--- a/src/event/routes/test/token.rs
+++ /dev/null
@@ -1,151 +0,0 @@
-use axum::extract::State;
-use axum_extra::extract::Query;
-use futures::{future, stream::StreamExt as _};
-
-use crate::{
-    event::routes::get,
-    test::fixtures::{self, future::Expect as _},
-};
-
-#[tokio::test]
-async fn terminates_on_token_expiry() {
-    // Set up the environment
-
-    let app = fixtures::scratch_app().await;
-    let channel = fixtures::channel::create(&app, &fixtures::now()).await;
-    let sender = fixtures::user::create(&app, &fixtures::now()).await;
-    let resume_point = fixtures::boot::resume_point(&app).await;
-
-    // Subscribe via the endpoint
-
-    let subscriber_creds = fixtures::user::create_with_password(&app, &fixtures::now()).await;
-    let subscriber =
-        fixtures::identity::logged_in(&app, &subscriber_creds, &fixtures::ancient()).await;
-
-    let get::Response(events) = get::handler(
-        State(app.clone()),
-        subscriber,
-        None,
-        Query(get::QueryParams { resume_point }),
-    )
-    .await
-    .expect("subscribe never fails");
-
-    // Verify the resulting stream's behaviour
-
-    app.tokens()
-        .expire(&fixtures::now())
-        .await
-        .expect("expiring tokens succeeds");
-
-    // These should not be delivered.
-    let messages = [
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-    ];
-
-    events
-        .filter_map(fixtures::event::message)
-        .filter_map(fixtures::event::message::sent)
-        .filter(|event| future::ready(messages.iter().any(|message| &event.message == message)))
-        .next()
-        .expect_none("end of stream")
-        .await;
-}
-
-#[tokio::test]
-async fn terminates_on_logout() {
-    // Set up the environment
-
-    let app = fixtures::scratch_app().await;
-    let channel = fixtures::channel::create(&app, &fixtures::now()).await;
-    let sender = fixtures::user::create(&app, &fixtures::now()).await;
-    let resume_point = fixtures::boot::resume_point(&app).await;
-
-    // Subscribe via the endpoint
-
-    let subscriber = fixtures::identity::create(&app, &fixtures::now()).await;
-
-    let get::Response(events) = get::handler(
-        State(app.clone()),
-        subscriber.clone(),
-        None,
-        Query(get::QueryParams { resume_point }),
-    )
-    .await
-    .expect("subscribe never fails");
-
-    // Verify the resulting stream's behaviour
-
-    app.tokens()
-        .logout(&subscriber.token)
-        .await
-        .expect("expiring tokens succeeds");
-
-    // These should not be delivered.
-
-    let messages = [
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-    ];
-
-    events
-        .filter_map(fixtures::event::message)
-        .filter_map(fixtures::event::message::sent)
-        .filter(|event| future::ready(messages.iter().any(|message| &event.message == message)))
-        .next()
-        .expect_none("end of stream")
-        .await;
-}
-
-#[tokio::test]
-async fn terminates_on_password_change() {
-    // Set up the environment
-
-    let app = fixtures::scratch_app().await;
-    let channel = fixtures::channel::create(&app, &fixtures::now()).await;
-    let sender = fixtures::user::create(&app, &fixtures::now()).await;
-    let resume_point = fixtures::boot::resume_point(&app).await;
-
-    // Subscribe via the endpoint
-
-    let creds = fixtures::user::create_with_password(&app, &fixtures::now()).await;
-    let cookie = fixtures::cookie::logged_in(&app, &creds, &fixtures::now()).await;
-    let subscriber = fixtures::identity::from_cookie(&app, &cookie, &fixtures::now()).await;
-
-    let get::Response(events) = get::handler(
-        State(app.clone()),
-        subscriber.clone(),
-        None,
-        Query(get::QueryParams { resume_point }),
-    )
-    .await
-    .expect("subscribe never fails");
-
-    // Verify the resulting stream's behaviour
-
-    let (_, password) = creds;
-    let to = fixtures::user::propose_password();
-    app.tokens()
-        .change_password(&subscriber.user, &password, &to, &fixtures::now())
-        .await
-        .expect("expiring tokens succeeds");
-
-    // These should not be delivered.
-
-    let messages = [
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-        fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await,
-    ];
-
-    events
-        .filter_map(fixtures::event::message)
-        .filter_map(fixtures::event::message::sent)
-        .filter(|event| future::ready(messages.iter().any(|message| &event.message == message)))
-        .next()
-        .expect_none("end of stream")
-        .await;
-}