Method #connect

packages/client/lib/client/socket.ts:244–294

()

  }

  async #connect(): Promise<void> {
    let retries = 0;
    do {
      try {
        const connectStartTime = performance.now();
        this.#socket = await this.#createSocket();
        this.emit('connect');

        try {
          await this.#initiator();

          // Check if socket was closed/destroyed during initiator execution
          if (!this.#socket || this.#socket.destroyed || !this.#socket.readable || !this.#socket.writable) {
            const retryIn = this.#shouldReconnect(retries++, new SocketClosedUnexpectedlyError());
            if (typeof retryIn !== 'number') { throw retryIn; }
            await setTimeout(retryIn);
            this.emit('reconnecting');
            continue;
          }
        } catch (err) {
          this.#socket.destroy();
          this.#socket = undefined;
          throw err;
        }
        this.#isReady = true;
        this.#socketEpoch++;
        publish(CHANNELS.CONNECTION_READY, () => ({
          clientId: this.#clientId,
          serverAddress: this.host,
          serverPort: this.port,
          createTimeMs: performance.now() - connectStartTime,
        }));
        this.emit('ready');
      } catch (err) {
        const retryIn = this.#shouldReconnect(retries++, err as Error);
        if (typeof retryIn !== 'number') {
          throw retryIn;
        }

        publish(CHANNELS.ERROR, () => ({
          error: err as Error,
          origin: 'client',
          internal: false,
          clientId: this.#clientId
        }));
        this.emit('error', err);
        await setTimeout(retryIn);
        this.emit('reconnecting');
      }
    } while (this.#isOpen && !this.#isReady);
  }

  setMaintenanceTimeout(ms?: number) {
    dbgMaintenance(`Set socket timeout to ${ms}`);