RM

Ravi Menon · Cap backoff at one minute

18 lines

  1. import type { Job, JobHandler } from './types'
  3. // Wait 1s, 2s, 4s... capped at one minute.
  4. export function backoff(attempts: number) {
  5. return Math.min(2 ** attempts * 1000, 60_000)
  6. }
  8. export function withRetry<Payload>(handler: JobHandler<Payload>, maxAttempts = 5): JobHandler<Payload> {
  9. return async (job: Job<Payload>) => {
  10. try {
  11. await handler(job)
  12. } catch (error) {
  13. if (job.attempts + 1 >= maxAttempts) throw error
  14. await new Promise(resolve => setTimeout(resolve, backoff(job.attempts)))
  15. await withRetry(handler, maxAttempts)({ ...job, attempts: job.attempts + 1 })
  16. }
  17. }
  18. }