websocket-sans-io 0.1.0

Low-level WebSocket library
Documentation 
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
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325

use std::vec::Vec;

use std::vec;

use super::*;

extern crate std;

#[allow(unused)]
use std::dbg;

use pretty_assertions::assert_eq;

fn decode(input: &[u8], max_chunk_size : Option<usize>) -> (Vec<u8>, Vec<WebsocketFrameEvent>) {
    let mut input : Vec<u8> = input.into();
    let mut payload = Vec::new();
    let mut events = Vec::new();
    let mut d  = frame_decoding::WebsocketFrameDecoder::new();
    
    if let Some(mcs) = max_chunk_size {
        for chunk in input.chunks_mut(mcs) {
            decode_chunk(&mut d, chunk, &mut payload, &mut events);
        }
    } else {
        let ibuf = &mut input[..];
        decode_chunk(&mut d, ibuf, &mut payload, &mut events);
    }
    (payload, events)
}

fn decode_chunk(d: &mut frame_decoding::WebsocketFrameDecoder, mut ibuf: &mut [u8], payload: &mut Vec<u8>, events: &mut Vec<WebsocketFrameEvent>) {
    loop {
        //dbg!(ibuf.len());
        let ret = d.add_data(ibuf).unwrap();
        //dbg!(&ret);
        if let Some(WebsocketFrameEvent::PayloadChunk { .. }) = ret.event {
            payload.extend_from_slice(&ibuf[0..ret.consumed_bytes]);    
        }
        ibuf = &mut ibuf[ret.consumed_bytes..];
        if ibuf.is_empty() && ret.event.is_none() {
            break;   
        }
        if let Some(ev) = ret.event {
            events.push(ev);
        }
    }
}

#[test]
fn decode_dummy() {
    assert_eq!(decode(b"", None), ((*b"").into(), vec![]));
}

#[test]
fn decode_simple_unmasked() {
    assert_eq!(decode(b"\x81\x05\x48\x65\x6c\x6c\x6f", None), 
    ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_unmasked_1bc() {
    assert_eq!(decode(b"\x81\x05\x48\x65\x6c\x6c\x6f", Some(1)), 
    ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_unmasked_2bc() {
    assert_eq!(decode(b"\x81\x05\x48\x65\x6c\x6c\x6f", Some(2)), 
    ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_unmasked_3bc() {
    assert_eq!(decode(b"\x81\x05\x48\x65\x6c\x6c\x6f", Some(3)), 
    ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: None, fin: true, reserved: 0 }},
    ]));
}


#[test]
fn decode_simple_masked() {
    assert_eq!(decode(b"\x81\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", None), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_masked_1bc() {
    assert_eq!(decode(b"\x81\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", Some(1)), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_masked_2bc() {
    assert_eq!(decode(b"\x81\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", Some(2)), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_masked_3bc() {
    assert_eq!(decode(b"\x81\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", Some(3)), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_masked_5bc() {
    assert_eq!(decode(b"\x81\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", Some(5)), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_masked_6bc() {
    assert_eq!(decode(b"\x81\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", Some(6)), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_simple_fragmented() {
    assert_eq!(decode(b"\x01\x03\x48\x65\x6c\x80\x02\x6c\x6f", None), ((*b"Hello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 3, mask: None, fin: false, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Text, payload_length: 3, mask: None, fin: false, reserved: 0 }},
        WebsocketFrameEvent::Start{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Continuation, payload_length: 2, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Text},
        WebsocketFrameEvent::End{original_opcode: Opcode::Text, frame_info: FrameInfo { opcode: Opcode::Continuation, payload_length: 2, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_ping_pong() {
    assert_eq!(decode(b"\x89\x05\x48\x65\x6c\x6c\x6f\x8a\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", None), ((*b"HelloHello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Ping, frame_info: FrameInfo { opcode: Opcode::Ping, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Ping},
        WebsocketFrameEvent::End{original_opcode: Opcode::Ping, frame_info: FrameInfo { opcode: Opcode::Ping, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::Start{original_opcode: Opcode::Pong, frame_info: FrameInfo { opcode: Opcode::Pong, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Pong},
        WebsocketFrameEvent::End{original_opcode: Opcode::Pong, frame_info: FrameInfo { opcode: Opcode::Pong, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_ping_pong_1bc() {
    assert_eq!(decode(b"\x89\x05\x48\x65\x6c\x6c\x6f\x8a\x85\x37\xfa\x21\x3d\x7f\x9f\x4d\x51\x58", Some(1)), ((*b"HelloHello").into(), vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Ping, frame_info: FrameInfo { opcode: Opcode::Ping, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Ping},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Ping},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Ping},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Ping},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Ping},
        WebsocketFrameEvent::End{original_opcode: Opcode::Ping, frame_info: FrameInfo { opcode: Opcode::Ping, payload_length: 5, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::Start{original_opcode: Opcode::Pong, frame_info: FrameInfo { opcode: Opcode::Pong, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Pong},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Pong},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Pong},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Pong},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Pong},
        WebsocketFrameEvent::End{original_opcode: Opcode::Pong, frame_info: FrameInfo { opcode: Opcode::Pong, payload_length: 5, mask: Some(*b"\x37\xfa\x21\x3d"), fin: true, reserved: 0 }},
    ]));
}

#[test]
fn decode_bin256() {
    let mut input : Vec<u8> = (*b"\x82\x7E\x01\x00").into();
    let zeroes = vec![0; 256];
    input.extend_from_slice(&zeroes[..]);
    assert_eq!(decode(&input, None), (zeroes, vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 256, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::End{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 256, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[cfg(feature="large_frames")]
#[test]
fn decode_bin64k() {
    let mut input : Vec<u8> = (*b"\x82\x7F\x00\x00\x00\x00\x00\x01\x00\x00").into();
    let zeroes = vec![0; 65536];
    input.extend_from_slice(&zeroes[..]);
    std::assert_eq!(decode(&input, None), (zeroes, vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::End{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[cfg(feature="large_frames")]
#[test]
fn decode_bin64k_bc() {
    let mut input : Vec<u8> = (*b"\x82\x7F\x00\x00\x00\x00\x00\x01\x00\x00").into();
    let zeroes = vec![0; 65536];
    input.extend_from_slice(&zeroes[..]);
    std::assert_eq!(decode(&input, Some(32767)), (zeroes, vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: None, fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::End{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: None, fin: true, reserved: 0 }},
    ]));
}

#[cfg(feature="large_frames")]
#[test]
fn decode_bin64k_masked() {
    let mut input : Vec<u8> = (*b"\x82\xFF\x00\x00\x00\x00\x00\x01\x00\x00\x11\x22\x33\x44").into();
    let zeroes = vec![0; 65536];
    for _ in 0..(65536 / 4) {
        input.extend_from_slice(b"\x11\x22\x33\x44");
    }
    std::assert_eq!(decode(&input, None), (zeroes, vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: Some(*b"\x11\x22\x33\x44"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::End{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: Some(*b"\x11\x22\x33\x44"), fin: true, reserved: 0 }},
    ]));
}

#[cfg(feature="large_frames")]
#[test]
fn decode_bin64k_masked_chunks1() {
    let mut input : Vec<u8> = (*b"\x82\xFF\x00\x00\x00\x00\x00\x01\x00\x00\x11\x22\x33\x44").into();
    let zeroes = vec![0; 65536];
    for _ in 0..(65536 / 4) {
        input.extend_from_slice(b"\x11\x22\x33\x44");
    }
    std::assert_eq!(decode(&input, Some(65535)), (zeroes, vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: Some(*b"\x11\x22\x33\x44"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::End{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: Some(*b"\x11\x22\x33\x44"), fin: true, reserved: 0 }},
    ]));
}

#[cfg(feature="large_frames")]
#[test]
fn decode_bin64k_masked_chunks2() {
    let mut input : Vec<u8> = (*b"\x82\xFF\x00\x00\x00\x00\x00\x01\x00\x00\x11\x22\x33\x44").into();
    let zeroes = vec![0; 65536];
    for _ in 0..(65536 / 4) {
        input.extend_from_slice(b"\x11\x22\x33\x44");
    }
    std::assert_eq!(decode(&input, Some(2039)), (zeroes, vec![
        WebsocketFrameEvent::Start{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: Some(*b"\x11\x22\x33\x44"), fin: true, reserved: 0 }},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::PayloadChunk { original_opcode: Opcode::Binary},
        WebsocketFrameEvent::End{original_opcode: Opcode::Binary, frame_info: FrameInfo { opcode: Opcode::Binary, payload_length: 65536, mask: Some(*b"\x11\x22\x33\x44"), fin: true, reserved: 0 }},
    ]));
}