module.exports = {
  name: "heartbeat",
  scheduleSeconds: 30,
  async produceJobs(queue) {
    await queue.add("heartbeat", { at: Date.now() }, {
      attempts: 3,
      backoff: { type: "exponential", delay: 1000 },
      removeOnComplete: 200,
      removeOnFail: 200
    });
  },
  async process(job, log) {
    const t0 = Date.now();
    await new Promise(r => setTimeout(r, 250));
    log.info({ id: job.id, ms: Date.now() - t0 }, "heartbeat ok");
  }
};