Function setUpQueues

server/setUpQueues.js:37–243

(app)

let updateMongoDBSchemaQueue;

const setUpQueues = (app) => {
  const queuesToClose = [];
  const workersToClose = [];
  const queueEventsToClose = [];

  if (isQueueDebugEnabled) {
    console.log("[setUpQueues] queue debug logging is ENABLED"); // oxlint-disable-line no-console
  }

  // set up bullmq queues

  /*
  ** Update Charts Queue
  */
  updateChartsQueue = new Queue("updateChartsQueue", getQueueOptions());
  queuesToClose.push(updateChartsQueue);
  updateChartsQueue.on("error", (error) => {
    if (error.code === "ECONNREFUSED") {
      console.error("Failed to set up the updates queue. Please check if Redis is running: https://docs.chartbrew.com/quickstart#set-up-redis-for-automatic-dataset-updates"); // oxlint-disable-line no-console
      process.exit(1);
    }
  });

  /*
  ** Update Dashboards Queue
  */
  updateDashboardsQueue = new Queue("updateDashboardsQueue", getQueueOptions());
  queuesToClose.push(updateDashboardsQueue);
  updateDashboardsQueue.on("error", (error) => {
    if (error.code === "ECONNREFUSED") {
      console.error("Failed to set up the updates queue. Please check if Redis is running: https://docs.chartbrew.com/quickstart#set-up-redis-for-automatic-dataset-updates"); // oxlint-disable-line no-console
      process.exit(1);
    }
  });

  const updateDashboardsQueueEvents = new QueueEvents(updateDashboardsQueue.name, {
    connection: updateDashboardsQueue.opts.connection,
  });
  queueEventsToClose.push(updateDashboardsQueueEvents);

  if (isQueueDebugEnabled) {
    updateDashboardsQueueEvents.on("waiting", (event) => {
      debugQueueLog(updateDashboardsQueue.name, "waiting", event);
    });
    updateDashboardsQueueEvents.on("active", (event) => {
      debugQueueLog(updateDashboardsQueue.name, "active", event);
    });
    updateDashboardsQueueEvents.on("completed", (event) => {
      debugQueueLog(updateDashboardsQueue.name, "completed", event);
    });
    updateDashboardsQueueEvents.on("failed", (event) => {
      debugQueueLog(updateDashboardsQueue.name, "failed", event);
    });
    updateDashboardsQueueEvents.on("stalled", (event) => {
      debugQueueLog(updateDashboardsQueue.name, "stalled", event);
    });
    updateDashboardsQueueEvents.on("deduplicated", (event) => {
      debugQueueLog(updateDashboardsQueue.name, "deduplicated", event);