A script that uses dynamic queue name discovery to build Bull Arena object, without having to manually specify each queue name.

bull-arena-dynamic-queue-names.ts

import Arena from 'bull-arena'
import { uniq } from 'lodash'
import { getConnection } from './redis-connection'
import { config } from '../config'

const BULL_PREFIX = 'bull'
const HOST_ID = '__'

type Queue = Parameters<typeof Arena>[0]['queues'][0]

async function queueNames() {
  const redis = getConnection()

  // key format: bull:sum:active
  const keys = await redis.keys(`${BULL_PREFIX}:*`)

  // we no longer need the connection
  redis.disconnect()

  return uniq(keys.map(key => key.split(':')[1])).sort()
}

export async function arena() {
  const names = await queueNames()

  const queues = names.map<Queue>(name => {
    return {
      name,
      redis: config.REDIS_URL,
      hostId: HOST_ID,
      prefix: BULL_PREFIX,
    }
  })

  return Arena(
    { queues },
    {
      // port on which Arena will run
      port: config.PORT,
    },
  )
}