123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
/** * Options for the connection to an AMQP broker. */export interface AmqpConnectOptions {  /**   * Hostname or literal IP-address to the AMQP broker. Defaults to 'localhost'.   */  hostname?: string;
  /**   * TCP port of the AMQP broker. Defaults to 5672.   */  port?: number;
  /**   * Username for authenticating towards the AMQP broker. Defaults to 'guest'.   */  username?: string;
  /**   * Password for authenticating towards the AMQP broker. Defaults to 'guest'.   */  password?: string;
  /**   * AMQP virtual host. Defaults to "/"   */  vhost?: string;
  /**   * Interval in seconds for the AMQP heartbeat frames. If not provided, the suggested heartbeat interval from   * the AMQP broker will be used (usually 60s).   *   * If explicitly set to 0, heartbeat frames will be disabled.   */  heartbeatInterval?: number;
  /**   * Sets the maximum frame size in number of bytes.   *   * This is negotiated with the broker during the connection handshake.   */  frameMax?: number;
  /**   * **UNSTABLE**   * Controls the log level. Currently setting it to 'debug' will print received and sent frames on byte level.   *   * This should eventually be able to turn logging on and off on different levels such as framing/methods/connection.   */  loglevel?: "debug" | "none";  tls?: boolean;}
export interface AmqpConnectParameters {  hostname: string;  port: number;  username: string;  password: string;  vhost: string;  heartbeatInterval?: number;  frameMax?: number;  loglevel: "debug" | "none";  tls?: boolean;}
function resolvePort(url: URL): number {  if (url.port) {    return parseInt(url.port);  }
  if (url.protocol === "amqp:") {    return 5672;  }
  if (url.protocol === "amqps:") {    return 5671;  }
  throw new Error("Unsupported protocol");}
function resolveTls(url: URL): boolean {  return url.protocol === "amqps:";}
function parseUrl(value: string): AmqpConnectOptions {  const url = new URL(value);
  if (!["amqp:", "amqps:"].includes(url.protocol)) {    throw new Error("Unsupported protocol");  }
  const heartbeatParam = url.searchParams.get("heartbeat");  const heartbeat = heartbeatParam ? parseInt(heartbeatParam) : undefined;  if (heartbeat !== undefined && isNaN(heartbeat)) {    throw new Error(`Invalid heartbeat parameter ${heartbeatParam}`);  }
  const frameMaxParam = url.searchParams.get("frame_max");  const frameMax = frameMaxParam ? parseInt(frameMaxParam) : undefined;  if (frameMax !== undefined && isNaN(frameMax)) {    throw new Error(`Invalid frame_max parameter ${frameMaxParam}`);  }
  return {    hostname: url.hostname,    port: resolvePort(url),    username: url.username || "guest",    password: url.password || "guest",    tls: resolveTls(url),    vhost: url.pathname.length > 0 ? decodeURIComponent(url.pathname.substring(1)) : "/",    heartbeatInterval: heartbeat,    frameMax: frameMax,  };}
export function parseOptions(  optionsOrString: string | AmqpConnectOptions = {},): AmqpConnectParameters {  const {    hostname = "localhost",    port = 5672,    username = "guest",    password = "guest",    heartbeatInterval,    loglevel = "none",    vhost = "/",    frameMax,    tls = false,  } = typeof optionsOrString === "string" ? parseUrl(optionsOrString) : optionsOrString;
  return {    hostname,    port,    username,    password,    heartbeatInterval,    loglevel,    vhost,    frameMax,    tls,  };}