'use strict'

const deliveryMixin = {
  _deliveryReceiptGossipKeys: null,
  _receiptRegistryHealWatermark: null,
  _failureDigestHealWatermark: null,

  _initDeliveryMixinState () {
    if (!this._deliveryReceiptGossipKeys) {
      this._deliveryReceiptGossipKeys = new Set()
    }
  },

  _shouldGossipDeliveryReceipt (receipt) {
    this._initDeliveryMixinState()
    if (!receipt?.guildId || !receipt?.id) return true
    const hash = `${receipt.guildId}:${receipt.id}:${receipt.hookId || ''}:${receipt.status || ''}:${receipt.eventType || ''}:${receipt.at || 0}`
    if (this._deliveryReceiptGossipKeys.has(hash)) return false
    this._deliveryReceiptGossipKeys.add(hash)
    if (this._deliveryReceiptGossipKeys.size > 8192) {
      const first = this._deliveryReceiptGossipKeys.values().next().value
      if (first) this._deliveryReceiptGossipKeys.delete(first)
    }
    return true
  },

  async _healReceiptRegistryOnPartition (guildId) {
    const gid = guildId || this.guild?.guild?.id || null
    const span = this.log.time('delivery.receipt', {
      spanKind: 'delivery.receipt',
      guildId: gid,
      context: 'heal.registry'
    })
    try {
      if (!gid || !this.deliveryReceipts) {
        span.end({ relisted: 0, skipped: true, guildReceiptCount: 0 })
        return { relisted: 0, skipped: true }
      }
      await this._initDeliveryReceipts(gid)
      const rows = await this.deliveryReceipts.listRecent(512)
      let relisted = 0
      for (const row of rows) {
        if (this._shouldGossipDeliveryReceipt(row)) relisted++
      }
      const watermark = Date.now()
      this._receiptRegistryHealWatermark = watermark
      span.end({
        relisted,
        watermark,
        guildReceiptCount: rows.length,
        bridgeKind: 'delivery.receipt'
      })
      return { relisted, watermark, guildReceiptCount: rows.length }
    } catch (err) {
      this.log.error('delivery.receipt error', {
        guildId: gid,
        context: 'heal.registry',
        error: err?.message || String(err)
      })
      span.fail(err)
      return { relisted: 0, error: err?.message || String(err) }
    }
  },

  async _healFailureDigestCursorOnPartition (guildId) {
    const gid = guildId || this.guild?.guild?.id || null
    const span = this.log.time('delivery.receipt', {
      spanKind: 'delivery.receipt',
      guildId: gid,
      context: 'heal.digest'
    })
    try {
      if (!gid) {
        span.end({ relisted: 0, skipped: true, guildReceiptCount: 0 })
        return { relisted: 0, skipped: true }
      }
      await this._initDeliveryReceipts(gid)
      const digest = await this._computeHookFailureDigest().catch(() => null)
      const watermark = Date.now()
      this._failureDigestHealWatermark = watermark
      span.end({
        relisted: 0,
        watermark,
        guildReceiptCount: (await this.deliveryReceipts.listRecent(64)).length,
        digestFailures: digest?.totalFailures || 0,
        guildCount: (this.guilds || []).length,
        activeChannelId: this.activeChannelId || null,
        bridgeKind: 'delivery.receipt'
      })
      return {
        relisted: 0,
        watermark,
        guildReceiptCount: (await this.deliveryReceipts.listRecent(64)).length
      }
    } catch (err) {
      this.log.error('delivery.receipt error', {
        guildId: gid,
        context: 'heal.digest',
        error: err?.message || String(err)
      })
      span.fail(err)
      return { relisted: 0, error: err?.message || String(err) }
    }
  }
}

module.exports = { deliveryMixin }