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