summaryrefslogtreecommitdiff
path: root/services/worker/internal/scheduler/refresh.go
diff options
context:
space:
mode:
authorFuwn <[email protected]>2026-02-08 01:35:41 -0800
committerFuwn <[email protected]>2026-02-08 01:35:41 -0800
commitb8a9b40f786554e5a49511ce1b2dd2ea7f3db94c (patch)
tree23fcdad5c10a7a269286459b4b666120d92f2af7 /services/worker/internal/scheduler/refresh.go
parentfix: update worker Dockerfile to Go 1.24 to match go.mod requirement (diff)
downloadasa.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.go23
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 {