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