summaryrefslogtreecommitdiff
path: root/src/event/routes
diff options
context:
space:
mode:
Diffstat (limited to 'src/event/routes')
-rw-r--r--src/event/routes/test/invite.rs20
-rw-r--r--src/event/routes/test/message.rs18
-rw-r--r--src/event/routes/test/resume.rs4
-rw-r--r--src/event/routes/test/setup.rs8
-rw-r--r--src/event/routes/test/token.rs14
5 files changed, 32 insertions, 32 deletions
diff --git a/src/event/routes/test/invite.rs b/src/event/routes/test/invite.rs
index 73af62d..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,9 +40,9 @@ async fn accepting_invite() {
// Expect a login created event
let _ = events
- .filter_map(fixtures::event::login)
- .filter_map(fixtures::event::login::created)
- .filter(|event| future::ready(event.login == joiner))
+ .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;
@@ -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,9 +81,9 @@ async fn previously_accepted_invite() {
// Expect a login created event
let _ = events
- .filter_map(fixtures::event::login)
- .filter_map(fixtures::event::login::created)
- .filter(|event| future::ready(event.login == joiner))
+ .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;
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![
@@ -200,7 +200,7 @@ async fn expiring() {
let app = fixtures::scratch_app().await;
let channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
- let sender = fixtures::login::create(&app, &fixtures::ancient()).await;
+ let sender = fixtures::user::create(&app, &fixtures::ancient()).await;
let message = fixtures::message::send(&app, &channel, &sender, &fixtures::ancient()).await;
let resume_point = fixtures::boot::resume_point(&app).await;
@@ -239,7 +239,7 @@ async fn previously_expired() {
let app = fixtures::scratch_app().await;
let channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
- let sender = fixtures::login::create(&app, &fixtures::ancient()).await;
+ let sender = fixtures::user::create(&app, &fixtures::ancient()).await;
let message = fixtures::message::send(&app, &channel, &sender, &fixtures::ancient()).await;
let resume_point = fixtures::boot::resume_point(&app).await;
@@ -278,7 +278,7 @@ async fn deleting() {
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 message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await;
let resume_point = fixtures::boot::resume_point(&app).await;
@@ -317,7 +317,7 @@ async fn previously_deleted() {
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 message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await;
let resume_point = fixtures::boot::resume_point(&app).await;
@@ -356,7 +356,7 @@ async fn previously_purged() {
let app = fixtures::scratch_app().await;
let channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
- let sender = fixtures::login::create(&app, &fixtures::ancient()).await;
+ let sender = fixtures::user::create(&app, &fixtures::ancient()).await;
let message = fixtures::message::send(&app, &channel, &sender, &fixtures::ancient()).await;
let resume_point = fixtures::boot::resume_point(&app).await;
diff --git a/src/event/routes/test/resume.rs b/src/event/routes/test/resume.rs
index dc27691..633eae3 100644
--- a/src/event/routes/test/resume.rs
+++ b/src/event/routes/test/resume.rs
@@ -15,7 +15,7 @@ async fn resume() {
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 initial_message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await;
@@ -96,7 +96,7 @@ async fn serial_resume() {
// 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 channel_a = fixtures::channel::create(&app, &fixtures::now()).await;
let channel_b = fixtures::channel::create(&app, &fixtures::now()).await;
let resume_point = fixtures::boot::resume_point(&app).await;
diff --git a/src/event/routes/test/setup.rs b/src/event/routes/test/setup.rs
index 26b7ea7..1170fe4 100644
--- a/src/event/routes/test/setup.rs
+++ b/src/event/routes/test/setup.rs
@@ -19,7 +19,7 @@ async fn previously_completed() {
// Complete initial setup
- let (name, password) = fixtures::login::propose();
+ let (name, password) = fixtures::user::propose();
let (owner, _) = app
.setup()
.initial(&name, &password, &fixtures::now())
@@ -41,9 +41,9 @@ async fn previously_completed() {
// Expect a login created event
let _ = events
- .filter_map(fixtures::event::login)
- .filter_map(fixtures::event::login::created)
- .filter(|event| future::ready(event.login == owner))
+ .filter_map(fixtures::event::user)
+ .filter_map(fixtures::event::user::created)
+ .filter(|event| future::ready(event.user == owner))
.next()
.expect_some("a login created event is sent")
.await;
diff --git a/src/event/routes/test/token.rs b/src/event/routes/test/token.rs
index fa76865..a467de5 100644
--- a/src/event/routes/test/token.rs
+++ b/src/event/routes/test/token.rs
@@ -13,12 +13,12 @@ async fn terminates_on_token_expiry() {
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;
// Subscribe via the endpoint
- let subscriber_creds = fixtures::login::create_with_password(&app, &fixtures::now()).await;
+ let subscriber_creds = fixtures::user::create_with_password(&app, &fixtures::now()).await;
let subscriber =
fixtures::identity::logged_in(&app, &subscriber_creds, &fixtures::ancient()).await;
@@ -60,7 +60,7 @@ async fn terminates_on_logout() {
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;
// Subscribe via the endpoint
@@ -106,12 +106,12 @@ async fn terminates_on_password_change() {
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;
// Subscribe via the endpoint
- let creds = fixtures::login::create_with_password(&app, &fixtures::now()).await;
+ 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;
@@ -127,9 +127,9 @@ async fn terminates_on_password_change() {
// Verify the resulting stream's behaviour
let (_, password) = creds;
- let to = fixtures::login::propose_password();
+ let to = fixtures::user::propose_password();
app.tokens()
- .change_password(&subscriber.login, &password, &to, &fixtures::now())
+ .change_password(&subscriber.user, &password, &to, &fixtures::now())
.await
.expect("expiring tokens succeeds");
generated by cgit v1.2.3 (git 2.39.1) at 2026-01-02 22:41:09 +0000