core/services/chainlink: log warn instead of error if CSA key not ava…

…ilable for feeds service (#10543)
smartcontractkit · Sep 18, 2023 · 73966ef · 73966ef
1 parent d4e9b28
commit 73966ef
Showing 1 changed file with 23 additions and 19 deletions.
diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go
@@ -419,26 +419,30 @@ func NewApplication(opts ApplicationOpts) (Application, error) {
 		}
 	}
 
-	var feedsService feeds.Service
+	var feedsService feeds.Service = &feeds.NullService{}
 	if cfg.Feature().FeedsManager() {
-		feedsORM := feeds.NewORM(db, opts.Logger, cfg.Database())
-		feedsService = feeds.NewService(
-			feedsORM,
-			jobORM,
-			db,
-			jobSpawner,
-			keyStore,
-			cfg.Insecure(),
-			cfg.JobPipeline(),
-			cfg.OCR(),
-			cfg.OCR2(),
-			cfg.Database(),
-			legacyEVMChains,
-			globalLogger,
-			opts.Version,
-		)
-	} else {
-		feedsService = &feeds.NullService{}
+		if keys, err := opts.KeyStore.CSA().GetAll(); err != nil {
+			globalLogger.Warn("[Feeds Service] Unable to start without CSA key", "err", err)
+		} else if len(keys) == 0 {
+			globalLogger.Warn("[Feeds Service] Unable to start without CSA key")
+		} else {
+			feedsORM := feeds.NewORM(db, opts.Logger, cfg.Database())
+			feedsService = feeds.NewService(
+				feedsORM,
+				jobORM,
+				db,
+				jobSpawner,
+				keyStore,
+				cfg.Insecure(),
+				cfg.JobPipeline(),
+				cfg.OCR(),
+				cfg.OCR2(),
+				cfg.Database(),
+				legacyEVMChains,
+				globalLogger,
+				opts.Version,
+			)
+		}
 	}
 
 	healthChecker := services.NewChecker()