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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
// META: global=window,worker
// META: script=/common/get-host-info.sub.js
// META: script=resources/webtransport-test-helpers.sub.js
// META: script=/common/utils.js
// META: timeout=long
promise_test(async t => {
const id = token();
const wt = new WebTransport(webtransport_url(`client-close.py?token=${id}`));
add_completion_callback(() => wt.close());
await wt.ready;
wt.close();
const close_info = await wt.closed;
assert_equals(close_info.closeCode, 0, 'code');
assert_equals(close_info.reason, '', 'reason');
await wait(10);
const data = await query(id);
assert_own_property(data, 'session-close-info');
const info = data['session-close-info']
assert_false(info.abruptly, 'abruptly');
assert_equals(info.close_info.code, 0, 'code');
assert_equals(info.close_info.reason, '', 'reason');
}, 'close');
promise_test(async t => {
const id = token();
const wt = new WebTransport(webtransport_url(`client-close.py?token=${id}`));
add_completion_callback(() => wt.close());
await wt.ready;
wt.close({closeCode: 99, reason: 'reason X'});
const close_info = await wt.closed;
assert_equals(close_info.closeCode, 99, 'code');
assert_equals(close_info.reason, 'reason X', 'reason');
await wait(10);
const data = await query(id);
assert_own_property(data, 'session-close-info');
const info = data['session-close-info']
assert_false(info.abruptly, 'abruptly');
assert_equals(info.close_info.code, 99, 'code');
assert_equals(info.close_info.reason, 'reason X', 'reason');
}, 'close with code and reason');
promise_test(async t => {
const id = token();
const wt = new WebTransport(webtransport_url(`client-close.py?token=${id}`));
add_completion_callback(() => wt.close());
await wt.ready;
const reason = 'あいうえお'.repeat(1000);
wt.close({closeCode: 11, reason});
const close_info = await wt.closed;
assert_equals(close_info.closeCode, 11, 'code');
// `close_info.reason` should report the original, non-truncated reason as
// step 9 of https://w3c.github.io/webtransport/#dom-webtransport-close
// uses the original `closeInfo` to perform `Cleanup`.
assert_equals(close_info.reason, reason, 'reason');
await wait(10);
const data = await query(id);
assert_own_property(data, 'session-close-info');
const info = data['session-close-info']
// Server should have received truncated reason as step 6 of
// https://w3c.github.io/webtransport/#dom-webtransport-close specifies.
const expected_reason =
new TextDecoder().decode(
new TextEncoder().encode(reason).slice(0, 1024)).replaceAll('\ufffd', '');
assert_false(info.abruptly, 'abruptly');
assert_equals(info.close_info.code, 11, 'code');
assert_equals(info.close_info.reason, expected_reason, 'reason');
}, 'close with code and long reason');
promise_test(async t => {
const wt = new WebTransport(webtransport_url('server-close.py'));
const close_info = await wt.closed;
assert_equals(close_info.closeCode, 0, 'code');
assert_equals(close_info.reason, '', 'reason');
}, 'server initiated closure without code and reason');
promise_test(async t => {
const code = 32;
const reason = 'abc';
const wt = new WebTransport(
webtransport_url(`server-close.py?code=${code}&reason=${reason}`));
add_completion_callback(() => wt.close());
const close_info = await wt.closed;
assert_equals(close_info.closeCode, code, 'code');
assert_equals(close_info.reason, reason, 'reason');
}, 'server initiated closure with code and reason');
promise_test(async t => {
const wt = new WebTransport(webtransport_url('server-connection-close.py'));
add_completion_callback(() => wt.close());
const streams_reader = wt.incomingBidirectionalStreams.getReader();
const { value: bidi } = await streams_reader.read();
const writer = bidi.writable.getWriter();
const reader = bidi.readable.getReader();
try {
writer.write(new Uint8Array([65]));
} catch (e) {
}
// Sadly we cannot use promise_rejects_dom as the error constructor is
// WebTransportError rather than DOMException.
// We get a possible error, and then make sure wt.closed is rejected with it.
const e = await wt.closed.catch(e => e);
await promise_rejects_exactly(t, e, wt.closed, 'wt.closed');
await promise_rejects_exactly(t, e, writer.closed, 'writer.closed');
await promise_rejects_exactly(t, e, reader.closed, 'reader.closed');
assert_true(e instanceof WebTransportError);
assert_equals(e.source, 'session', 'source');
assert_equals(e.streamErrorCode, null, 'streamErrorCode');
}, 'server initiated connection closure');
promise_test(async t => {
const wt = new WebTransport(webtransport_url('echo.py'));
const stream = await wt.createUnidirectionalStream();
await wt.ready;
}, 'opening unidirectional stream before ready');
promise_test(async t => {
const wt = new WebTransport(webtransport_url('echo.py'));
const stream = await wt.createBidirectionalStream();
await wt.ready;
}, 'opening bidirectional stream before ready');
promise_test(async t => {
const wt = new WebTransport(webtransport_url('server-close.py'));
promise_rejects_dom(t, "InvalidStateError", wt.createUnidirectionalStream());
}, 'server initiated closure while opening unidirectional stream before ready');
promise_test(async t => {
const wt = new WebTransport(webtransport_url('server-close.py'));
promise_rejects_dom(t, "InvalidStateError", wt.createBidirectionalStream());
}, 'server initiated closure while opening bidirectional stream before ready');
|
