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

check for blank chunks

Browse Source
This commit is contained in:
Barry Deen 2024-09-07 17:26:26 -04:00
parent a97e0ab2d8
commit d1198a31b5
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
main.go
View File

@ -192,7 +192,6 @@ func refreshTrustNetwork(relay *khatru.Relay, ctx context.Context) []string {
} }
} }
fmt.Println("trust network size:", len(trustNetwork))
getTrustNetworkProfileMetadata(relay, ctx) getTrustNetworkProfileMetadata(relay, ctx)
} }
@ -219,6 +218,10 @@ func getTrustNetworkProfileMetadata(relay *khatru.Relay, ctx context.Context) {
} }
for _, chunk := range chunks { for _, chunk := range chunks {
if len(chunk) == 0 {
continue
}
timeoutCtx, cancel := context.WithTimeout(ctx, 3*time.Second) timeoutCtx, cancel := context.WithTimeout(ctx, 3*time.Second)
defer cancel() defer cancel()
filters := []nostr.Filter{{ filters := []nostr.Filter{{
@ -246,11 +249,10 @@ func appendPubkey(pubkey string) {
func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) { func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
ticker := time.NewTicker(1 * time.Minute) ticker := time.NewTicker(1 * time.Minute)
archivePool = nostr.NewSimplePool(ctx)
defer ticker.Stop() defer ticker.Stop()
for range ticker.C { for range ticker.C {
ctx := context.Background()
archivePool = nostr.NewSimplePool(ctx)
timeout, cancel := context.WithTimeout(ctx, 50*time.Second) timeout, cancel := context.WithTimeout(ctx, 50*time.Second)
filters := []nostr.Filter{{ filters := []nostr.Filter{{
Kinds: []int{ Kinds: []int{
@ -282,10 +284,10 @@ func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
if bloomFilter.Has(xxhash.Sum64([]byte(ev.Event.PubKey))) { if bloomFilter.Has(xxhash.Sum64([]byte(ev.Event.PubKey))) {
if len(ev.Event.Tags) > 2000 { if len(ev.Event.Tags) > 2000 {
fmt.Println("skiping note with over 2000 tags")
continue continue
} }
relay.AddEvent(ctx, ev.Event) relay.AddEvent(ctx, ev.Event)
} }
} }
cancel() cancel()