W260426/14.webpack/node_modules/webpack-dev-server/dist/servers/WebsocketServer.js

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.default = void 0;
var _ws = require("ws");
var _BaseServer = _interopRequireDefault(require("./BaseServer.js"));
function _interopRequireDefault(e) { return e && e.__esModule ? e : { default: e }; }
/** @typedef {import("../Server.js").WebSocketServerConfiguration} WebSocketServerConfiguration */
/** @typedef {import("../Server.js").ClientConnection} ClientConnection */

class WebsocketServer extends _BaseServer.default {
  static heartbeatInterval = 1000;

  /**
   * @param {import("../Server.js").default} server server
   */
  constructor(server) {
    super(server);

    /** @type {import("ws").ServerOptions} */
    const options = {
      ... /** @type {WebSocketServerConfiguration} */
      this.server.options.webSocketServer.options,
      clientTracking: false
    };
    const isNoServerMode = typeof options.port === "undefined" && typeof options.server === "undefined";
    if (isNoServerMode) {
      options.noServer = true;
    }
    this.implementation = new _ws.WebSocketServer(options);

    /** @type {import("http").Server} */
    this.server.server.on("upgrade",
    /**
     * @param {import("http").IncomingMessage} req request
     * @param {import("stream").Duplex} sock socket
     * @param {Buffer} head head
     */
    (req, sock, head) => {
      if (!this.implementation.shouldHandle(req)) {
        return;
      }
      this.implementation.handleUpgrade(req, sock, head, connection => {
        this.implementation.emit("connection", connection, req);
      });
    });
    this.implementation.on("error",
    /**
     * @param {Error} err error
     */
    err => {
      this.server.logger.error(err.message);
    });
    const interval = setInterval(() => {
      for (const client of this.clients) {
        if (client.isAlive === false) {
          client.terminate();
          continue;
        }
        client.isAlive = false;
        client.ping(() => {});
      }
    }, WebsocketServer.heartbeatInterval);
    this.implementation.on("connection",
    /**
     * @param {ClientConnection} client client
     */
    client => {
      this.clients.push(client);
      client.isAlive = true;
      client.on("pong", () => {
        client.isAlive = true;
      });
      client.on("close", () => {
        this.clients.splice(this.clients.indexOf(client), 1);
      });

      // TODO: add a test case for this - https://github.com/webpack/webpack-dev-server/issues/5018
      client.on("error",
      /**
       * @param {Error} err err
       */
      err => {
        this.server.logger.error(err.message);
      });
    });
    this.implementation.on("close", () => {
      clearInterval(interval);
    });
  }
}
exports.default = WebsocketServer;