+handler.ts

import type { FastifyPluginAsyncTypebox } from '@fastify/type-provider-typebox';
import { Type } from '@sinclair/typebox';

import useQueue from '~/composables/useQueue';
import useWorker from '~/composables/useWorker';

export default (async (app) => {
  /*
  $ curl --request GET \
         --url http://127.0.0.1:3000/api/queues/cron?color=blue
  */
  app.get(
    '',
    {
      schema: {
        querystring: Type.Object({ color: Type.String() }),
        response: { 200: Type.Object({ message: Type.String() }) },
      },
    },
    async (req, reply) => {
      // worker.js {%
      const paintRenewQueue = useQueue('PaintRenew');

      await paintRenewQueue.add(
        'wall',
        { color: req.query.color },
        {
          removeOnComplete: true,
          repeat: { pattern: '45 * * * * *' },
        },
      );

      useWorker(
        'PaintRenew',
        async (job) => {
          console.log('[PaintRenew] Starting job:', job.name);
          console.log(job.id, job.name, job.data);
          console.log('[PaintRenew] Finished job:', job.name);
          return;
        },
        {
          removeOnComplete: { count: 0 },
          removeOnFail: { count: 0 },
        },
      );
      // %}

      return reply.send({ message: 'OK' });
    },
  );
}) as FastifyPluginAsyncTypebox;