From 32c30194c414937ac33f0aaea8c096b65d7df051 Mon Sep 17 00:00:00 2001 From: Samuel Enocsson Date: Mon, 12 Oct 2026 18:43:20 +0200 Subject: [PATCH] feat(master): wire jobs into the master (#7) --- cmd/master/main.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/cmd/master/main.go b/cmd/master/main.go index 68d0287..c942ff4 100644 --- a/cmd/master/main.go +++ b/cmd/master/main.go @@ -19,6 +19,7 @@ import ( "github.com/shcizo/package-updater/internal/master/config" "github.com/shcizo/package-updater/internal/master/events" "github.com/shcizo/package-updater/internal/master/hub" + "github.com/shcizo/package-updater/internal/master/jobs" "github.com/shcizo/package-updater/internal/master/store" "github.com/shcizo/package-updater/internal/master/web" "github.com/shcizo/package-updater/internal/master/webauth" @@ -66,6 +67,7 @@ func run() error { broker := events.NewBroker() agentHub := hub.New(st, broker, logger) + jobService := jobs.New(st, agentHub, broker, cfg.AgentImage, logger) provider, err := webauth.NewOIDCProvider(ctx, webauth.OIDCConfig{ Issuer: cfg.OIDCIssuer, ClientID: cfg.OIDCClientID, ClientSecret: cfg.OIDCClientSecret, @@ -76,7 +78,7 @@ func run() error { } auth := webauth.New(provider, st, cfg.AllowedGroup, strings.HasPrefix(cfg.PublicURL, "https://"), logger) - ui, err := web.New(st, agentHub, nil, broker, web.Config{ // jobs is nil: wired in W3-4 + ui, err := web.New(st, agentHub, jobService, broker, web.Config{ AgentURL: cfg.AgentURL, MasterKey: fingerprint, AgentImage: cfg.AgentImage, }, logger) if err != nil {