hashirama/reanimate
Watch
1
0
Fork
You've already forked reanimate
 0
mirror of https://github.com/reanimate/reanimate.git synced 2026-09-14 09:32:22 +00:00
Code Issues Projects Releases Wiki Activity

Deploying to gh-pages from @ a634e4ad87 🚀

Browse source
This commit is contained in:
Lemmih 2020-09-20 01:42:24 +00:00
commit ff0c555ad9
2 changed files with 67 additions and 38 deletions
Download patch file Download diff file Expand all files Collapse all files

103
playground/playground.js
View file

@ -1,5 +1,22 @@
const backend = "149.56.132.163";
var lastConnect;
function scheduleConnect(cb) {
let minDelay = 2000;
if( lastConnect === undefined ) {
console.log('Connecting immediately');
lastConnect = new Date().getTime();
cb();
} else {
let now = new Date().getTime();
let target = Math.max(now, lastConnect + minDelay);
console.log('Connecting in', target-now);
lastConnect = target;
setTimeout(cb, target-now);
}
}
function playgroundInit(elt) {
var mySockets = {};
var frames = {};
@ -7,45 +24,57 @@ function playgroundInit(elt) {
function sendSocketCommand(wat) {
if (wat.cmd == "connect") {
socket = new WebSocket(wat.address);
socket.onopen = function (event) {
socket.send(lastScript);
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: "connection established"
});
}
socket.onmessage = function (event) {
const lines = event.data.split('\n');
const cmd = lines[0];
if( cmd === "frame_count" ) {
frames = {};
} else if ( cmd === "frame") {
// Prefetch image.
const nth = parseInt(lines[1]);
const url = lines[2];
frames[nth] = new Image();
frames[nth].src = "https://reanimate.clozecards.com/"+url;
scheduleConnect(function () {
socket = new WebSocket(wat.address);
socket.onopen = function (event) {
if( socket.readyState !== 1 ) {
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: "connection failed"
});
return;
}
console.log('onopen', socket, mySockets);
socket.send(lastScript);
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: "connection established"
});
}
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: event.data
});
}
connectionFailedHandler = function (event) {
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: "connection failed"
});
}
socket.onerror = connectionFailedHandler;
socket.onclose = connectionFailedHandler;
mySockets[wat.name] = socket;
socket.onmessage = function (event) {
const lines = event.data.split('\n');
const cmd = lines[0];
if( cmd === "frame_count" ) {
frames = {};
} else if ( cmd === "frame") {
// Prefetch image.
const nth = parseInt(lines[1]);
const url = lines[2];
frames[nth] = new Image();
frames[nth].src = "https://reanimate.clozecards.com/"+url;
}
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: event.data
});
}
connectionFailedHandler = function (event) {
app.ports.receiveSocketMsg.send({
name: wat.name,
msg: "data",
data: "connection failed"
});
}
socket.onerror = connectionFailedHandler;
socket.onclose = connectionFailedHandler;
mySockets[wat.name] = socket;
console.log('mySockets set');
});
} else if (wat.cmd == "send") {
if( mySockets[wat.name].readyState === mySockets[wat.name].OPEN ) {
if( mySockets[wat.name] && mySockets[wat.name].readyState === mySockets[wat.name].OPEN ) {
mySockets[wat.name].send(wat.content);
}
} else if (wat.cmd == "close") {