From 8ffb69a26abadc6760b39ea32e495646218a28c5 Mon Sep 17 00:00:00 2001 From: Anirudh Oppiliappan Date: Fri, 21 Mar 2025 08:00:58 +0200 Subject: [PATCH] knotserver: make jetstream endpoint configurable --- cmd/knotserver/main.go | 2 +- knotserver/config/config.go | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/cmd/knotserver/main.go b/cmd/knotserver/main.go index 78109c6..0a05a56 100644 --- a/cmd/knotserver/main.go +++ b/cmd/knotserver/main.go @@ -46,7 +46,7 @@ func main() { e.E.EnableAutoSave(true) - jc, err := jetstream.NewJetstreamClient("knotserver", []string{ + jc, err := jetstream.NewJetstreamClient(c.Server.JetstreamEndpoint, "knotserver", []string{ tangled.PublicKeyNSID, tangled.KnotMemberNSID, }, nil, l, db, true) diff --git a/knotserver/config/config.go b/knotserver/config/config.go index 8998dda..073a892 100644 --- a/knotserver/config/config.go +++ b/knotserver/config/config.go @@ -18,6 +18,7 @@ type Server struct { Secret string `env:"SECRET, required"` DBPath string `env:"DB_PATH, default=knotserver.db"` Hostname string `env:"HOSTNAME, required"` + JetstreamEndpoint string `env:"JETSTREAM_ENDPOINT, default=wss://jetstream1.us-west.bsky.network/subscribe"` // This disables signature verification so use with caution. Dev bool `env:"DEV, default=false"` -- 2.51.2