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