logos-storage/logos-storage-nim-dht
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim-dht.git synced 2026-05-21 17:19:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update codexdht/private/eth/p2p/discoveryv5/providers/maintenance.nim

Browse Source 
Co-authored-by: Eric <5089238+emizzle@users.noreply.github.com>
This commit is contained in:
Arnaud 2026-04-21 13:04:00 +04:00 committed by GitHub
parent 15b9a73271
commit cde029bd24
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 12 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
codexdht/private/eth/p2p/discoveryv5/providers/maintenance.nim
View File

@ -50,23 +50,20 @@ proc cleanupExpired*(
now = times.now().utc().toTime().toUnix()
for item in iter:
let res = await item
if res.isOk:
let (maybeKey, data) = res.value
if maybeKey.isSome:
let key = maybeKey.get()
let
expired = endians2.fromBytesBE(uint64, data).int64
let itemRes = await item
if (maybeKey, data) =? itemRes and key =? maybeKey:
let
expired = endians2.fromBytesBE(uint64, data).int64
if now >= expired:
trace "Found expired record", key
keys.add(key)
without pairs =? key.fromCidKey(), err:
trace "Error extracting parts from cid key", key
continue
if now >= expired:
trace "Found expired record", key
keys.add(key)
without pairs =? key.fromCidKey(), err:
trace "Error extracting parts from cid key", key
continue
if keys.len >= batchSize:
break
if keys.len >= batchSize:
break
if err =? (await store.delete(keys)).errorOption:
trace "Error cleaning up batch, records left intact!", size = keys.len, err = err.msg