goodmorningbitcoin/wot-relay
1
0
Fork 0
mirror of https://github.com/bitvora/wot-relay.git synced 2025-06-06 18:31:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

return when done, remose eose

Browse Source
This commit is contained in:
Barry Deen 2024-09-11 13:02:07 -04:00
parent f1ff8bb6bb
commit 5d9325793f
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
main.go
View File

@ -323,7 +323,7 @@ func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
trustNetworkFilterMu.Lock() trustNetworkFilterMu.Lock()
defer trustNetworkFilterMu.Unlock() defer trustNetworkFilterMu.Unlock()
for ev := range pool.SubManyEose(timeout, seedRelays, filters) { for ev := range pool.SubMany(timeout, seedRelays, filters) {
select { select {
case <-ctx.Done(): case <-ctx.Done():
log.Println("⏰ Archive process terminated due to timeout") log.Println("⏰ Archive process terminated due to timeout")
@ -344,4 +344,5 @@ func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
} }
log.Println("📦 archived", trustedNotes, "trusted notes and discarded", untrustedNotes, "untrusted notes") log.Println("📦 archived", trustedNotes, "trusted notes and discarded", untrustedNotes, "untrusted notes")
return
} }