]> git.proxmox.com Git - mirror_novnc.git/blame - tests/fake.websocket.js
Prefer const/let over var
[mirror_novnc.git] / tests / fake.websocket.js
CommitLineData
8727f598
JD
1import Base64 from '../core/base64.js';
2
dfae3209
SR
3// PhantomJS can't create Event objects directly, so we need to use this
4function make_event(name, props) {
2b5f94fa 5 const evt = document.createEvent('Event');
dfae3209
SR
6 evt.initEvent(name, true, true);
7 if (props) {
2b5f94fa 8 for (let prop in props) {
dfae3209 9 evt[prop] = props[prop];
2cccf753 10 }
2cccf753 11 }
dfae3209
SR
12 return evt;
13}
2cccf753 14
dfae3209
SR
15export default function FakeWebSocket (uri, protocols) {
16 this.url = uri;
17 this.binaryType = "arraybuffer";
18 this.extensions = "";
2cccf753 19
dfae3209
SR
20 if (!protocols || typeof protocols === 'string') {
21 this.protocol = protocols;
22 } else {
23 this.protocol = protocols[0];
24 }
2cccf753 25
dfae3209 26 this._send_queue = new Uint8Array(20000);
2cccf753 27
dfae3209
SR
28 this.readyState = FakeWebSocket.CONNECTING;
29 this.bufferedAmount = 0;
2cccf753 30
dfae3209 31 this.__is_fake = true;
8727f598 32}
2cccf753 33
dfae3209
SR
34FakeWebSocket.prototype = {
35 close: function (code, reason) {
36 this.readyState = FakeWebSocket.CLOSED;
37 if (this.onclose) {
38 this.onclose(make_event("close", { 'code': code, 'reason': reason, 'wasClean': true }));
39 }
40 },
2cccf753 41
dfae3209
SR
42 send: function (data) {
43 if (this.protocol == 'base64') {
44 data = Base64.decode(data);
45 } else {
46 data = new Uint8Array(data);
47 }
48 this._send_queue.set(data, this.bufferedAmount);
49 this.bufferedAmount += data.length;
50 },
2cccf753 51
dfae3209 52 _get_sent_data: function () {
2b5f94fa 53 const res = new Uint8Array(this._send_queue.buffer, 0, this.bufferedAmount);
dfae3209
SR
54 this.bufferedAmount = 0;
55 return res;
56 },
2cccf753 57
dfae3209
SR
58 _open: function (data) {
59 this.readyState = FakeWebSocket.OPEN;
60 if (this.onopen) {
61 this.onopen(make_event('open'));
2cccf753 62 }
dfae3209 63 },
2cccf753 64
dfae3209
SR
65 _receive_data: function (data) {
66 this.onmessage(make_event("message", { 'data': data }));
67 }
68};
2cccf753 69
dfae3209
SR
70FakeWebSocket.OPEN = WebSocket.OPEN;
71FakeWebSocket.CONNECTING = WebSocket.CONNECTING;
72FakeWebSocket.CLOSING = WebSocket.CLOSING;
73FakeWebSocket.CLOSED = WebSocket.CLOSED;
2cccf753 74
dfae3209 75FakeWebSocket.__is_fake = true;
2cccf753 76
dfae3209
SR
77FakeWebSocket.replace = function () {
78 if (!WebSocket.__is_fake) {
2b5f94fa 79 const real_version = WebSocket;
8727f598 80 // eslint-disable-next-line no-global-assign
dfae3209
SR
81 WebSocket = FakeWebSocket;
82 FakeWebSocket.__real_version = real_version;
83 }
84};
85
86FakeWebSocket.restore = function () {
87 if (WebSocket.__is_fake) {
8727f598 88 // eslint-disable-next-line no-global-assign
dfae3209
SR
89 WebSocket = WebSocket.__real_version;
90 }
91};