amqp_connect.ts

import { AmqpConnection } from "./amqp_connection.ts";
import { AmqpSocket } from "./amqp_socket.ts";
import { AmqpConnectOptions, parseOptions } from "./amqp_connect_options.ts";

export type { AmqpConnectOptions };

export async function connect(): Promise<AmqpConnection>;
export async function connect(
  options?: AmqpConnectOptions,
): Promise<AmqpConnection>;
export async function connect(uri?: string): Promise<AmqpConnection>;
export async function connect(
  optionsOrUrl?: AmqpConnectOptions | string,
): Promise<AmqpConnection> {
  const {
    hostname,
    port,
    username,
    password,
    heartbeatInterval,
    loglevel,
    vhost,
    frameMax,
    tls,
  } = parseOptions(optionsOrUrl);

  const conn = tls ? await Deno.connectTls({ port, hostname }) : await Deno.connect({ port, hostname });
  const socket = new AmqpSocket(conn);

  const connection = new AmqpConnection(socket, {
    username,
    password,
    heartbeatInterval,
    frameMax,
    loglevel,
    vhost,
  });

  await connection.open();

  return connection;
}