Function serverConnect

client/src/components/websocketPanel/WebsocketHandler.tsx:86–143

(request: CurrentWebsocketRequest)

  }

  async function serverConnect(request: CurrentWebsocketRequest): Promise<string> {
    return new Promise((resolve, reject) => {
      try {
        const websocket = new WebSocket('/api/ws');
        websocket.onopen = () => {
          sendMessageToWebsocket(websocket, currentRequest.id, {
            type: 'ws-connect',
            request,
          })
            .then((msg: any) => {
              if (msg.status === 'error') {
                reject(msg.err);
              } else {
                ws.current = websocket;
                resolve(msg.wsId);
              }
            })
            .catch(reject);
        };
        websocket.onmessage = (event) => {
          const msg = JSON.parse(event.data);
          if (!msg) {
            console.error('server message', msg);
            return;
          }
          if (msg.type === 'ws-read') {
            if (!msg || msg?.type !== 'ws-read' || msg.result?.wsId !== wsId.current) {
              return;
            }
            dispatchCurrentRequest({
              type: CurrentRequestActionType.ADD_WEBSOCKET_RESPONSE_MESSAGE,
              message: {
                message: msg.result.message,
                date: Date.now(),
                type: 'incoming',
              },
            });
          } else if (msg.type === 'ws-error') {
            ws.current?.close();
            wsId.current = null;
            setConnectionStatus('disconnected');
            errorToast('WebSocket error: ' + msg.result.error, toast);
          } else if (msg.type === 'ws-close') {
            ws.current?.close();
            wsId.current = null;
            setConnectionStatus('disconnected');
            errorToast('WebSocket closed unexpectedly', toast);
          }
        };
        websocket.onerror = (err) => {
          ws.current?.close();
          reject(err);
        };
      } catch (err) {
        reject(err);
      }
    });
  }