Function ReactiveWebSocket

web-src/src/common/connections/rxWebsocket.js:14–105

(path, observer)

let i = 0;

export function ReactiveWebSocket(path, observer) {
    if (/^((https?)|(wss?)):\/\//.test(path)) {
        this.url = path;
    } else {
        this.url = getWebsocketUrl(path);
    }

    var self = this;

    this._finished = false;
    this._observer = observer;
    this._id = i++;
    this.queuedMessages = []

    try {
        this._websocket = new WebSocket(this.url);
    } catch (e) {
        if (this._observer.onError) {
            this._observer.onError(e);
        }
        return;
    }

    this._websocket.addEventListener('open', () => {
        for (const queuedMessage of this.queuedMessages) {
            this._websocket.send(queuedMessage);
        }
    })

    this._websocket.addEventListener('close', function (event) {
        if (self._finished) {
            return;
        }

        self._finished = true;

        if (event.code === 1000) {
            self._observer.onCompleted();
            return;
        }

        if (event.code === 403) {
            self._observer.onError(new HttpForbiddenError(event.code, event.reason));
            return;
        }

        if (event.code === 401) {
            self._observer.onError(new HttpUnauthorizedError(event.code, event.reason));
            return;
        }

        if (event.code === 404) {
            self._observer.onError(new HttpRequestError(event.code, event.reason));
            return;
        }

        if (self._observer.onError) {
            self._observer.onError(new SocketClosedError(event.code, event.reason));