60 lines
No EOL
2 KiB
TypeScript
60 lines
No EOL
2 KiB
TypeScript
import util from "./util"
|
|
import {AdapterState, AdapterData} from "./adapter";
|
|
import {Message, Attachment, Author} from "./message"
|
|
|
|
var $ = util.$
|
|
var _ = util._
|
|
|
|
function connect() {
|
|
|
|
let datastore = <AdapterState>_("datastore", {});
|
|
|
|
const wsProto = location.protocol == "https:" ? "wss" : "ws";
|
|
const _conn = new WebSocket(`${wsProto}://${location.host}/subscribe`, "underbbs");
|
|
_conn.addEventListener("open", (e: any) => {
|
|
console.log("websocket connection opened");
|
|
console.log(JSON.stringify(e));
|
|
});
|
|
_conn.addEventListener("message", (e: any) => {
|
|
const data = JSON.parse(e.data);
|
|
console.log(data);
|
|
if (data.key) {
|
|
_("skey", data.key)
|
|
util.authorizedFetch("POST", "/api/adapters", JSON.stringify(_("settings").adapters))
|
|
} else {
|
|
if (!datastore[data.adapter]) {
|
|
datastore[data.adapter] = new AdapterData(data.protocol);
|
|
}
|
|
|
|
// typeswitch on the incoming data type and fill the memory
|
|
switch (data.type) {
|
|
case "message":
|
|
datastore[data.adapter].messages.set(data.id, <Message>data);
|
|
break;
|
|
case "author":
|
|
datastore[data.adapter].profileCache.set(data.id, <Author>data);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
// if the adapter is active, inject the web components
|
|
let adapter = $(`adapter_${data.adapter}`);
|
|
if (adapter) {
|
|
adapter.setAttribute("data-latest", data.id);
|
|
}
|
|
// FOR HOTFETCHED DATA:
|
|
// before fetching, we can set properties on the DOM,
|
|
// so when those data return to us we know where to inject components!
|
|
if (_("currentAdapter") == data.adapter) {
|
|
// dive in and insert that shit in the dom
|
|
}
|
|
}
|
|
});
|
|
_conn.addEventListener("error", (e: any) => {
|
|
console.log("websocket connection error");
|
|
console.log(JSON.stringify(e));
|
|
});
|
|
_("websocket", _conn);
|
|
}
|
|
|
|
export default { connect } |