diff options
| author | Owen Jacobson <owen@grimoire.ca> | 2025-03-23 19:06:43 -0400 |
|---|---|---|
| committer | Owen Jacobson <owen@grimoire.ca> | 2025-03-23 20:01:54 -0400 |
| commit | 5e4e052c400bb88933125f3549cec6dc12a9d09b (patch) | |
| tree | 32ba0249d010d7706ba01464723f2f07a987266a /src | |
| parent | f6191926ba94b8a1b303bca7c6996dce67781290 (diff) | |
Rename `login` to `user` throughout the server
Diffstat (limited to 'src')
| -rw-r--r-- | src/boot/app.rs | 2 | ||||
| -rw-r--r-- | src/boot/mod.rs | 2 | ||||
| -rw-r--r-- | src/boot/routes/get.rs | 4 | ||||
| -rw-r--r-- | src/boot/routes/test.rs | 12 | ||||
| -rw-r--r-- | src/channel/routes/channel/test/delete.rs | 2 | ||||
| -rw-r--r-- | src/event/app.rs | 6 | ||||
| -rw-r--r-- | src/event/mod.rs | 6 | ||||
| -rw-r--r-- | src/event/routes/test/invite.rs | 16 | ||||
| -rw-r--r-- | src/event/routes/test/message.rs | 18 | ||||
| -rw-r--r-- | src/event/routes/test/resume.rs | 4 | ||||
| -rw-r--r-- | src/event/routes/test/setup.rs | 6 | ||||
| -rw-r--r-- | src/event/routes/test/token.rs | 12 | ||||
| -rw-r--r-- | src/invite/routes/invite/test/get.rs | 4 | ||||
| -rw-r--r-- | src/invite/routes/invite/test/post.rs | 28 | ||||
| -rw-r--r-- | src/message/routes/message/test.rs | 8 | ||||
| -rw-r--r-- | src/setup/routes/test.rs | 10 | ||||
| -rw-r--r-- | src/test/fixtures/event.rs | 6 | ||||
| -rw-r--r-- | src/test/fixtures/identity.rs | 4 | ||||
| -rw-r--r-- | src/test/fixtures/mod.rs | 2 | ||||
| -rw-r--r-- | src/test/fixtures/user.rs (renamed from src/test/fixtures/login.rs) | 0 | ||||
| -rw-r--r-- | src/user/routes/login/test.rs | 10 | ||||
| -rw-r--r-- | src/user/routes/logout/test.rs | 2 | ||||
| -rw-r--r-- | src/user/routes/password/test.rs | 4 |
23 files changed, 84 insertions, 84 deletions
diff --git a/src/boot/app.rs b/src/boot/app.rs index 9c2559e..264d5ae 100644 --- a/src/boot/app.rs +++ b/src/boot/app.rs @@ -45,7 +45,7 @@ impl<'a> Boot<'a> { Ok(Snapshot { resume_point, - logins, + users: logins, channels, messages, }) diff --git a/src/boot/mod.rs b/src/boot/mod.rs index d614df5..c52b088 100644 --- a/src/boot/mod.rs +++ b/src/boot/mod.rs @@ -8,7 +8,7 @@ pub use self::routes::router; #[derive(serde::Serialize)] pub struct Snapshot { pub resume_point: Sequence, - pub logins: Vec<User>, + pub users: Vec<User>, pub channels: Vec<Channel>, pub messages: Vec<Message>, } diff --git a/src/boot/routes/get.rs b/src/boot/routes/get.rs index c04c6b3..4873b7a 100644 --- a/src/boot/routes/get.rs +++ b/src/boot/routes/get.rs @@ -8,14 +8,14 @@ use crate::{app::App, boot::Snapshot, error::Internal, 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.user, + user: identity.user, snapshot, }) } #[derive(serde::Serialize)] pub struct Response { - pub login: User, + pub user: User, #[serde(flatten)] pub snapshot: Snapshot, } diff --git a/src/boot/routes/test.rs b/src/boot/routes/test.rs index 5bd9f66..55802fe 100644 --- a/src/boot/routes/test.rs +++ b/src/boot/routes/test.rs @@ -12,20 +12,20 @@ async fn returns_identity() { .await .expect("boot always succeeds"); - assert_eq!(viewer.user, response.login); + assert_eq!(viewer.user, response.user); } #[tokio::test] async fn includes_logins() { let app = fixtures::scratch_app().await; - let spectator = fixtures::login::create(&app, &fixtures::now()).await; + let spectator = fixtures::user::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)); + assert!(response.snapshot.users.contains(&spectator)); } #[tokio::test] @@ -44,7 +44,7 @@ async fn includes_channels() { #[tokio::test] async fn includes_messages() { let app = fixtures::scratch_app().await; - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::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; @@ -59,7 +59,7 @@ async fn includes_messages() { #[tokio::test] async fn excludes_expired_messages() { let app = fixtures::scratch_app().await; - let sender = fixtures::login::create(&app, &fixtures::ancient()).await; + let sender = fixtures::user::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; @@ -80,7 +80,7 @@ async fn excludes_expired_messages() { #[tokio::test] async fn excludes_deleted_messages() { let app = fixtures::scratch_app().await; - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::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; diff --git a/src/channel/routes/channel/test/delete.rs b/src/channel/routes/channel/test/delete.rs index 77a0b03..bd9261d 100644 --- a/src/channel/routes/channel/test/delete.rs +++ b/src/channel/routes/channel/test/delete.rs @@ -156,7 +156,7 @@ pub async fn channel_not_empty() { let app = fixtures::scratch_app().await; let channel = fixtures::channel::create(&app, &fixtures::now()).await; - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::create(&app, &fixtures::now()).await; fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await; // Send the request diff --git a/src/event/app.rs b/src/event/app.rs index 447a98f..45a9099 100644 --- a/src/event/app.rs +++ b/src/event/app.rs @@ -33,8 +33,8 @@ impl<'a> Events<'a> { let mut tx = self.db.begin().await?; - let logins = tx.users().replay(resume_at).await?; - let login_events = logins + let users = tx.users().replay(resume_at).await?; + let user_events = users .iter() .map(user::History::events) .kmerge_by(Sequence::merge) @@ -57,7 +57,7 @@ impl<'a> Events<'a> { .filter(Sequence::after(resume_at)) .map(Event::from); - let replay_events = login_events + let replay_events = user_events .merge_by(channel_events, Sequence::merge) .merge_by(message_events, Sequence::merge) .collect::<Vec<_>>(); diff --git a/src/event/mod.rs b/src/event/mod.rs index 773adc3..3ab88ec 100644 --- a/src/event/mod.rs +++ b/src/event/mod.rs @@ -16,7 +16,7 @@ pub use self::{ #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize)] #[serde(tag = "type", rename_all = "snake_case")] pub enum Event { - Login(user::Event), + User(user::Event), Channel(channel::Event), Message(message::Event), } @@ -24,7 +24,7 @@ pub enum Event { impl Sequenced for Event { fn instant(&self) -> Instant { match self { - Self::Login(event) => event.instant(), + Self::User(event) => event.instant(), Self::Channel(event) => event.instant(), Self::Message(event) => event.instant(), } @@ -33,7 +33,7 @@ impl Sequenced for Event { impl From<user::Event> for Event { fn from(event: user::Event) -> Self { - Self::Login(event) + Self::User(event) } } diff --git a/src/event/routes/test/invite.rs b/src/event/routes/test/invite.rs index 80b4291..1d1bec6 100644 --- a/src/event/routes/test/invite.rs +++ b/src/event/routes/test/invite.rs @@ -12,7 +12,7 @@ async fn accepting_invite() { // Set up the environment let app = fixtures::scratch_app().await; - let issuer = fixtures::login::create(&app, &fixtures::now()).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; @@ -30,7 +30,7 @@ async fn accepting_invite() { // Accept the invite - let (name, password) = fixtures::login::propose(); + let (name, password) = fixtures::user::propose(); let (joiner, _) = app .invites() .accept(&invite.id, &name, &password, &fixtures::now()) @@ -40,8 +40,8 @@ async fn accepting_invite() { // Expect a login created event let _ = events - .filter_map(fixtures::event::login) - .filter_map(fixtures::event::login::created) + .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") @@ -53,13 +53,13 @@ async fn previously_accepted_invite() { // Set up the environment let app = fixtures::scratch_app().await; - let issuer = fixtures::login::create(&app, &fixtures::now()).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::login::propose(); + let (name, password) = fixtures::user::propose(); let (joiner, _) = app .invites() .accept(&invite.id, &name, &password, &fixtures::now()) @@ -81,8 +81,8 @@ async fn previously_accepted_invite() { // Expect a login created event let _ = events - .filter_map(fixtures::event::login) - .filter_map(fixtures::event::login::created) + .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") diff --git a/src/event/routes/test/message.rs b/src/event/routes/test/message.rs index fafaeb3..84a3aec 100644 --- a/src/event/routes/test/message.rs +++ b/src/event/routes/test/message.rs @@ -32,7 +32,7 @@ async fn sending() { // Send a message - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::create(&app, &fixtures::now()).await; let message = app .messages() .send( @@ -65,7 +65,7 @@ async fn previously_sent() { // Send a message - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::create(&app, &fixtures::now()).await; let message = app .messages() .send( @@ -105,7 +105,7 @@ async fn sent_in_multiple_channels() { // Set up the environment let app = fixtures::scratch_app().await; - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::create(&app, &fixtures::now()).await; let resume_point = fixtures::boot::resume_point(&app).await; let channels = [ @@ -156,7 +156,7 @@ async fn sent_sequentially() { let app = fixtures::scratch_app().await; let channel = fixtures::channel::create(&app, &fixtures::now()).await; - let sender = fixtures::login::create(&app, &fixtures::now()).await; + let sender = fixtures::user::create(&app, &fixtures::now()).await; let resume_point = fixtures::boot::resume_point(&app).await; let messages = vec