summaryrefslogtreecommitdiff
path: root/src/boot
diff options
context:
space:
mode:
Diffstat (limited to 'src/boot')
-rw-r--r--src/boot/app.rs36
-rw-r--r--src/boot/routes.rs27
-rw-r--r--src/boot/routes/get.rs27
-rw-r--r--src/boot/routes/mod.rs11
-rw-r--r--src/boot/routes/test.rs130
5 files changed, 196 insertions, 35 deletions
diff --git a/src/boot/app.rs b/src/boot/app.rs
index ef48b2f..e716b58 100644
--- a/src/boot/app.rs
+++ b/src/boot/app.rs
@@ -2,8 +2,11 @@ use sqlx::sqlite::SqlitePool;
use super::Snapshot;
use crate::{
- channel::repo::Provider as _, event::repo::Provider as _, login::repo::Provider as _,
+ channel::{self, repo::Provider as _},
+ event::repo::Provider as _,
+ login::{self, repo::Provider as _},
message::repo::Provider as _,
+ name,
};
pub struct Boot<'a> {
@@ -15,12 +18,12 @@ impl<'a> Boot<'a> {
Self { db }
}
- pub async fn snapshot(&self) -> Result<Snapshot, sqlx::Error> {
+ pub async fn snapshot(&self) -> Result<Snapshot, Error> {
let mut tx = self.db.begin().await?;
let resume_point = tx.sequence().current().await?;
let logins = tx.logins().all(resume_point.into()).await?;
- let channels = tx.channels().all(resume_point.into()).await?;
+ let channels = tx.channels().all(resume_point).await?;
let messages = tx.messages().all(resume_point.into()).await?;
tx.commit().await?;
@@ -48,3 +51,30 @@ impl<'a> Boot<'a> {
})
}
}
+
+#[derive(Debug, thiserror::Error)]
+#[error(transparent)]
+pub enum Error {
+ Name(#[from] name::Error),
+ Database(#[from] sqlx::Error),
+}
+
+impl From<login::repo::LoadError> for Error {
+ fn from(error: login::repo::LoadError) -> Self {
+ use login::repo::LoadError;
+ match error {
+ LoadError::Name(error) => error.into(),
+ LoadError::Database(error) => error.into(),
+ }
+ }
+}
+
+impl From<channel::repo::LoadError> for Error {
+ fn from(error: channel::repo::LoadError) -> Self {
+ use channel::repo::LoadError;
+ match error {
+ LoadError::Name(error) => error.into(),
+ LoadError::Database(error) => error.into(),
+ }
+ }
+}
diff --git a/src/boot/routes.rs b/src/boot/routes.rs
deleted file mode 100644
index 80f70bd..0000000
--- a/src/boot/routes.rs
+++ /dev/null
@@ -1,27 +0,0 @@
-use axum::{
- extract::{Json, State},
- routing::get,
- Router,
-};
-
-use super::Snapshot;
-use crate::{app::App, error::Internal, login::Login};
-
-#[cfg(test)]
-mod test;
-
-pub fn router() -> Router<App> {
- Router::new().route("/api/boot", get(boot))
-}
-
-async fn boot(State(app): State<App>, login: Login) -> Result<Json<Boot>, Internal> {
- let snapshot = app.boot().snapshot().await?;
- Ok(Boot { login, snapshot }.into())
-}
-
-#[derive(serde::Serialize)]
-struct Boot {
- login: Login,
- #[serde(flatten)]
- snapshot: Snapshot,
-}
diff --git a/src/boot/routes/get.rs b/src/boot/routes/get.rs
new file mode 100644
index 0000000..563fbf1
--- /dev/null
+++ b/src/boot/routes/get.rs
@@ -0,0 +1,27 @@
+use axum::{
+ extract::{Json, State},
+ response::{self, IntoResponse},
+};
+
+use crate::{app::App, boot::Snapshot, error::Internal, login::Login, token::extract::Identity};
+
+pub async fn handler(State(app): State<App>, identity: Identity) -> Result<Response, Internal> {
+ let snapshot = app.boot().snapshot().await?;
+ Ok(Response {
+ login: identity.login,
+ snapshot,
+ })
+}
+
+#[derive(serde::Serialize)]
+pub struct Response {
+ pub login: Login,
+ #[serde(flatten)]
+ pub snapshot: Snapshot,
+}
+
+impl IntoResponse for Response {
+ fn into_response(self) -> response::Response {
+ Json(self).into_response()
+ }
+}
diff --git a/src/boot/routes/mod.rs b/src/boot/routes/mod.rs
new file mode 100644
index 0000000..e4d5ac8
--- /dev/null
+++ b/src/boot/routes/mod.rs
@@ -0,0 +1,11 @@
+use axum::{routing::get, Router};
+
+use crate::app::App;
+
+mod get;
+#[cfg(test)]
+mod test;
+
+pub fn router() -> Router<App> {
+ Router::new().route("/api/boot", get(get::handler))
+}
diff --git a/src/boot/routes/test.rs b/src/boot/routes/test.rs
index 5f2ba6f..8808b70 100644
--- a/src/boot/routes/test.rs
+++ b/src/boot/routes/test.rs
@@ -1,14 +1,134 @@
-use axum::extract::{Json, State};
+use axum::extract::State;
-use crate::{boot::routes, test::fixtures};
+use super::get;
+use crate::test::fixtures;
#[tokio::test]
async fn returns_identity() {
let app = fixtures::scratch_app().await;
- let login = fixtures::login::fictitious();
- let Json(response) = routes::boot(State(app), login.clone())
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer.clone())
+ .await
+ .expect("boot always succeeds");
+
+ assert_eq!(viewer.login, response.login);
+}
+
+#[tokio::test]
+async fn includes_logins() {
+ let app = fixtures::scratch_app().await;
+ let spectator = fixtures::login::create(&app, &fixtures::now()).await;
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
+ .await
+ .expect("boot always succeeds");
+
+ assert!(response.snapshot.logins.contains(&spectator));
+}
+
+#[tokio::test]
+async fn includes_channels() {
+ let app = fixtures::scratch_app().await;
+ let channel = fixtures::channel::create(&app, &fixtures::now()).await;
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
+ .await
+ .expect("boot always succeeds");
+
+ assert!(response.snapshot.channels.contains(&channel));
+}
+
+#[tokio::test]
+async fn includes_messages() {
+ let app = fixtures::scratch_app().await;
+ let sender = fixtures::login::create(&app, &fixtures::now()).await;
+ let channel = fixtures::channel::create(&app, &fixtures::now()).await;
+ let message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await;
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
+ .await
+ .expect("boot always succeeds");
+
+ assert!(response.snapshot.messages.contains(&message));
+}
+
+#[tokio::test]
+async fn excludes_expired_messages() {
+ let app = fixtures::scratch_app().await;
+ let sender = fixtures::login::create(&app, &fixtures::ancient()).await;
+ let channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
+ let expired_message =
+ fixtures::message::send(&app, &channel, &sender, &fixtures::ancient()).await;
+
+ app.messages()
+ .expire(&fixtures::now())
+ .await
+ .expect("expiry never fails");
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
+ .await
+ .expect("boot always succeeds");
+
+ assert!(!response.snapshot.messages.contains(&expired_message));
+}
+
+#[tokio::test]
+async fn excludes_deleted_messages() {
+ let app = fixtures::scratch_app().await;
+ let sender = fixtures::login::create(&app, &fixtures::now()).await;
+ let channel = fixtures::channel::create(&app, &fixtures::now()).await;
+ let deleted_message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await;
+
+ app.messages()
+ .delete(&deleted_message.id, &fixtures::now())
+ .await
+ .expect("deleting valid message succeeds");
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
+ .await
+ .expect("boot always succeeds");
+
+ assert!(!response.snapshot.messages.contains(&deleted_message));
+}
+
+#[tokio::test]
+async fn excludes_expired_channels() {
+ let app = fixtures::scratch_app().await;
+ let expired_channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
+
+ app.channels()
+ .expire(&fixtures::now())
+ .await
+ .expect("expiry never fails");
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
+ .await
+ .expect("boot always succeeds");
+
+ assert!(!response.snapshot.channels.contains(&expired_channel));
+}
+
+#[tokio::test]
+async fn excludes_deleted_channels() {
+ let app = fixtures::scratch_app().await;
+ let deleted_channel = fixtures::channel::create(&app, &fixtures::now()).await;
+
+ app.channels()
+ .delete(&deleted_channel.id, &fixtures::now())
+ .await
+ .expect("deleting a valid channel succeeds");
+
+ let viewer = fixtures::identity::fictitious();
+ let response = get::handler(State(app), viewer)
.await
.expect("boot always succeeds");
- assert_eq!(login, response.login);
+ assert!(!response.snapshot.channels.contains(&deleted_channel));
}
generated by cgit v1.2.3 (git 2.39.1) at 2026-01-05 01:42:14 +0000