A vibe coded tangled fork which supports pijul.
at 8d635ac425c4b97df1061b38a9b3c24d70189e64 175 lines 5.7 kB view raw
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}