Provide a resume point to bridge clients from state snapshots to the event sequence.

3 files changed, 22 insertions, 3 deletions

diff --git a/src/login/app.rs b/src/login/app.rs
index 95f0a07..f1dffb9 100644
--- a/src/login/app.rs
+++ b/src/login/app.rs
@@ -13,6 +13,7 @@ use crate::{
     repo::{
         error::NotFound as _,
         login::{Login, Provider as _},
+        sequence::{Provider as _, Sequence},
         token::{self, Provider as _},
     },
 };
@@ -27,6 +28,14 @@ impl<'a> Logins<'a> {
         Self { db, logins }
     }
 
+    pub async fn boot_point(&self) -> Result<Sequence, sqlx::Error> {
+        let mut tx = self.db.begin().await?;
+        let sequence = tx.sequence().current().await?;
+        tx.commit().await?;
+
+        Ok(sequence)
+    }
+
     pub async fn login(
         &self,
         name: &str,
diff --git a/src/login/routes.rs b/src/login/routes.rs
index d7cb9b1..ef75871 100644
--- a/src/login/routes.rs
+++ b/src/login/routes.rs
@@ -26,13 +26,18 @@ pub fn router() -> Router<App> {
         .route("/api/auth/logout", post(on_logout))
 }
 
-async fn boot(login: Login) -> Boot {
-    Boot { login }
+async fn boot(State(app): State<App>, login: Login) -> Result<Boot, Internal> {
+    let resume_point = app.logins().boot_point().await?;
+    Ok(Boot {
+        login,
+        resume_point: resume_point.to_string(),
+    })
 }
 
 #[derive(serde::Serialize)]
 struct Boot {
     login: Login,
+    resume_point: String,
 }
 
 impl IntoResponse for Boot {
diff --git a/src/login/routes/test/boot.rs b/src/login/routes/test/boot.rs
index dee554f..9655354 100644
--- a/src/login/routes/test/boot.rs
+++ b/src/login/routes/test/boot.rs
@@ -1,9 +1,14 @@
+use axum::extract::State;
+
 use crate::{login::routes, test::fixtures};
 
 #[tokio::test]
 async fn returns_identity() {
+    let app = fixtures::scratch_app().await;
     let login = fixtures::login::fictitious();
-    let response = routes::boot(login.clone()).await;
+    let response = routes::boot(State(app), login.clone())
+        .await
+        .expect("boot always succeeds");
 
     assert_eq!(login, response.login);
 }