This repository has no description
0

Configure Feed

Select the types of activity you want to include in your feed.

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