sf-sim/packages/sim-consumidor-objenious/index.ts

import { startRMQClient } from "#config/eventBus.config"
import { httpInstance } from "#config/httpClient.config"
import { SimController } from "./aplication/Sim.controller.js"
import { SimRouter } from "./aplication/Sim.router.js"
import { SimUseCases } from "./aplication/Sim.usecases.js"

async function startWorker() {
  const rmqClient = await startRMQClient()
  const httpClient = httpInstance
  const simActivationController = new SimController(
    rmqClient,
    new SimUseCases({
      httpClient: httpClient
    })
  )
  const simRouter = new SimRouter(simActivationController)

  // de momento solo una cola por simplificar
  rmqClient.consume("sim.objenious", simRouter.route)
}

startWorker()
  .then(e => {
    console.log("[o] Worker de SIM de Objenious[FR] iniciado")
  })
  .catch(e => {
    console.error("[x] Error iniciando worker de SIM de Objenious[FR]", e)
  })

export default {}