Monorepo for Tangled tangled.org

appview/config: make jetstream endpoint configurable

Changed files
+6 -5
appview
+5 -4
appview/config.go
··· 7 7 ) 8 8 9 9 type Config struct { 10 - CookieSecret string `env:"TANGLED_COOKIE_SECRET, default=00000000000000000000000000000000"` 11 - DbPath string `env:"TANGLED_DB_PATH, default=appview.db"` 12 - ListenAddr string `env:"TANGLED_LISTEN_ADDR, default=0.0.0.0:3000"` 13 - Dev bool `env:"TANGLED_DEV, default=false"` 10 + CookieSecret string `env:"TANGLED_COOKIE_SECRET, default=00000000000000000000000000000000"` 11 + DbPath string `env:"TANGLED_DB_PATH, default=appview.db"` 12 + ListenAddr string `env:"TANGLED_LISTEN_ADDR, default=0.0.0.0:3000"` 13 + Dev bool `env:"TANGLED_DEV, default=false"` 14 + JetstreamEndpoint string `env:"TANGLED_JETSTREAM_ENDPOINT, default=wss://jetstream1.us-east.bsky.network/subscribe"` 14 15 } 15 16 16 17 func LoadConfig(ctx context.Context) (*Config, error) {
+1 -1
appview/state/state.go
··· 61 61 resolver := appview.NewResolver() 62 62 63 63 wrapper := db.DbWrapper{d} 64 - jc, err := jetstream.NewJetstreamClient("appview", []string{tangled.GraphFollowNSID}, nil, slog.Default(), wrapper, false) 64 + jc, err := jetstream.NewJetstreamClient(config.JetstreamEndpoint, "appview", []string{tangled.GraphFollowNSID}, nil, slog.Default(), wrapper, false) 65 65 if err != nil { 66 66 return nil, fmt.Errorf("failed to create jetstream client: %w", err) 67 67 }