import { CoreEventQueue, PriorityQueue } from '@segment/analytics-core'
import type { Plugin } from '../app/types'
import type { Context } from './context'

class NodePriorityQueue extends PriorityQueue<Context> {
  constructor() {
    super(1, [])
  }
  // do not use an internal "seen" map
  getAttempts(ctx: Context): number {
    return ctx.attempts ?? 0
  }
  updateAttempts(ctx: Context): number {
    ctx.attempts = this.getAttempts(ctx) + 1
    return this.getAttempts(ctx)
  }
}

export class NodeEventQueue extends CoreEventQueue<Context, Plugin> {
  constructor() {
    super(new NodePriorityQueue())
  }
}