mirror of https://codeberg.org/pzp/pzp-gc.git
69 lines
1.5 KiB
JavaScript
69 lines
1.5 KiB
JavaScript
const makeDebug = require('debug')
|
|
const multicb = require('multicb')
|
|
|
|
module.exports = {
|
|
name: 'gc',
|
|
manifest: {},
|
|
permissions: {
|
|
anonymous: {},
|
|
},
|
|
|
|
/**
|
|
* @param {any} peer
|
|
* @param {{
|
|
* gc?: {
|
|
* maxLogBytes?: number
|
|
* }
|
|
* }} config
|
|
*/
|
|
init(peer, config) {
|
|
// Assertions
|
|
if (!peer.goals) throw new Error('gc requires the goals plugin')
|
|
if (typeof config.gc?.maxLogBytes !== 'number') {
|
|
throw new Error('gc requires config.gc.maxLogBytes')
|
|
}
|
|
|
|
// State
|
|
const debug = makeDebug('ppppp:gc')
|
|
|
|
/**
|
|
* Deletes messages that don't correspond to any goal.
|
|
* @private
|
|
*/
|
|
function cleanup(cb) {
|
|
debug('cleanup goalless started')
|
|
const done = multicb({ pluck: 1 })
|
|
let waiting = false
|
|
for (const rec of peer.db.records()) {
|
|
if (!rec.msg) continue
|
|
const purpose = peer.goals.getRecordPurpose(rec)
|
|
if (purpose === 'none') {
|
|
peer.db.del(rec.id, done())
|
|
waiting = true
|
|
} else if (purpose === 'trail') {
|
|
peer.db.erase(rec.id, done())
|
|
waiting = true
|
|
}
|
|
}
|
|
function whenEnded(err) {
|
|
// prettier-ignore
|
|
if (err) debug('cleanup goalless ended with an error %s', err.message ?? err)
|
|
else debug('cleanup goalless ended')
|
|
cb()
|
|
}
|
|
if (waiting) done(whenEnded)
|
|
else whenEnded()
|
|
}
|
|
|
|
function forceImmediately(cb) {
|
|
debug('force immediately')
|
|
cleanup(cb)
|
|
}
|
|
|
|
return {
|
|
initiate,
|
|
forceImmediately,
|
|
}
|
|
},
|
|
}
|