MJPEGServer.js

Filename	Percent	Threshold	Total	Covered	Uncovered
test/utils/MJPEGServer.js	97.06%	80%	102	99	3

// @ts-check
// SPDX-License-Identifier: Zlib
// SPDX-FileCopyrightText: 2024 CERN (home.cern)

import express from "express";
import { makeDeferred } from "@cern/nodash";

import MJPEGStreamer from "./MJPEGStreamer.js";

/**
 * @typedef {import('net').AddressInfo} AddressInfo
 * @typedef {{ [name: string]: {
 *    auth?: { user: string, password: string }
 *    path: string
 * } }} Config
 */

class MJPEGServer {
  /**
   * @param {Config} config
   * @param {number} [port]
   */
  constructor(config, port) {
    this.port = port ?? 0;
    this.config = config;
    this.app = express();

    /** @type {{[name: string]: MJPEGStreamer}} */
    this.streamers = Object.entries(config).reduce(
      (ret, [ key, cam ]) => {
        const s = new MJPEGStreamer({ auth: cam.auth, path: cam.path });
        s.register(this.app);
        ret[key] = s;
        return ret;
      }, {});

    this.app.get("/plain-text", (req, res, next) => {
      req.on("error", next);

      res
      .status(200)
      .set("Content-Type", "text/plain")
      .send("TEST");
    });
  }

  close() {
    Object.values(this.streamers ?? {}).forEach((s) => {
      s.release();
    });

    if (this.server) {
      this.server.close();
      this.server = null;
    }
  }

  /**
   * @return {Promise<void>}
   */
  listen() {
    const def = makeDeferred();
    var server = this.app.listen(this.port, () => {
      this.server = server;
      const port =
        this.port || /** @type {AddressInfo} */(server.address()).port;
      console.log(`MJPEG Server Stub listening on http://localhost:${port}`);
      def.resolve(undefined);
    });
    return def.promise;
  }

  /**
   * @return {AddressInfo | string | null}
   */
  address() {
    if (this.server) {
      return this.server.address();
    }
    return null;
  }
}

export default MJPEGServer;

[{"file":"test/utils/MJPEGServer.js","line":23,"character":9,"text":"port","kind":1},{"file":"test/utils/MJPEGServer.js","line":24,"character":9,"text":"config","kind":1},{"file":"test/utils/MJPEGServer.js","line":25,"character":9,"text":"app","kind":1}]

TypeScript Coverage Report generated by type-coverage and typescript-coverage-report at Sun, 30 Jun 2024 01:34:16 GMT

TypeScript coverage report