refactor(worker): initialize handlers registry with subjects

fabriziosestito · fabriziosestito · commit c887a419b7de · 2025-06-17T07:56:33.000+02:00
Signed-off-by: Fabrizio Sestito &lt;fabrizio.sestito@suse.com&gt;
diff --git a/cmd/worker/main.go b/cmd/worker/main.go
@@ -74,9 +74,9 @@ func main() { //nolint:funlen // This function is intentionally long to keep the
 	}
 
 	handlers := messaging.HandlerRegistry{
-		messaging.CreateCatalogType: handlers.NewCreateCatalogHandler(registryClientFactory, k8sClient, scheme, logger),
-		messaging.GenerateSBOMType:  handlers.NewGenerateSBOMHandler(k8sClient, scheme, runDir, logger),
-		messaging.ScanSBOMType:      handlers.NewScanSBOMHandler(k8sClient, scheme, runDir, logger),
+		handlers.CreateCatalogSubject: handlers.NewCreateCatalogHandler(registryClientFactory, k8sClient, scheme, logger),
+		handlers.GenerateSBOMSubject:  handlers.NewGenerateSBOMHandler(k8sClient, scheme, runDir, logger),
+		handlers.ScanSBOMSubject:      handlers.NewScanSBOMHandler(k8sClient, scheme, runDir, logger),
 	}
 
 	nc, err := nats.Connect(natsURL,

Original file line number	Diff line number	Diff line change
`@@ -74,9 +74,9 @@ func main() { //nolint:funlen // This function is intentionally long to keep the`
`74`	`74`	`}`
`75`	`75`
`76`	`76`	`handlers := messaging.HandlerRegistry{`
`77`		`- messaging.CreateCatalogType: handlers.NewCreateCatalogHandler(registryClientFactory, k8sClient, scheme, logger),`
`78`		`- messaging.GenerateSBOMType: handlers.NewGenerateSBOMHandler(k8sClient, scheme, runDir, logger),`
`79`		`- messaging.ScanSBOMType: handlers.NewScanSBOMHandler(k8sClient, scheme, runDir, logger),`
	`77`	`+ handlers.CreateCatalogSubject: handlers.NewCreateCatalogHandler(registryClientFactory, k8sClient, scheme, logger),`
	`78`	`+ handlers.GenerateSBOMSubject: handlers.NewGenerateSBOMHandler(k8sClient, scheme, runDir, logger),`
	`79`	`+ handlers.ScanSBOMSubject: handlers.NewScanSBOMHandler(k8sClient, scheme, runDir, logger),`
`80`	`80`	`}`
`81`	`81`
`82`	`82`	`nc, err := nats.Connect(natsURL,`