worker.js

require("dotenv").config()
const Queue = require("bull")
const { Sequelize } = require("sequelize")

const sequelize = new Sequelize(process.env.DATABASE_URL)

const REDIS_URL = process.env.REDIS_URL

let workQueue = new Queue("queueEcheanceTodos", REDIS_URL)

workQueue.process(async (job) => {
  console.log(
    `Exécution du job de mise à jour du statut du ToDo ${job.data.idTodo} qui arrive à écheance le ${job.data.dateEcheance}`
  )
  try {
    // Il manque quelque chose ici...  A vous de l'ajouter !
    // Indice : vous aurez besoin de await sequelize.query(...)
    const [todos] = await sequelize.query(
      `SELECT * FROM todos WHERE id = ${job.data.idTodo}`
    )
    const todo = todos[0]
    if (todo.date_echeance < new Date()) {
      await sequelize.query(
        `UPDATE todos SET status = "EN_RETARD" WHERE id = ${job.data.idTodo}`
      )
    }
  } catch (error) {
    console.error(error)
  }
})