diff --git a/appview/config.go b/appview/config.go index 8a98695..950b8be 100644 --- a/appview/config.go +++ b/appview/config.go @@ -7,10 +7,11 @@ import ( ) type Config struct { - CookieSecret string `env:"TANGLED_COOKIE_SECRET, default=00000000000000000000000000000000"` - DbPath string `env:"TANGLED_DB_PATH, default=appview.db"` - ListenAddr string `env:"TANGLED_LISTEN_ADDR, default=0.0.0.0:3000"` - Dev bool `env:"TANGLED_DEV, default=false"` + CookieSecret string `env:"TANGLED_COOKIE_SECRET, default=00000000000000000000000000000000"` + DbPath string `env:"TANGLED_DB_PATH, default=appview.db"` + ListenAddr string `env:"TANGLED_LISTEN_ADDR, default=0.0.0.0:3000"` + Dev bool `env:"TANGLED_DEV, default=false"` + JetstreamEndpoint string `env:"TANGLED_JETSTREAM_ENDPOINT, default=wss://jetstream1.us-east.bsky.network/subscribe"` } func LoadConfig(ctx context.Context) (*Config, error) { diff --git a/appview/state/state.go b/appview/state/state.go index c5e5bad..99253aa 100644 --- a/appview/state/state.go +++ b/appview/state/state.go @@ -61,7 +61,7 @@ func Make(config *appview.Config) (*State, error) { resolver := appview.NewResolver() wrapper := db.DbWrapper{d} - jc, err := jetstream.NewJetstreamClient("appview", []string{tangled.GraphFollowNSID}, nil, slog.Default(), wrapper, false) + jc, err := jetstream.NewJetstreamClient(config.JetstreamEndpoint, "appview", []string{tangled.GraphFollowNSID}, nil, slog.Default(), wrapper, false) if err != nil { return nil, fmt.Errorf("failed to create jetstream client: %w", err) }