alice.pds.demo.boltless.dev
This repository has no description
1package config
2
3import (
4 "context"
5 "fmt"
6 "net/url"
7 "strings"
8 "time"
9
10 "github.com/sethvargo/go-envconfig"
11)
12
13type CoreConfig struct {
14 CookieSecret string `env:"COOKIE_SECRET, default=00000000000000000000000000000000"`
15 DbPath string `env:"DB_PATH, default=appview.db"`
16 ListenAddr string `env:"LISTEN_ADDR, default=0.0.0.0:3000"`
17 AppviewHost string `env:"APPVIEW_HOST, default=tangled.org"`
18 AppviewName string `env:"APPVIEW_NAME, default=Tangled"`
19 Dev bool `env:"DEV, default=false"`
20 DisallowedNicknamesFile string `env:"DISALLOWED_NICKNAMES_FILE"`
21
22 // temporarily, to add users to default knot and spindle
23 AppPassword string `env:"APP_PASSWORD"`
24
25 // uhhhh this is because knot1 is under icy's did
26 TmpAltAppPassword string `env:"ALT_APP_PASSWORD"`
27}
28
29func (c *CoreConfig) UseTLS() bool {
30 return !c.Dev
31}
32
33func (c *CoreConfig) BaseUrl() string {
34 if c.UseTLS() {
35 return "https://" + c.AppviewHost
36 }
37 return "http://" + c.AppviewHost
38}
39
40type OAuthConfig struct {
41 ClientSecret string `env:"CLIENT_SECRET"`
42 ClientKid string `env:"CLIENT_KID"`
43}
44
45type PlcConfig struct {
46 PLCURL string `env:"URL, default=https://plc.directory"`
47}
48
49type KnotMirrorConfig struct {
50 Url string `env:"URL, default=https://mirror.tangled.network"`
51}
52
53type JetstreamConfig struct {
54 Endpoint string `env:"ENDPOINT, default=wss://jetstream1.us-east.bsky.network/subscribe"`
55}
56
57type ConsumerConfig struct {
58 RetryInterval time.Duration `env:"RETRY_INTERVAL, default=60s"`
59 MaxRetryInterval time.Duration `env:"MAX_RETRY_INTERVAL, default=120m"`
60 ConnectionTimeout time.Duration `env:"CONNECTION_TIMEOUT, default=5s"`
61 WorkerCount int `env:"WORKER_COUNT, default=64"`
62 QueueSize int `env:"QUEUE_SIZE, default=100"`
63}
64
65type ResendConfig struct {
66 ApiKey string `env:"API_KEY"`
67 SentFrom string `env:"SENT_FROM, default=noreply@notifs.tangled.sh"`
68 NewsletterSegmentId string `env:"NEWSLETTER_SEGMENT_ID"`
69}
70
71type CamoConfig struct {
72 Host string `env:"HOST, default=https://camo.tangled.sh"`
73 SharedSecret string `env:"SHARED_SECRET"`
74}
75
76func (c *CamoConfig) Enabled() bool {
77 return c.SharedSecret != ""
78}
79
80type AvatarConfig struct {
81 Host string `env:"HOST, default=https://avatar.tangled.sh"`
82 SharedSecret string `env:"SHARED_SECRET"`
83}
84
85type PosthogConfig struct {
86 ApiKey string `env:"API_KEY"`
87 Endpoint string `env:"ENDPOINT, default=https://eu.i.posthog.com"`
88}
89
90type RedisConfig struct {
91 Addr string `env:"ADDR, default=localhost:6379"`
92 Password string `env:"PASS"`
93 DB int `env:"DB, default=0"`
94}
95
96type PdsConfig struct {
97 Host string `env:"HOST, default=https://tngl.sh"`
98 UserDomain string `env:"USER_DOMAIN, default=.tngl.sh"`
99 AdminSecret string `env:"ADMIN_SECRET"`
100}
101
102func (p *PdsConfig) IsTnglShUser(pdsHost string) bool {
103 return strings.TrimRight(pdsHost, "/") == strings.TrimRight(p.Host, "/")
104}
105
106type R2Config struct {
107 AccessKeyID string `env:"ACCESS_KEY_ID"`
108 SecretAccessKey string `env:"SECRET_ACCESS_KEY"`
109 Bucket string `env:"BUCKET, default=tangled-sites"`
110}
111
112type TurnstileConfig struct {
113 SiteKey string `env:"SITE_KEY"`
114 SecretKey string `env:"SECRET_KEY"`
115}
116
117type KVConfig struct {
118 NamespaceId string `env:"NAMESPACE_ID"`
119 ApiToken string `env:"API_TOKEN"`
120}
121
122type Cloudflare struct {
123 // Legacy top-level API token. For services like Workers KV, we
124 // now use a scoped Account API token configured under the relevant
125 // sub-struct.
126 ApiToken string `env:"API_TOKEN"`
127 ZoneId string `env:"ZONE_ID"`
128 AccountId string `env:"ACCOUNT_ID"`
129
130 KV KVConfig `env:",prefix=KV_"`
131 Turnstile TurnstileConfig `env:",prefix=TURNSTILE_"`
132 R2 R2Config `env:",prefix=R2_"`
133}
134
135type SitesConfig struct {
136 Domain string `env:"DOMAIN, default=tngl.io"`
137}
138
139type LabelConfig struct {
140 DefaultLabelDefs []string `env:"DEFAULTS, default=at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/wontfix,at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/good-first-issue,at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/duplicate,at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/documentation,at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/assignee"` // delimiter=,
141 GoodFirstIssue string `env:"GFI, default=at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/good-first-issue"`
142}
143
144type BlueskyConfig struct {
145 UpdateInterval time.Duration `env:"UPDATE_INTERVAL, default=1h"`
146}
147
148type OgreConfig struct {
149 Host string `env:"HOST, default=https://ogre.tangled.network"`
150}
151
152func (cfg RedisConfig) ToURL() string {
153 u := &url.URL{
154 Scheme: "redis",
155 Host: cfg.Addr,
156 Path: fmt.Sprintf("/%d", cfg.DB),
157 }
158
159 if cfg.Password != "" {
160 u.User = url.UserPassword("", cfg.Password)
161 }
162
163 return u.String()
164}
165
166type Config struct {
167 Core CoreConfig `env:",prefix=TANGLED_"`
168 Jetstream JetstreamConfig `env:",prefix=TANGLED_JETSTREAM_"`
169 Knotstream ConsumerConfig `env:",prefix=TANGLED_KNOTSTREAM_"`
170 Spindlestream ConsumerConfig `env:",prefix=TANGLED_SPINDLESTREAM_"`
171 Resend ResendConfig `env:",prefix=TANGLED_RESEND_"`
172 Posthog PosthogConfig `env:",prefix=TANGLED_POSTHOG_"`
173 Camo CamoConfig `env:",prefix=TANGLED_CAMO_"`
174 Avatar AvatarConfig `env:",prefix=TANGLED_AVATAR_"`
175 OAuth OAuthConfig `env:",prefix=TANGLED_OAUTH_"`
176 Redis RedisConfig `env:",prefix=TANGLED_REDIS_"`
177 Plc PlcConfig `env:",prefix=TANGLED_PLC_"`
178 Pds PdsConfig `env:",prefix=TANGLED_PDS_"`
179 Cloudflare Cloudflare `env:",prefix=TANGLED_CLOUDFLARE_"`
180 Label LabelConfig `env:",prefix=TANGLED_LABEL_"`
181 Bluesky BlueskyConfig `env:",prefix=TANGLED_BLUESKY_"`
182 Sites SitesConfig `env:",prefix=TANGLED_SITES_"`
183 KnotMirror KnotMirrorConfig `env:",prefix=TANGLED_KNOTMIRROR_"`
184 Ogre OgreConfig `env:",prefix=TANGLED_OGRE_"`
185}
186
187func LoadConfig(ctx context.Context) (*Config, error) {
188 var cfg Config
189 err := envconfig.Process(ctx, &cfg)
190 if err != nil {
191 return nil, err
192 }
193
194 return &cfg, nil
195}