frontend/src/notifications.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

import log from "./log";
import dispatcher from "./dispatcher";

class Notifications {

    constructor() {
        const location = document.location;
        this.wsUrl = `ws://${location.hostname}${location.port ? ":" + location.port : ""}/ws`;
    }

    createWebsocket = () => {
        this.ws = new WebSocket(this.wsUrl);
        this.ws.onopen = this.onWebsocketOpen;
        this.ws.onerror = this.onWebsocketError;
        this.ws.onclose = this.onWebsocketClose;
        this.ws.onmessage = this.onWebsocketMessage;
    };

    onWebsocketOpen = () => {
        log.debug("Connected to backend with websocket");
    };

    onWebsocketError = (err) => {
        this.ws.close();
        log.error("Websocket error", err);
        setTimeout(() => this.createWebsocket(), 3000);
    };

    onWebsocketClose = () => {
        log.debug("Closed websocket connection with backend");
    };

    onWebsocketMessage = (message) => {
        dispatcher.dispatch("notifications", JSON.parse(message.data));
    };
}

const notifications = new Notifications();

export default notifications;