import { RabbitMQEventBus, RMQConnectionParams } from "sim-shared/infrastructure/RabbitMQEventBus.js"
import { env } from "./env/index.js"

const rmqUser = env.RABBITMQ_USER
const rmqPass = env.RABBITMQ_PASSWORD
const rmqHost = env.RABBITMQ_HOST
const rmqPort = Number(env.RABBITMQ_PORT)
const rmqSecure = false
const rmqVhost = env.RABBITMQ_VHOST

export const rmqConnOptions = <RMQConnectionParams>{
  username: rmqUser,
  password: rmqPass,
  vhost: rmqVhost,
  hostname: rmqHost,
  port: rmqPort,
  secure: rmqSecure,
}

export const rabbitmqEventBus = new RabbitMQEventBus({
  connectionParams: rmqConnOptions,
  // La entrada de eventos no tiene que definir exchanges de dlx o delay pero es obligatorio
  delayedExchange: "-",
  dlxExchange: "-"
})

export async function startRMQClient() {
  await rabbitmqEventBus.connect()
}