100 lines
2.5 KiB
JavaScript
100 lines
2.5 KiB
JavaScript
async function setupApp() {
|
|
Vue.filter('plural', pluralize);
|
|
|
|
window.app = new Vue({
|
|
el: "#app-container",
|
|
data: {
|
|
streamStatus: "Stream is offline.", // Default state.
|
|
viewerCount: 0,
|
|
sessionMaxViewerCount: 0,
|
|
overallMaxViewerCount: 0,
|
|
messages: [],
|
|
description: "",
|
|
title: "",
|
|
isOnline: false,
|
|
socialHandles: [],
|
|
},
|
|
watch: {
|
|
messages: {
|
|
deep: true,
|
|
handler: function (newMessages, oldMessages) {
|
|
if (newMessages.length !== oldMessages.length) {
|
|
// jump to bottom
|
|
jumpToBottom(appMessaging.scrollableMessagesContainer);
|
|
}
|
|
},
|
|
},
|
|
},
|
|
});
|
|
|
|
|
|
// init messaging interactions
|
|
var appMessaging = new Messaging();
|
|
appMessaging.init();
|
|
|
|
const config = await new Config().init();
|
|
app.title = config.title;
|
|
app.socialHandles = config.socialHandles;
|
|
|
|
// const configFileLocation = "../js/config.json";
|
|
|
|
try {
|
|
const pageContentFile = "../static/content.md"
|
|
const response = await fetch(pageContentFile);
|
|
const descriptionMarkdown = await response.text()
|
|
const descriptionHTML = new showdown.Converter().makeHtml(descriptionMarkdown);
|
|
app.description = descriptionHTML;
|
|
return this;
|
|
} catch (error) {
|
|
console.log(error);
|
|
}
|
|
}
|
|
|
|
var websocketReconnectTimer;
|
|
function setupWebsocket() {
|
|
clearTimeout(websocketReconnectTimer);
|
|
|
|
// Uncomment to point to somewhere other than goth.land
|
|
const protocol = location.protocol == "https:" ? "wss" : "ws"
|
|
// var ws = new WebSocket(protocol + "://" + location.host + "/entry")
|
|
|
|
var ws = new WebSocket("wss://goth.land/entry")
|
|
|
|
ws.onmessage = (e) => {
|
|
const model = JSON.parse(e.data)
|
|
|
|
// Ignore non-chat messages (such as keepalive PINGs)
|
|
if (model.type !== SocketMessageTypes.CHAT) { return; }
|
|
|
|
const message = new Message(model);
|
|
|
|
const existing = this.app.messages.filter(function (item) {
|
|
return item.id === message.id;
|
|
})
|
|
|
|
if (existing.length === 0 || !existing) {
|
|
this.app.messages = [...this.app.messages, message];
|
|
}
|
|
}
|
|
|
|
ws.onclose = (e) => {
|
|
// connection closed, discard old websocket and create a new one in 5s
|
|
ws = null;
|
|
console.log("Websocket closed.")
|
|
websocketReconnectTimer = setTimeout(setupWebsocket, 5000);
|
|
}
|
|
|
|
// On ws error just close the socket and let it re-connect again for now.
|
|
ws.onerror = (e) => {
|
|
console.log("Websocket error: ", e);
|
|
ws.close();
|
|
}
|
|
|
|
window.ws = ws;
|
|
}
|
|
|
|
setupApp();
|
|
|
|
setupWebsocket();
|
|
|