1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
use axum::extract::State;
use axum_extra::extract::Query;
use futures::{future, stream::StreamExt as _};
use crate::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 super::Response(events) = super::handler(
State(app.clone()),
subscriber,
None,
Query(super::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");
let (_, joiner) = app
.tokens()
.validate(&joiner, &fixtures::now())
.await
.expect("a newly-issued secret is valid");
// Expect a login created event
let _ = events
.filter_map(fixtures::event::stream::user)
.filter_map(fixtures::event::stream::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");
let (_, joiner) = app
.tokens()
.validate(&joiner, &fixtures::now())
.await
.expect("a newly-issued secret is valid");
// Subscribe
let subscriber = fixtures::identity::create(&app, &fixtures::now()).await;
let super::Response(events) = super::handler(
State(app.clone()),
subscriber,
None,
Query(super::QueryParams { resume_point }),
)
.await
.expect("subscribe never fails");
// Expect a login created event
let _ = events
.filter_map(fixtures::event::stream::user)
.filter_map(fixtures::event::stream::user::created)
.filter(|event| future::ready(event.user == joiner))
.next()
.expect_some("a login created event is sent")
.await;
}
|
