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