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, 90 deletions

diff --git a/src/event/routes/test/invite.rs b/src/event/routes/test/invite.rs
deleted file mode 100644
index 1d1bec6..0000000
--- a/src/event/routes/test/invite.rs
+++ /dev/null
@@ -1,90 +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 accepting_invite() {
-    // Set up the environment
-
-    let app = fixtures::scratch_app().await;
-    let issuer = fixtures::user::create(&app, &fixtures::now()).await;
-    let invite = fixtures::invite::issue(&app, &issuer, &fixtures::now()).await;
-    let resume_point = fixtures::boot::resume_point(&app).await;
-
-    // Subscribe
-
-    let subscriber = fixtures::identity::create(&app, &fixtures::now()).await;
-    let get::Response(events) = get::handler(
-        State(app.clone()),
-        subscriber,
-        None,
-        Query(get::QueryParams { resume_point }),
-    )
-    .await
-    .expect("subscribe never fails");
-
-    // Accept the invite
-
-    let (name, password) = fixtures::user::propose();
-    let (joiner, _) = app
-        .invites()
-        .accept(&invite.id, &name, &password, &fixtures::now())
-        .await
-        .expect("accepting an invite succeeds");
-
-    // Expect a login created event
-
-    let _ = events
-        .filter_map(fixtures::event::user)
-        .filter_map(fixtures::event::user::created)
-        .filter(|event| future::ready(event.user == joiner))
-        .next()
-        .expect_some("a login created event is sent")
-        .await;
-}
-
-#[tokio::test]
-async fn previously_accepted_invite() {
-    // Set up the environment
-
-    let app = fixtures::scratch_app().await;
-    let issuer = fixtures::user::create(&app, &fixtures::now()).await;
-    let invite = fixtures::invite::issue(&app, &issuer, &fixtures::now()).await;
-    let resume_point = fixtures::boot::resume_point(&app).await;
-
-    // Accept the invite
-
-    let (name, password) = fixtures::user::propose();
-    let (joiner, _) = app
-        .invites()
-        .accept(&invite.id, &name, &password, &fixtures::now())
-        .await
-        .expect("accepting an invite succeeds");
-
-    // Subscribe
-
-    let subscriber = fixtures::identity::create(&app, &fixtures::now()).await;
-    let get::Response(events) = get::handler(
-        State(app.clone()),
-        subscriber,
-        None,
-        Query(get::QueryParams { resume_point }),
-    )
-    .await
-    .expect("subscribe never fails");
-
-    // Expect a login created event
-
-    let _ = events
-        .filter_map(fixtures::event::user)
-        .filter_map(fixtures::event::user::created)
-        .filter(|event| future::ready(event.user == joiner))
-        .next()
-        .expect_some("a login created event is sent")
-        .await;
-}