edufeed-org/amb-relay
2
0
Fork 0
mirror of https://github.com/edufeed-org/amb-relay.git synced 2025-12-10 00:34:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Basic Deletion working

Browse source
This commit is contained in:
@s.roertgen 2025-03-28 13:20:01 +01:00
parent 49d0c7ff55
commit 5d0be447f0
4 changed files with 61 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

15
main.go
View file

@ -39,9 +39,9 @@ func main() {
relay.StoreEvent = append(relay.StoreEvent)
relay.QueryEvents = append(relay.QueryEvents, handleQuery)
relay.CountEvents = append(relay.CountEvents, dbts.CountEvents)
relay.DeleteEvent = append(relay.DeleteEvent, dbts.DeleteEvent)
relay.ReplaceEvent = append(relay.ReplaceEvent, dbts.ReplaceEvent, handleEvent) // use badger for counting events -> TODO switch to typesense?
relay.CountEvents = append(relay.CountEvents, dbts.CountEvents) // use badger for counting events -> TODO switch to typesense?
relay.DeleteEvent = append(relay.DeleteEvent, handleDelete)
relay.ReplaceEvent = append(relay.ReplaceEvent, handleReplaceEvent)
relay.Negentropy = true
relay.RejectEvent = append(relay.RejectEvent,
@ -57,7 +57,12 @@ func main() {
http.ListenAndServe(":3334", relay)
}
func handleEvent(ctx context.Context, event *nostr.Event) error {
func handleDelete(ctx context.Context, event *nostr.Event) error {
DeleteNostrEvent(collectionName, event)
return nil
}
func handleReplaceEvent(ctx context.Context, event *nostr.Event) error {
IndexNostrEvent(collectionName, event)
return nil
}
@ -77,7 +82,5 @@ func handleQuery(ctx context.Context, filter nostr.Filter) (chan *nostr.Event, e
}
close(ch)
}()
return ch, nil
}