Method close

packages/core/src/server/socketServer.ts:337–368

()

  }

  public async close(): Promise<void> {
    this.clearHeartbeatTimer();

    // Remove all event listeners
    this.wsServer.removeAllListeners();

    // Close all client sockets
    for (const socket of this.wsServer.clients) {
      socket.terminate();
    }
    // Close all tracked sockets
    for (const sockets of this.socketsMap.values()) {
      sockets.forEach((socket) => {
        socket.close();
      });
    }

    // Reset all properties
    this.socketsMap.clear();
    this.initialChunksMap.clear();
    this.reportedBrowserLogs.clear();

    return new Promise<void>((resolve, reject) => {
      this.wsServer.close((err) => {
        if (err) {
          reject(err);
        } else {
          resolve();
        }
      });
    });
  }

  private onConnect(socket: ExtWebSocket, token: string) {
    socket.isAlive = true;