diff options
| author | Fuwn <[email protected]> | 2026-02-08 01:35:41 -0800 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2026-02-08 01:35:41 -0800 |
| commit | b8a9b40f786554e5a49511ce1b2dd2ea7f3db94c (patch) | |
| tree | 23fcdad5c10a7a269286459b4b666120d92f2af7 /services/worker/internal/scheduler/refresh.go | |
| parent | fix: update worker Dockerfile to Go 1.24 to match go.mod requirement (diff) | |
| download | asa.news-b8a9b40f786554e5a49511ce1b2dd2ea7f3db94c.tar.xz asa.news-b8a9b40f786554e5a49511ce1b2dd2ea7f3db94c.zip | |
feat: implement authenticated feed support across worker and web app
Wire up the full authenticated feeds pipeline:
- Worker resolves credentials from Supabase Vault for authenticated feeds
- Worker sets owner_id on entries for per-user dedup
- query_param auth now parses name=value format
- Add-feed dialog shows auth type + credential fields for pro/developer
- Subscribe mutation passes credentials to RPC
- Sidebar and settings show [auth] indicator for authenticated feeds
Diffstat (limited to 'services/worker/internal/scheduler/refresh.go')
| -rw-r--r-- | services/worker/internal/scheduler/refresh.go | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/services/worker/internal/scheduler/refresh.go b/services/worker/internal/scheduler/refresh.go index 229a20f..d1c5d26 100644 --- a/services/worker/internal/scheduler/refresh.go +++ b/services/worker/internal/scheduler/refresh.go @@ -27,16 +27,25 @@ func ProcessRefreshRequest( var ownerIdentifier *string + authenticationConfig := fetcher.AuthenticationConfiguration{} + if feed.Visibility == "authenticated" { - logger.Warn( - "authenticated feed refresh not yet implemented", - "feed_identifier", feed.Identifier, - ) + if feed.AuthenticationType == nil || feed.AuthenticationValue == nil { + logger.Warn( + "authenticated feed missing credentials, skipping", + "feed_identifier", feed.Identifier, + ) - return - } + return + } - authenticationConfig := fetcher.AuthenticationConfiguration{} + authenticationConfig = fetcher.AuthenticationConfiguration{ + AuthenticationType: *feed.AuthenticationType, + AuthenticationValue: *feed.AuthenticationValue, + } + + ownerIdentifier = feed.SubscriberUserIdentifier + } entityTag := "" if feed.EntityTag != nil { |