RedwoodJS v7 Server Config with BullMQ & BullBoard

server.ts

import { createBullBoard } from '@bull-board/api'
import { BullMQAdapter } from '@bull-board/api/bullMQAdapter'
import { FastifyAdapter } from '@bull-board/fastify'

import { createServer } from '@redwoodjs/api-server'

import { logger } from 'src/lib/logger'

// (↓) Enable bullMQ worker processing
import 'src/queue/worker'
import { defaultQueue } from 'src/queue/index'

async function main() {
  const server = await createServer({
    logger,
  })
  /**
   * auto compress larger than 1024Mb
   */
  await server.register(import('@fastify/compress'), {
    global: true,
    threshold: 1024,
    encodings: ['deflate', 'gzip'],
  })

  /**
   * Rate limit by IP to 1K within 5 minutes
   */
  await server.register(import('@fastify/rate-limit'), {
    max: 1_000,
    timeWindow: '5 minutes',
  })

  /**
   * BullMQ Bullboard
   */
  const serverAdapter = new FastifyAdapter()
  createBullBoard({
    queues: [new BullMQAdapter(defaultQueue)],
    serverAdapter,
  })
  serverAdapter.setBasePath('/bullmq')
  await server.register(serverAdapter.registerPlugin(), {
    prefix: '/bullmq',
    basePath: '/bullmq',
  })

  await server.start()
}

main()

worker.ts

// src/queue/worker

import { Worker } from 'bullmq'

import { welcomeMessage, redisOptions } from './index.js'

const jobHandlers = {
  welcomeMessage: welcomeMessage,
}

const processJob = async (job) => {
  const handler = jobHandlers[job.name]

  if (handler) {
    console.log(`Processing job: ${job.name}`)
    await handler(job)
  }
}

const worker = new Worker('defaultQueue', processJob, {
  connection: redisOptions,
})

worker.on('completed', (job) => {
  console.log(`${job.id} has completed!`)
})

worker.on('failed', (job, err) => {
  console.log(`${job.id} has failed with ${err.message}`)
})

console.log('Worker started!')