xapi-inspector/utils.mjs

import { PassThrough } from "stream";
import { request as httpsRequest } from "https";

// ===================================================================

export const createReadableCopies = (n, readable) => {
  return Array.from({ length: n }, () => readable.pipe(new PassThrough()));
};

// -------------------------------------------------------------------

export const fromCallback = (fn) =>
  new Promise((resolve, reject) => {
    fn((error, result) => (error ? reject(error) : resolve(result)));
  });

// -------------------------------------------------------------------

export const proxyHttpsRequest = (
  { headers, hostname, method, url, port },
  inputReq
) =>
  new Promise((resolve, reject) => {
    const req = httpsRequest(
      {
        headers: headers || inputReq.headers,
        hostname,
        method: method || inputReq.method,
        path: url || inputReq.url,
        port,
        rejectUnauthorized: false,
      },
      resolve
    ).on("error", reject);
    inputReq.pipe(req);
  });

// -------------------------------------------------------------------

const _isPort = (value) =>
  typeof value === "number" &&
  value >= 0 &&
  value <= 65534 &&
  Math.floor(value) === value;

// splitHost('localhost:80') => { hostname: 'localhost', port: 80 }
// splitHost('localhost') => { hostname: 'localhost' }
// splitHost('80') => { port: 80 }
export const splitHost = (host) => {
  host = String(host);
  const i = host.lastIndexOf(":");

  if (i === -1) {
    const port = +host;
    return _isPort(port) ? { port } : { hostname: host };
  }

  const port = +host.slice(i + 1);
  return _isPort(port)
    ? {
        hostname: host.slice(0, i),
        port,
      }
    : { hostname: host };
};