nostr/strfry
1
0
Fork 0
mirror of https://github.com/hoytech/strfry.git synced 2025-06-17 00:38:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

clean-up expiration logic a bit

Browse Source
This commit is contained in:
Doug Hoyte
2024-09-04 23:08:50 -04:00
parent f7ee2c23f1
commit 3905f84ec8
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/apps/relay/RelayCron.cpp
View File

@ -85,7 +85,8 @@ void RelayServer::runCron() {
auto expiration = lmdb::from_sv<uint64_t>(k); auto expiration = lmdb::from_sv<uint64_t>(k);
auto levId = lmdb::from_sv<uint64_t>(v); auto levId = lmdb::from_sv<uint64_t>(v);
if (levId == mostRecent) return true; if (expiration > now) return false;
if (levId == mostRecent) return true; // don't delete because it could cause levId re-use
if (expiration == 1) { // Ephemeral event if (expiration == 1) { // Ephemeral event
auto view = env.lookup_Event(txn, levId); auto view = env.lookup_Event(txn, levId);
@ -96,12 +97,12 @@ void RelayServer::runCron() {
numEphemeral++; numEphemeral++;
expiredLevIds.emplace_back(levId); expiredLevIds.emplace_back(levId);
} }
} else if (expiration <= now) { } else {
numExpired++; numExpired++;
expiredLevIds.emplace_back(levId); expiredLevIds.emplace_back(levId);
} }
return expiration <= now; return true;
}); });
} }