lbry.tech/app/dist/scripts/sockets.js
ポール ウェッブ 2182428e2c Trying to fix this
2019-02-21 13:28:09 -06:00

129 lines
4.1 KiB
JavaScript

"use strict"; /* global document, location, WebSocket, window */
document.addEventListener("DOMContentLoaded", () => {
initializeWebSocketConnection();
setInterval(checkWebSocketConnection, 5000);
});
let ws = null;
function checkWebSocketConnection() {
if (!ws || ws.readyState === 3)
initializeWebSocketConnection();
}
function initializeWebSocketConnection() {
ws = new WebSocket(location.origin.replace(/^http/, "ws"));
// ws.onopen = () => console.log("WebSocket connection established"); // eslint-disable-line no-console
ws.onmessage = socket => {
let data = JSON.parse(socket.data);
switch(true) {
case data.message === "github token status":
data = data.data;
syncWithApi(data); // eslint-disable-line no-undef
break;
case data.message === "notification": // TODO: Make work with appending so multiple notifications can be sent
document.getElementById("flash-container").innerHTML =
`<div class="flash active${data.type ? " " + data.type : ""}">${data.details}</div>`;
setTimeout(() => {
document.getElementById("flash-container").innerHTML = "";
}, 2100);
break;
case data.message === "redirect":
window.location.href = data.url;
break;
case data.message === "show result":
if (!data.example)
return;
document.querySelector(data.selector).innerHTML = data.html;
if (!document.querySelector(`[data-example="${data.example}"`).classList.contains("completed"))
document.getElementById("playground-example-description").classList.remove("success");
document.querySelector(`[data-example="${data.example}"`).classList.add("completed");
document.getElementById("playground-example-description").classList.add("success");
document.getElementById("playground-example-description").innerHTML =
document.querySelector(`[data-example="${data.example}"`).dataset.success;
if (document.getElementById("temp-loader"))
document.getElementById("temp-loader").style.display = "none";
if (document.querySelector(".playground"))
document.querySelector(".playground").classList.remove("waiting");
break;
case data.message === "updated html":
document.querySelector(data.selector).innerHTML = data.html;
if (data.class)
document.querySelector(data.selector).classList.add(data.class);
if (data.selector !== "#emailMessage") {
document.getElementById("emailAddress").value = "";
document.getElementById("emailMessage").innerHTML = "";
}
if (data.example === 2) {
detectLanguageAndUpdate(); // eslint-disable-line no-undef
initCanvas(); // eslint-disable-line no-undef
setTimeout(() => {
document.querySelector(".playground-content__meme__canvas__thumbnail").click();
}, 500);
}
if (document.getElementById("playground-example-description")) {
document.getElementById("playground-example-description").classList.remove("success");
document.getElementById("playground-example-description").innerHTML =
document.querySelector(".playground-navigation__example.active").dataset.description;
}
if (document.getElementById("temp-loader"))
document.getElementById("temp-loader").style.display = "none";
if (document.querySelector(".playground"))
document.querySelector(".playground").classList.remove("waiting");
break;
default:
console.log(data); // eslint-disable-line no-console
break;
}
};
ws.onclose = () => checkWebSocketConnection(); // reconnect now
}
function send(msg) { // eslint-disable-line no-unused-vars
socketReady(ws, () => ws.send(JSON.stringify(msg)));
}
function socketReady(socket, callback) {
setTimeout(() => {
if (socket && socket.readyState === 1) {
if (callback !== undefined)
callback();
return;
}
return socketReady(socket, callback);
}, 5);
}