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

Lot of refactor, use .env and dedicated eventstore

Browse source
This commit is contained in:
@s.roertgen 2025-04-25 11:17:15 +02:00
parent 68d3012dba
commit d3b6a3f04a
8 changed files with 47 additions and 822 deletions
Download patch file Download diff file Expand all files Collapse all files

74
main.go
View file

@ -3,33 +3,33 @@ package main
import (
"context"
"fmt"
"log"
"net/http"
"os"
"github.com/fiatjaf/eventstore/badger"
"github.com/edufeed-org/eventstore/typesense30142"
"github.com/fiatjaf/khatru"
"github.com/joho/godotenv"
"github.com/nbd-wtf/go-nostr"
)
const (
apiKey string = "xyz"
typesenseHost string = "http://localhost:8108"
collectionName string = "amb-test"
)
func main() {
err := CheckOrCreateCollection("amb-test")
// Load .env file
err := godotenv.Load()
if err != nil {
log.Fatalf("Failed to check/create collection: %v", err)
fmt.Printf("Error loading .env file: %v", err)
}
relay := khatru.NewRelay()
relay.Info.Name = "my typesense relay"
// tsRelay.Info.PubKey = "79be667ef9dcbbac55a06295ce870b07029bfcdb2dce28d959f2815b16f81798"
relay.Info.Description = "this is the typesense custom relay"
// tsRelay.Info.Icon = "https://external-content.duckduckgo.com/iu/?u=https%3A%2F%2Fliquipedia.net%2Fcommons%2Fimages%2F3%2F35%2FSCProbe.jpg&f=1&nofb=1&ipt=0cbbfef25bce41da63d910e86c3c343e6c3b9d63194ca9755351bb7c2efa3359&ipo=images"
dbts := badger.BadgerBackend{Path: "/tmp/khatru-badgern-tmp-2"}
if err := dbts.Init(); err != nil {
relay.Info.Name = os.Getenv("NAME")
relay.Info.PubKey = os.Getenv("PUBKEY")
relay.Info.Description = os.Getenv("DESCRIPTION")
relay.Info.Icon = os.Getenv("ICON")
db := typesense30142.TSBackend{
ApiKey: os.Getenv("TS_APIKEY"),
Host: os.Getenv("TS_HOST"),
CollectionName: os.Getenv("TS_COLLECTION"),
}
if err := db.Init(); err != nil {
panic(err)
}
@ -37,10 +37,9 @@ func main() {
khatru.RequestAuth(ctx)
})
relay.QueryEvents = append(relay.QueryEvents, handleQuery)
relay.CountEvents = append(relay.CountEvents, handleCount)
relay.DeleteEvent = append(relay.DeleteEvent, handleDelete)
relay.ReplaceEvent = append(relay.ReplaceEvent, handleReplaceEvent)
relay.QueryEvents = append(relay.QueryEvents, db.QueryEvents)
relay.DeleteEvent = append(relay.DeleteEvent, db.DeleteEvent)
relay.ReplaceEvent = append(relay.ReplaceEvent, db.ReplaceEvent)
relay.Negentropy = true
relay.RejectEvent = append(relay.RejectEvent,
@ -55,38 +54,3 @@ func main() {
fmt.Println("running on :3334")
http.ListenAndServe(":3334", relay)
}
func handleQuery(ctx context.Context, filter nostr.Filter) (chan *nostr.Event, error) {
ch := make(chan *nostr.Event)
nostrs, err := SearchResources(collectionName, filter.Search)
if err != nil {
log.Printf("Search failed: %v", err)
return ch, err
}
go func() {
for _, evt := range nostrs {
ch <- &evt
}
close(ch)
}()
return ch, nil
}
func handleCount(ctx context.Context, filter nostr.Filter) (int64, error) {
CountEvents(collectionName, filter)
return 0, nil
}
func handleDelete(ctx context.Context, event *nostr.Event) error {
fmt.Println("delete event", event)
DeleteNostrEvent(collectionName, event)
return nil
}
func handleReplaceEvent(ctx context.Context, event *nostr.Event) error {
IndexNostrEvent(collectionName, event)
return nil
}