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
|
<!doctype html>
<html>
<head>
<meta charset="utf-8">
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
</head>
<body>
<script>
promise_test(async (test) => {
const pc = new RTCPeerConnection();
const senderTransform = new SFrameTransform();
const receiverTransform = new SFrameTransform();
const sender1 = pc.addTransceiver('audio').sender;
const sender2 = pc.addTransceiver('video').sender;
const receiver1 = pc.getReceivers()[0];
const receiver2 = pc.getReceivers()[1];
sender1.transform = senderTransform;
receiver1.transform = receiverTransform;
assert_throws_dom("InvalidStateError", () => sender2.transform = senderTransform);
assert_throws_dom("InvalidStateError", () => receiver2.transform = receiverTransform);
sender1.transform = senderTransform;
receiver1.transform = receiverTransform;
sender1.transform = null;
receiver1.transform = null;
}, "Cannot reuse attached transforms");
test(() => {
const senderTransform = new SFrameTransform();
assert_true(senderTransform.readable instanceof ReadableStream);
assert_true(senderTransform.writable instanceof WritableStream);
}, "SFrameTransform exposes readable and writable");
promise_test(async (test) => {
const pc = new RTCPeerConnection();
const senderTransform = new SFrameTransform();
const receiverTransform = new SFrameTransform();
const sender1 = pc.addTransceiver('audio').sender;
const sender2 = pc.addTransceiver('video').sender;
const receiver1 = pc.getReceivers()[0];
const receiver2 = pc.getReceivers()[1];
assert_false(senderTransform.readable.locked, "sender readable before");
assert_false(senderTransform.writable.locked, "sender writable before");
assert_false(receiverTransform.readable.locked, "receiver readable before");
assert_false(receiverTransform.writable.locked, "receiver writable before");
sender1.transform = senderTransform;
receiver1.transform = receiverTransform;
assert_true(senderTransform.readable.locked, "sender readable during");
assert_true(senderTransform.writable.locked, "sender writable during");
assert_true(receiverTransform.readable.locked, "receiver readable during");
assert_true(receiverTransform.writable.locked, "receiver writable during");
sender1.transform = null;
receiver1.transform = null;
assert_true(senderTransform.readable.locked, "sender readable after");
assert_true(senderTransform.writable.locked, "sender writable after");
assert_true(receiverTransform.readable.locked, "receiver readable after");
assert_true(receiverTransform.writable.locked, "receiver writable after");
}, "readable/writable are locked when attached and after being attached");
promise_test(async (test) => {
const key = await crypto.subtle.importKey("raw", new Uint8Array([143, 77, 43, 10, 72, 19, 37, 67, 236, 219, 24, 93, 26, 165, 91, 178]), "HKDF", false, ["deriveBits", "deriveKey"]);
const senderTransform = new SFrameTransform({ role : 'encrypt', authenticationSize: 10 });
senderTransform.setEncryptionKey(key);
const receiverTransform = new SFrameTransform({ role : 'decrypt', authenticationSize: 10 });
receiverTransform.setEncryptionKey(key);
const writer = senderTransform.writable.getWriter();
const reader = receiverTransform.readable.getReader();
senderTransform.readable.pipeTo(receiverTransform.writable);
const sent = new ArrayBuffer(8);
const view = new Int8Array(sent);
for (let cptr = 0; cptr < sent.byteLength; ++cptr)
view[cptr] = cptr;
writer.write(sent);
const received = await reader.read();
assert_equals(received.value.byteLength, 8);
const view2 = new Int8Array(received.value);
for (let cptr = 0; cptr < sent.byteLength; ++cptr)
assert_equals(view2[cptr], view[cptr]);
}, "SFrame with array buffer - authentication size 10");
promise_test(async (test) => {
const key = await crypto.subtle.importKey("raw", new Uint8Array([143, 77, 43, 10, 72, 19, 37, 67, 236, 219, 24, 93, 26, 165, 91, 178]), "HKDF", false, ["deriveBits", "deriveKey"]);
const senderTransform = new SFrameTransform({ role : 'encrypt', authenticationSize: 10 });
const senderWriter = senderTransform.writable.getWriter();
const senderReader = senderTransform.readable.getReader();
const receiverTransform = new SFrameTransform({ role : 'decrypt', authenticationSize: 10 });
const receiverWriter = receiverTransform.writable.getWriter();
const receiverReader = receiverTransform.readable.getReader();
senderTransform.setEncryptionKey(key);
receiverTransform.setEncryptionKey(key);
const chunk = new ArrayBuffer(8);
// decryption should fail, leading to an empty array buffer.
await receiverWriter.write(chunk);
let received = await receiverReader.read();
assert_equals(received.value.byteLength, 0);
// We write again but this time with a chunk we can decrypt.
await senderWriter.write(chunk);
const encrypted = await senderReader.read();
await receiverWriter.write(encrypted.value);
received = await receiverReader.read();
assert_equals(received.value.byteLength, 8);
}, "SFrame decryption with array buffer that is too small");
promise_test(async (test) => {
const key = await crypto.subtle.importKey("raw", new Uint8Array([143, 77, 43, 10, 72, 19, 37, 67, 236, 219, 24, 93, 26, 165, 91, 178]), "HKDF", false, ["deriveBits", "deriveKey"]);
const receiverTransform = new SFrameTransform({ role : 'decrypt', authenticationSize: 10 });
const receiverWriter = receiverTransform.writable.getWriter();
receiverTransform.setEncryptionKey(key);
// decryption should fail, leading to erroring the transform.
await promise_rejects_js(test, TypeError, receiverWriter.write({ }));
await promise_rejects_js(test, TypeError, receiverWriter.closed);
}, "SFrame transform gets errored if trying to process unexpected value types");
</script>
</body>
</html>
|
