Raven ScottandCursor
a5dba86570
Move 136 prototype mixins under mixins/domain, json-export, and runtime/* so the package root stays navigable. Manifest assign order is unchanged; apply-platform-mixins and runtime registry paths updated. Co-authored-by: Cursor <[email protected]>
104 lines
3.4 KiB
JavaScript
104 lines
3.4 KiB
JavaScript
'use strict'
|
|
|
|
const healthMixin = {
|
|
_digestRelayHandoffGossipKeys: null,
|
|
_scheduleDashboardHealWatermark: null,
|
|
_archivePeerHealWatermark: null,
|
|
|
|
_initHealthMixinState () {
|
|
if (!this._digestRelayHandoffGossipKeys) {
|
|
this._digestRelayHandoffGossipKeys = new Set()
|
|
}
|
|
},
|
|
|
|
_shouldGossipDigestRelayHandoff (slice) {
|
|
this._initHealthMixinState()
|
|
if (!slice?.guildId || !slice?.exportedAt) return true
|
|
const hash = `${slice.guildId}:${slice.exportedAt}:${slice.snapshotId || ''}:${slice.transport || ''}:${slice.signature || ''}`
|
|
if (this._digestRelayHandoffGossipKeys.has(hash)) return false
|
|
this._digestRelayHandoffGossipKeys.add(hash)
|
|
if (this._digestRelayHandoffGossipKeys.size > 8192) {
|
|
const first = this._digestRelayHandoffGossipKeys.values().next().value
|
|
if (first) this._digestRelayHandoffGossipKeys.delete(first)
|
|
}
|
|
return true
|
|
},
|
|
|
|
async _healScheduleDashboardOnPartition (guildId) {
|
|
const gid = guildId || this.guild?.guild?.id || null
|
|
const span = this.log.time('automation.health', {
|
|
spanKind: 'automation.health',
|
|
guildId: gid,
|
|
context: 'heal.schedule'
|
|
})
|
|
try {
|
|
if (!gid || !this.getAutomationHealthDashboard) {
|
|
span.end({ relisted: 0, skipped: true, guildHealthRowCount: 0 })
|
|
return { relisted: 0, skipped: true }
|
|
}
|
|
const dash = await this.getAutomationHealthDashboard()
|
|
const watermark = Date.now()
|
|
this._scheduleDashboardHealWatermark = watermark
|
|
const rowCount = (dash.overdueActions || []).length + (dash.auditExport ? 1 : 0) + (dash.digestSync ? 1 : 0)
|
|
span.end({
|
|
relisted: 1,
|
|
watermark,
|
|
guildHealthRowCount: rowCount,
|
|
anyOverdue: !!dash.anyOverdue,
|
|
bridgeKind: 'automation.health'
|
|
})
|
|
return { relisted: 1, watermark, guildHealthRowCount: rowCount }
|
|
} catch (err) {
|
|
this.log.error('automation.health error', {
|
|
guildId: gid,
|
|
context: 'heal.schedule',
|
|
error: err?.message || String(err)
|
|
})
|
|
span.fail(err)
|
|
return { relisted: 0, error: err?.message || String(err) }
|
|
}
|
|
},
|
|
|
|
async _healArchivePeerCursorOnPartition (guildId) {
|
|
const gid = guildId || this.guild?.guild?.id || null
|
|
const span = this.log.time('automation.health', {
|
|
spanKind: 'automation.health',
|
|
guildId: gid,
|
|
context: 'heal.archive'
|
|
})
|
|
try {
|
|
if (!gid) {
|
|
span.end({ relisted: 0, skipped: true, guildHealthRowCount: 0 })
|
|
return { relisted: 0, skipped: true }
|
|
}
|
|
const watermark = Date.now()
|
|
this._archivePeerHealWatermark = watermark
|
|
const dash = await this.getAutomationHealthDashboard().catch(() => ({}))
|
|
span.end({
|
|
relisted: 0,
|
|
watermark,
|
|
guildHealthRowCount: (dash.health?.archivePeers || []).length,
|
|
avgArchivePeerScore: dash.health?.avgArchivePeerScore || 0,
|
|
guildCount: (this.guilds || []).length,
|
|
activeChannelId: this.activeChannelId || null,
|
|
bridgeKind: 'automation.health'
|
|
})
|
|
return {
|
|
relisted: 0,
|
|
watermark,
|
|
guildHealthRowCount: (dash.health?.archivePeers || []).length
|
|
}
|
|
} catch (err) {
|
|
this.log.error('automation.health error', {
|
|
guildId: gid,
|
|
context: 'heal.archive',
|
|
error: err?.message || String(err)
|
|
})
|
|
span.fail(err)
|
|
return { relisted: 0, error: err?.message || String(err) }
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = { healthMixin }
|