import { Queue } from 'pglite-queue'

const queue = new Queue()

// Define a handler
queue.define('send-email', async (job) => {
  console.log(`Sending email to ${job.data.to}`)
  // your logic here
  return { sent: true }
})

// Start processing
await queue.start()

// Add a job
await queue.add('send-email', { to: 'user@example.com', subject: 'Hello' })

await queue.add('flaky-api-call', { url: '...' }, {
  retry: 5,          // retry up to 5 times (6 total attempts)
  backoff: {
    type: 'exponential',  // or 'fixed'
    baseDelay: 1000,      // 1s, 2s, 4s, 8s, 16s...
    maxDelay: 300000,     // cap at 5 minutes
  },
})

// Lower number = higher priority
await queue.add('critical', data, { priority: 1 })
await queue.add('normal', data, { priority: 5 })
await queue.add('low', data, { priority: 10 })

await queue.add('reminder', data, { delay: '30m' })  // run in 30 minutes
await queue.add('cleanup', data, { delay: '2h' })    // run in 2 hours
await queue.add('precise', data, { delay: 5000 })    // run in 5000ms

// Every day at 9:00 UTC
await queue.every('0 9 * * *', 'daily-report', { type: 'summary' })

// Every 15 minutes
await queue.every('*/15 * * * *', 'health-check', {})

// Weekdays at 6pm
await queue.every('0 18 * * 1-5', 'eod-sync', {})

queue.define('video-encode', async (job) => {
  for (let i = 0; i <= 100; i += 10) {
    await doWork()
    await job.progress(i)
  }
})

queue.on('progress', (job, pct) => {
  console.log(`Job ${job.id}: ${pct}%`)
})

const queue = new Queue({
  concurrency: 5, // process up to 5 jobs in parallel
})

queue.on('active', (job) => console.log(`Started: ${job.id}`))
queue.on('completed', (job) => console.log(`Done: ${job.id}`))
queue.on('failed', (job, err) => console.log(`Failed: ${job.id} - ${err.message}`))
queue.on('retrying', (job, attempt) => console.log(`Retry #${attempt}: ${job.id}`))
queue.on('progress', (job, pct) => console.log(`${job.id}: ${pct}%`))
queue.on('drained', () => console.log('All jobs processed'))
queue.on('error', (err) => console.error('Queue error:', err))

// In-memory (default) — data lost on restart
const queue = new Queue()

// Filesystem — survives restarts
const queue = new Queue({ dataDir: './my-queue-data' })

// Bring your own PGlite instance
import { PGlite } from '@electric-sql/pglite'
const db = new PGlite('./shared-db')
const queue = new Queue({ db })

// Waits for active jobs to finish before stopping
await queue.stop()

// Or let the queue handle SIGINT/SIGTERM automatically
const queue = new Queue({ handleSignals: true })

// Get a specific job
const job = await queue.getJob(42)

// Query jobs
const failed = await queue.getJobs({ status: 'failed' })
const recent = await queue.getJobs({ task: 'send-email', limit: 10 })

// Remove a job
await queue.removeJob(42)

// Clean up old jobs
await queue.clean('completed')  // remove all completed
await queue.clean('failed')     // remove all failed
await queue.clean()             // remove both

// Get counts
const counts = await queue.counts()
// { pending: 5, active: 2, completed: 100, failed: 3 }