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