Remove expired fixers

This commit is contained in:
Ben Sarmiento
2024-02-03 07:30:40 +01:00
parent 9a8b1553a2
commit 371a90fa03

View File

@@ -49,7 +49,22 @@ func (t *TorrentManager) handleFixers() {
infoCache.Remove(id) infoCache.Remove(id)
t.deleteTorrentFile(id) t.deleteTorrentFile(id)
} }
// remove expired fixers
var expired []string
t.fixers.IterCb(func(trigger string, command string) {
if infoCache.Has(trigger) {
return
}
expired = append(expired, trigger)
})
for _, trigger := range expired {
t.log.Debugf("Removing expired fixer id=%s", trigger)
t.fixers.Remove(trigger)
}
t.writeFixersToFile() t.writeFixersToFile()
t.log.Debugf("Finished handling fixers") t.log.Debugf("Finished handling fixers")
} }