[core] DCS: send enabled link IDs for selected detectors

It is activated with '<det>_dcs_send_enabled_links' variable.

OCTRL-980

Author: knopers8

core/integration/dcs/dcsutil.go

@@ -26,6 +26,8 @@ package dcs
 
 import (
 	"fmt"
+	"github.com/AliceO2Group/Control/common/logger/infologger"
+	"github.com/AliceO2Group/Control/core/the"
 	"strings"
 
 	dcspb "github.com/AliceO2Group/Control/core/integration/dcs/protos"
@@ -51,6 +53,24 @@ func resolveDefaults(detectorArgMap map[string]string, varStack map[string]strin
 	return detectorArgMap
 }
 
+func addEnabledLinks(detectorArgMap map[string]string, varStack map[string]string, ecsDetector string, theLog *logrus.Entry) map[string]string {
+	sendDetLinks, ok := varStack[ecsDetector+"_dcs_send_enabled_links"]
+	if !ok || sendDetLinks != "true" {
+		return detectorArgMap
+	}
+	linkIDs, err := the.ConfSvc().GetAliasedLinkIDsForDetector(ecsDetector, true)
+	if err != nil {
+		theLog.WithError(err).Errorf("failed to get aliased link IDs for detector '%s'", ecsDetector)
+		return detectorArgMap
+	}
+	linksJoined := strings.Join(linkIDs, ",")
+	theLog.WithField(infologger.Level, infologger.IL_Devel).
+		Infof("adding enabled link IDs for detector '%s' to DCS payload '%s'", ecsDetector, linksJoined)
+	detectorArgMap["ddl_list"] = linksJoined
+
+	return detectorArgMap
+}
+
 func ecsToDcsDetector(ecsDetector string) (dcspb.Detector, error) {
 	var err error
 	det := strings.ToUpper(strings.TrimSpace(ecsDetector))

core/integration/dcs/plugin.go

@@ -664,6 +664,11 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 					WithField("call", "PrepareForRun").
 					WithField("detector", ecsDet))
 
+			detectorArgMap = addEnabledLinks(detectorArgMap, varStack, ecsDet,
+				log.WithField("partition", envId).
+					WithField("call", "PrepareForRun").
+					WithField("detector", ecsDet))
+
 			in.Detectors[i] = &dcspb.DetectorOperationRequest{
 				Detector:        dcsDet,
 				ExtraParameters: detectorArgMap,
@@ -1365,6 +1370,12 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 					WithField("detector", ecsDet).
 					WithField("run", runNumber64))
 
+			detectorArgMap = addEnabledLinks(detectorArgMap, varStack, ecsDet,
+				log.WithField("partition", envId).
+					WithField("call", "StartOfRun").
+					WithField("detector", ecsDet).
+					WithField("run", runNumber64))
+
 			in.Detectors[i] = &dcspb.DetectorOperationRequest{
 				Detector:        dcsDet,
 				ExtraParameters: detectorArgMap,