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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
use axum::extract::State;
use axum_extra::extract::Query;
use futures::StreamExt as _;
use crate::test::{fixtures, fixtures::future::Expect as _};
#[tokio::test]
async fn live_vapid_key_changes() {
// Set up the context
let app = fixtures::scratch_app().await;
let resume_point = fixtures::boot::resume_point(&app).await;
// Subscribe to events
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");
// Rotate the VAPID key
app.vapid()
.refresh_key(&fixtures::now())
.await
.expect("refreshing the vapid key always succeeds");
// Verify that there's a key rotation event
events
.filter_map(fixtures::event::stream::vapid)
.filter_map(fixtures::event::stream::vapid::changed)
.next()
.expect_some("a vapid key change event is sent")
.await;
}
#[tokio::test]
async fn stored_vapid_key_changes() {
// Set up the context
let app = fixtures::scratch_app().await;
let resume_point = fixtures::boot::resume_point(&app).await;
// Rotate the VAPID key
app.vapid()
.refresh_key(&fixtures::now())
.await
.expect("refreshing the vapid key always succeeds");
// Subscribe to events
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");
// Verify that there's a key rotation event
events
.filter_map(fixtures::event::stream::vapid)
.filter_map(fixtures::event::stream::vapid::changed)
.next()
.expect_some("a vapid key change event is sent")
.await;
}
#[tokio::test]
async fn no_past_vapid_key_changes() {
// Set up the context
let app = fixtures::scratch_app().await;
// Rotate the VAPID key
app.vapid()
.refresh_key(&fixtures::now())
.await
.expect("refreshing the vapid key always succeeds");
// Subscribe to events
let resume_point = fixtures::boot::resume_point(&app).await;
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");
// Verify that there's a key rotation event
events
.filter_map(fixtures::event::stream::vapid)
.filter_map(fixtures::event::stream::vapid::changed)
.next()
.expect_wait("a vapid key change event is not sent")
.await;
}
|
