XYOracleNetwork/clients

import type { JobQueue } from '@xyo-network/node-core-model'
import type { Job } from '@xyo-network/shared'
import type { DefineOptions } from 'agenda'

// TODO: Depends on job schedule, calculate dynamically
// to something like 25% of schedule to allow for retries
const options: DefineOptions = { lockLifetime: 10_000 }

export const defineJobs = (jobQueue: JobQueue, jobs: Job[]) => {
  jobs.map(job => jobQueue.define(job.name, options, job.task))
}