bugsnag/bugsnag-js

module.exports = class MinidumpQueue {
  constructor (filestore) {
    this._filestore = filestore
    this._minidumps = null
    this._seen = new Set()
  }

  async peek () {
    if (!this._minidumps) {
      try {
        this._minidumps = await this._filestore.listMinidumps()
        this._minidumps.forEach(m => this._seen.add(m.minidumpPath))
      } catch (e) {
        this._minidumps = []
      }
    }

    return this._minidumps[0]
  }

  push (minidump) {
    // if _minidumps has not yet been lazy-loaded, this minidump will be picked
    // up automatically when the list loads
    if (this._minidumps && !this._seen.has(minidump.minidumpPath)) {
      this._seen.add(minidump.minidumpPath)
      this._minidumps.push(minidump)
    }
  }

  hasSeen (minidumpPath) {
    return this._seen.has(minidumpPath)
  }

  remove (minidump) {
    if (!minidump) {
      return
    }

    // remove the minidump from our in-memory queue, regardless of whether we can delete the file
    // this prevents accidental re-delivery within the same session
    this._minidumps = this._minidumps && this._minidumps.filter(
      queued => queued.minidumpPath !== minidump.minidumpPath && queued.eventPath !== minidump.eventPath)

    // we ignore any file delete failures - the file has probably already been deleted
    this._filestore.deleteMinidump(minidump).catch(e => {})
  }
}