syndicate-lang
/
syndicate-js
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Handle browser-based WebSockets yielding Blob instances

This commit is contained in:
Tony Garnock-Jones 2018-11-19 22:20:58 +00:00
parent ae5096fae2
commit 7267503337
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
packages/driver-websocket/src/index.js
View File

@ -45,14 +45,24 @@ spawn named 'WebSocketFactory' {
ws = new _WebSocket(url, options); ws = new _WebSocket(url, options);
ws.onerror = Dataspace.wrapExternal((e) => { ws.onerror = Dataspace.wrapExternal((e) => {
console.error('WebSocket', id, url, e.message); console.error('WebSocket', id, url, e);
disconnect(); disconnect();
sleep(1000, connect); sleep(1000, connect);
}); });
ws.onopen = Dataspace.wrapExternal(() => { this.connected = true; }); ws.onopen = Dataspace.wrapExternal(() => { this.connected = true; });
ws.onclose = Dataspace.wrapExternal(() => { if (this.connected) { connect(); }}); ws.onclose = Dataspace.wrapExternal(() => { if (this.connected) { connect(); }});
ws.onmessage = Dataspace.wrapExternal((data) => { send DataIn(id, Bytes.fromIO(data.data)) }); ws.onmessage = Dataspace.wrapExternal((data) => {
if (typeof Blob !== 'undefined' && data.data instanceof Blob) {
var reader = new FileReader();
reader.addEventListener("loadend", Dataspace.wrapExternal(() => {
send DataIn(id, Bytes.from(reader.result));
}));
reader.readAsArrayBuffer(data.data);
} else {
send DataIn(id, Bytes.fromIO(data.data));
}
});
}; };
const disconnect = () => { const disconnect = () => {