Function initWebSocket

frontend/src/store/modules/process.ts:136–166

(currentNode: string)

    };

    const initWebSocket = async (currentNode: string) => {
        if (websocket || isConnecting.value) {
            return;
        }

        const token = ++initWebSocketToken;
        isConnecting.value = true;

        const href = window.location.href;
        const protocol = href.split('//')[0] === 'http:' ? 'ws' : 'wss';
        const ipLocal = href.split('//')[1].split('/')[0];

        const url = `${protocol}://${ipLocal}/api/v2/process/ws?operateNode=${currentNode}`;
        const authError = await checkStreamAuth(url, currentNode);
        if (token !== initWebSocketToken || connectionRefCount === 0) {
            if (token === initWebSocketToken) {
                isConnecting.value = false;
            }
            return;
        }
        if (authError) {
            MsgError(authError);
            isConnecting.value = false;
            return;
        }
        websocket = new WebSocket(url);
        websocket.onopen = onOpen;
        websocket.onmessage = onMessage;
        websocket.onerror = onError;
        websocket.onclose = onClose;
    };

    const closeWebSocket = () => {
        initWebSocketToken++;