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

fix archiving

Browse Source
This commit is contained in:
Barry Deen 2024-09-06 17:39:39 -04:00
parent 797c3d89b4
commit b68cdeffba
1 changed files with 4 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
main.go
View File

@ -49,15 +49,10 @@ func main() {
panic(err) panic(err)
} }
mu.Lock()
copiedTrustNetwork := make([]string, len(trustNetwork))
copy(copiedTrustNetwork, trustNetwork)
mu.Unlock()
relay.StoreEvent = append(relay.StoreEvent, db.SaveEvent) relay.StoreEvent = append(relay.StoreEvent, db.SaveEvent)
relay.QueryEvents = append(relay.QueryEvents, db.QueryEvents) relay.QueryEvents = append(relay.QueryEvents, db.QueryEvents)
relay.RejectEvent = append(relay.RejectEvent, func(ctx context.Context, event *nostr.Event) (bool, string) { relay.RejectEvent = append(relay.RejectEvent, func(ctx context.Context, event *nostr.Event) (bool, string) {
for _, pk := range copiedTrustNetwork { for _, pk := range trustNetwork {
if pk == event.PubKey { if pk == event.PubKey {
return false, "" return false, ""
} }
@ -223,14 +218,8 @@ func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
defer ticker.Stop() defer ticker.Stop()
archivePool = nostr.NewSimplePool(ctx) archivePool = nostr.NewSimplePool(ctx)
for range ticker.C { for range ticker.C {
since := nostr.Timestamp(time.Now().Unix()) timeout, cancel := context.WithTimeout(ctx, 58*time.Second)
mu.Lock()
trustNetworkCopy := make([]string, len(trustNetwork))
copy(trustNetworkCopy, trustNetwork)
mu.Unlock()
filters := []nostr.Filter{{ filters := []nostr.Filter{{
Kinds: []int{ Kinds: []int{
nostr.KindArticle, nostr.KindArticle,
@ -245,12 +234,10 @@ func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
nostr.KindZap, nostr.KindZap,
nostr.KindTextNote, nostr.KindTextNote,
}, },
Since: &since,
}} }}
timeout, cancel := context.WithTimeout(ctx, 1*time.Minute)
for ev := range archivePool.SubManyEose(timeout, relays, filters) { for ev := range archivePool.SubManyEose(timeout, relays, filters) {
for _, trustedPubkey := range trustNetworkCopy { for _, trustedPubkey := range trustNetwork {
if ev.Event.PubKey == trustedPubkey { if ev.Event.PubKey == trustedPubkey {
if ev.Event.Kind == nostr.KindContactList { if ev.Event.Kind == nostr.KindContactList {
if len(ev.Event.Tags.GetAll([]string{"p"})) > 2000 { if len(ev.Event.Tags.GetAll([]string{"p"})) > 2000 {
@ -259,6 +246,7 @@ func archiveTrustedNotes(relay *khatru.Relay, ctx context.Context) {
} }
} }
relay.AddEvent(ctx, ev.Event) relay.AddEvent(ctx, ev.Event)
fmt.Println("archived trusted note: ", ev.Event.ID)
} }
} }
} }