mirror of
https://github.com/Relintai/pandemonium_engine.git
synced 2025-01-30 21:09:19 +01:00
Re-format file.
This commit is contained in:
parent
8198a3eafe
commit
a4e1126d45
@ -29,173 +29,173 @@
|
||||
/*************************************************************************/
|
||||
|
||||
const PandemoniumWebSocket = {
|
||||
// Our socket implementation that forwards events to C++.
|
||||
$PandemoniumWebSocket__deps: ['$IDHandler', '$PandemoniumRuntime'],
|
||||
$PandemoniumWebSocket: {
|
||||
// Connection opened, report selected protocol
|
||||
_onopen: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
const c_str = PandemoniumRuntime.allocString(ref.protocol);
|
||||
callback(c_str);
|
||||
PandemoniumRuntime.free(c_str);
|
||||
},
|
||||
|
||||
// Message received, report content and type (UTF8 vs binary)
|
||||
_onmessage: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
let buffer;
|
||||
let is_string = 0;
|
||||
if (event.data instanceof ArrayBuffer) {
|
||||
buffer = new Uint8Array(event.data);
|
||||
} else if (event.data instanceof Blob) {
|
||||
PandemoniumRuntime.error('Blob type not supported');
|
||||
return;
|
||||
} else if (typeof event.data === 'string') {
|
||||
is_string = 1;
|
||||
const enc = new TextEncoder('utf-8');
|
||||
buffer = new Uint8Array(enc.encode(event.data));
|
||||
} else {
|
||||
PandemoniumRuntime.error('Unknown message type');
|
||||
return;
|
||||
}
|
||||
const len = buffer.length * buffer.BYTES_PER_ELEMENT;
|
||||
const out = PandemoniumRuntime.malloc(len);
|
||||
HEAPU8.set(buffer, out);
|
||||
callback(out, len, is_string);
|
||||
PandemoniumRuntime.free(out);
|
||||
},
|
||||
|
||||
// An error happened, 'onclose' will be called after this.
|
||||
_onerror: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
callback();
|
||||
},
|
||||
|
||||
// Connection is closed, this is always fired. Report close code, reason, and clean status.
|
||||
_onclose: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
const c_str = PandemoniumRuntime.allocString(event.reason);
|
||||
callback(event.code, c_str, event.wasClean ? 1 : 0);
|
||||
PandemoniumRuntime.free(c_str);
|
||||
},
|
||||
|
||||
// Send a message
|
||||
send: function(p_id, p_data) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref || ref.readyState !== ref.OPEN) {
|
||||
return 1; // Pandemonium object is gone or socket is not in a ready state.
|
||||
}
|
||||
ref.send(p_data);
|
||||
return 0;
|
||||
},
|
||||
|
||||
// Get current bufferedAmount
|
||||
bufferedAmount: function(p_id) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return 0; // Pandemonium object is gone.
|
||||
}
|
||||
return ref.bufferedAmount;
|
||||
},
|
||||
|
||||
create: function(socket, p_on_open, p_on_message, p_on_error, p_on_close) {
|
||||
const id = IDHandler.add(socket);
|
||||
socket.onopen = PandemoniumWebSocket._onopen.bind(null, id, p_on_open);
|
||||
socket.onmessage = PandemoniumWebSocket._onmessage.bind(null, id, p_on_message);
|
||||
socket.onerror = PandemoniumWebSocket._onerror.bind(null, id, p_on_error);
|
||||
socket.onclose = PandemoniumWebSocket._onclose.bind(null, id, p_on_close);
|
||||
return id;
|
||||
},
|
||||
|
||||
// Closes the JavaScript WebSocket (if not already closing) associated to a given C++ object.
|
||||
close: function(p_id, p_code, p_reason) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (ref && ref.readyState < ref.CLOSING) {
|
||||
const code = p_code;
|
||||
const reason = PandemoniumRuntime.parseString(p_reason);
|
||||
ref.close(code, reason);
|
||||
}
|
||||
},
|
||||
|
||||
// Deletes the reference to a C++ object (closing any connected socket if necessary).
|
||||
destroy: function(p_id) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return;
|
||||
}
|
||||
PandemoniumWebSocket.close(p_id, 1001, '');
|
||||
IDHandler.remove(p_id);
|
||||
ref.onopen = null;
|
||||
ref.onmessage = null;
|
||||
ref.onerror = null;
|
||||
ref.onclose = null;
|
||||
},
|
||||
// Our socket implementation that forwards events to C++.
|
||||
$PandemoniumWebSocket__deps: ['$IDHandler', '$PandemoniumRuntime'],
|
||||
$PandemoniumWebSocket: {
|
||||
// Connection opened, report selected protocol
|
||||
_onopen: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
const c_str = PandemoniumRuntime.allocString(ref.protocol);
|
||||
callback(c_str);
|
||||
PandemoniumRuntime.free(c_str);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_create__sig: 'iiiiiiii',
|
||||
pandemonium_js_websocket_create: function(p_ref, p_url, p_proto, p_on_open, p_on_message, p_on_error, p_on_close) {
|
||||
const on_open = PandemoniumRuntime.get_func(p_on_open).bind(null, p_ref);
|
||||
const on_message = PandemoniumRuntime.get_func(p_on_message).bind(null, p_ref);
|
||||
const on_error = PandemoniumRuntime.get_func(p_on_error).bind(null, p_ref);
|
||||
const on_close = PandemoniumRuntime.get_func(p_on_close).bind(null, p_ref);
|
||||
const url = PandemoniumRuntime.parseString(p_url);
|
||||
const protos = PandemoniumRuntime.parseString(p_proto);
|
||||
let socket = null;
|
||||
try {
|
||||
if (protos) {
|
||||
socket = new WebSocket(url, protos.split(','));
|
||||
} else {
|
||||
socket = new WebSocket(url);
|
||||
}
|
||||
} catch (e) {
|
||||
return 0;
|
||||
}
|
||||
socket.binaryType = 'arraybuffer';
|
||||
return PandemoniumWebSocket.create(socket, on_open, on_message, on_error, on_close);
|
||||
// Message received, report content and type (UTF8 vs binary)
|
||||
_onmessage: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
let buffer;
|
||||
let is_string = 0;
|
||||
if (event.data instanceof ArrayBuffer) {
|
||||
buffer = new Uint8Array(event.data);
|
||||
} else if (event.data instanceof Blob) {
|
||||
PandemoniumRuntime.error('Blob type not supported');
|
||||
return;
|
||||
} else if (typeof event.data === 'string') {
|
||||
is_string = 1;
|
||||
const enc = new TextEncoder('utf-8');
|
||||
buffer = new Uint8Array(enc.encode(event.data));
|
||||
} else {
|
||||
PandemoniumRuntime.error('Unknown message type');
|
||||
return;
|
||||
}
|
||||
const len = buffer.length * buffer.BYTES_PER_ELEMENT;
|
||||
const out = PandemoniumRuntime.malloc(len);
|
||||
HEAPU8.set(buffer, out);
|
||||
callback(out, len, is_string);
|
||||
PandemoniumRuntime.free(out);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_send__sig: 'iiiii',
|
||||
pandemonium_js_websocket_send: function(p_id, p_buf, p_buf_len, p_raw) {
|
||||
const bytes_array = new Uint8Array(p_buf_len);
|
||||
let i = 0;
|
||||
for (i = 0; i < p_buf_len; i++) {
|
||||
bytes_array[i] = PandemoniumRuntime.getHeapValue(p_buf + i, 'i8');
|
||||
}
|
||||
let out = bytes_array.buffer;
|
||||
if (!p_raw) {
|
||||
out = new TextDecoder('utf-8').decode(bytes_array);
|
||||
}
|
||||
return PandemoniumWebSocket.send(p_id, out);
|
||||
// An error happened, 'onclose' will be called after this.
|
||||
_onerror: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
callback();
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_buffered_amount__sig: 'ii',
|
||||
pandemonium_js_websocket_buffered_amount: function(p_id) {
|
||||
return PandemoniumWebSocket.bufferedAmount(p_id);
|
||||
// Connection is closed, this is always fired. Report close code, reason, and clean status.
|
||||
_onclose: function(p_id, callback, event) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return; // Pandemonium object is gone.
|
||||
}
|
||||
const c_str = PandemoniumRuntime.allocString(event.reason);
|
||||
callback(event.code, c_str, event.wasClean ? 1 : 0);
|
||||
PandemoniumRuntime.free(c_str);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_close__sig: 'viii',
|
||||
pandemonium_js_websocket_close: function(p_id, p_code, p_reason) {
|
||||
// Send a message
|
||||
send: function(p_id, p_data) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref || ref.readyState !== ref.OPEN) {
|
||||
return 1; // Pandemonium object is gone or socket is not in a ready state.
|
||||
}
|
||||
ref.send(p_data);
|
||||
return 0;
|
||||
},
|
||||
|
||||
// Get current bufferedAmount
|
||||
bufferedAmount: function(p_id) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return 0; // Pandemonium object is gone.
|
||||
}
|
||||
return ref.bufferedAmount;
|
||||
},
|
||||
|
||||
create: function(socket, p_on_open, p_on_message, p_on_error, p_on_close) {
|
||||
const id = IDHandler.add(socket);
|
||||
socket.onopen = PandemoniumWebSocket._onopen.bind(null, id, p_on_open);
|
||||
socket.onmessage = PandemoniumWebSocket._onmessage.bind(null, id, p_on_message);
|
||||
socket.onerror = PandemoniumWebSocket._onerror.bind(null, id, p_on_error);
|
||||
socket.onclose = PandemoniumWebSocket._onclose.bind(null, id, p_on_close);
|
||||
return id;
|
||||
},
|
||||
|
||||
// Closes the JavaScript WebSocket (if not already closing) associated to a given C++ object.
|
||||
close: function(p_id, p_code, p_reason) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (ref && ref.readyState < ref.CLOSING) {
|
||||
const code = p_code;
|
||||
const reason = PandemoniumRuntime.parseString(p_reason);
|
||||
PandemoniumWebSocket.close(p_id, code, reason);
|
||||
ref.close(code, reason);
|
||||
}
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_destroy__sig: 'vi',
|
||||
pandemonium_js_websocket_destroy: function(p_id) {
|
||||
PandemoniumWebSocket.destroy(p_id);
|
||||
// Deletes the reference to a C++ object (closing any connected socket if necessary).
|
||||
destroy: function(p_id) {
|
||||
const ref = IDHandler.get(p_id);
|
||||
if (!ref) {
|
||||
return;
|
||||
}
|
||||
PandemoniumWebSocket.close(p_id, 1001, '');
|
||||
IDHandler.remove(p_id);
|
||||
ref.onopen = null;
|
||||
ref.onmessage = null;
|
||||
ref.onerror = null;
|
||||
ref.onclose = null;
|
||||
},
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_create__sig: 'iiiiiiii',
|
||||
pandemonium_js_websocket_create: function(p_ref, p_url, p_proto, p_on_open, p_on_message, p_on_error, p_on_close) {
|
||||
const on_open = PandemoniumRuntime.get_func(p_on_open).bind(null, p_ref);
|
||||
const on_message = PandemoniumRuntime.get_func(p_on_message).bind(null, p_ref);
|
||||
const on_error = PandemoniumRuntime.get_func(p_on_error).bind(null, p_ref);
|
||||
const on_close = PandemoniumRuntime.get_func(p_on_close).bind(null, p_ref);
|
||||
const url = PandemoniumRuntime.parseString(p_url);
|
||||
const protos = PandemoniumRuntime.parseString(p_proto);
|
||||
let socket = null;
|
||||
try {
|
||||
if (protos) {
|
||||
socket = new WebSocket(url, protos.split(','));
|
||||
} else {
|
||||
socket = new WebSocket(url);
|
||||
}
|
||||
} catch (e) {
|
||||
return 0;
|
||||
}
|
||||
socket.binaryType = 'arraybuffer';
|
||||
return PandemoniumWebSocket.create(socket, on_open, on_message, on_error, on_close);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_send__sig: 'iiiii',
|
||||
pandemonium_js_websocket_send: function(p_id, p_buf, p_buf_len, p_raw) {
|
||||
const bytes_array = new Uint8Array(p_buf_len);
|
||||
let i = 0;
|
||||
for (i = 0; i < p_buf_len; i++) {
|
||||
bytes_array[i] = PandemoniumRuntime.getHeapValue(p_buf + i, 'i8');
|
||||
}
|
||||
let out = bytes_array.buffer;
|
||||
if (!p_raw) {
|
||||
out = new TextDecoder('utf-8').decode(bytes_array);
|
||||
}
|
||||
return PandemoniumWebSocket.send(p_id, out);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_buffered_amount__sig: 'ii',
|
||||
pandemonium_js_websocket_buffered_amount: function(p_id) {
|
||||
return PandemoniumWebSocket.bufferedAmount(p_id);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_close__sig: 'viii',
|
||||
pandemonium_js_websocket_close: function(p_id, p_code, p_reason) {
|
||||
const code = p_code;
|
||||
const reason = PandemoniumRuntime.parseString(p_reason);
|
||||
PandemoniumWebSocket.close(p_id, code, reason);
|
||||
},
|
||||
|
||||
pandemonium_js_websocket_destroy__sig: 'vi',
|
||||
pandemonium_js_websocket_destroy: function(p_id) {
|
||||
PandemoniumWebSocket.destroy(p_id);
|
||||
},
|
||||
};
|
||||
|
||||
autoAddDeps(PandemoniumWebSocket, '$PandemoniumWebSocket');
|
||||
|
||||
Loading…
Reference in New Issue
Block a user