Function connectWebSocket

frontend/src/react/components/monaco/lsp-client.ts:130–194

()

};

const connectWebSocket = () => {
  if (conn.ws) {
    return conn.ws;
  }

  const connect = (
    resolve: (value: WebSocket | PromiseLike<WebSocket>) => void,
    reject: (reason?: unknown) => void
  ) => {
    const ws = new WebSocket(conn.url);
    const retries = conn.retries++;
    emit();

    switch (conn.state) {
      case "closed":
        reject("Connection is closed");
        return;
      case "ready":
      case "reconnecting":
        setConnState({ state: "reconnecting" });
        break;
      case "initial":
        break;
    }

    sleep(progressiveDelay(retries)).then(() => {
      const handleError = (code: number, reason: string) => {
        if (conn.state === "closed" || conn.state === "ready") {
          return;
        }
        if (conn.retries >= MAX_RETRIES) {
          setConnState({ state: "closed" });
          reject(
            `${messages.disconnected()}: max retries exceeded (${MAX_RETRIES}). code=${code} reason="${reason}"`
          );
          return;
        }
        connect(resolve, reject);
      };

      const timer = setTimeout(() => {
        handleError(-1, "timeout");
      }, WEBSOCKET_TIMEOUT);

      ws.addEventListener("open", () => {
        clearTimeout(timer);
        if (conn.state === "ready" || conn.state === "closed") {
          return;
        }
        setConnState({ state: "ready", retries: 0 });
        useHeartbeat(ws);
        resolve(ws);
      });

      ws.addEventListener("close", (event) => {
        clearTimeout(timer);
        handleError(event.code, event.reason);
      });