My own copy of Tangled :)
appview/config: make jetstream endpoint configurable
author
Anirudh Oppiliappan
date
(Mar 21, 2025, 8:32 AM +0200)
commit
20d553c1
20d553c1e4f17d9f9f7cd1084b40eed17ead9c71
parent
ff15b665
ff15b665bc052e4d0174fc160616e9a7272342ac
+6
-5
+5
-4
appview/config.go
+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
+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
}