fixing Sampler request expected input data

apps/go/manager/activities/analyze_node.go

@@ -18,6 +18,7 @@ func (aCtx *Ctx) AnalyzeNode(ctx context.Context, params types.AnalyzeNodeParams
 
 	var result types.AnalyzeNodeResults
 	result.Success = false
+	result.IsNew = false
 
 	// Get logger
 	l := aCtx.App.Logger
@@ -41,6 +42,7 @@ func (aCtx *Ctx) AnalyzeNode(ctx context.Context, params types.AnalyzeNodeParams
 		// Create entry in MongoDB
 		l.Debug().Bool("found", found).Msg("Creating empty node entry.")
 		thisNodeData.Init(params, l)
+		result.IsNew = true
 
 	} else {
 		// If the node entry exist we must cycle and check for pending results
@@ -103,7 +105,7 @@ func (aCtx *Ctx) AnalyzeNode(ctx context.Context, params types.AnalyzeNodeParams
 				}
 				defer cursor.Close(ctxM)
 				var inQueue uint32 = 0
-				var blackList []int
+				blackList := make([]int, 0)
 				for cursor.Next(ctxM) {
 					var taskReq types.TaskRequestRecord
 					if err := cursor.Decode(&taskReq); err != nil {

apps/go/manager/activities/trigger_sampler.go

@@ -20,8 +20,8 @@ func (aCtx *Ctx) TriggerSampler(ctx context.Context, params types.TriggerSampler
 	result.Success = false
 
 	samplerParams := types.SamplerWorkflowParams{
-		Evaluation: params.Trigger.Framework,
-		Task:       params.Trigger.Task,
+		Framework: params.Trigger.Framework,
+		Task:      params.Trigger.Task,
 		RequesterArgs: types.RequesterArgs{
 			Address: params.Trigger.Address,
 			Service: params.Trigger.Service,

apps/go/manager/types/activities.go

@@ -28,6 +28,7 @@ type AnalyzeNodeParams struct {
 
 type AnalyzeNodeResults struct {
 	Success  bool          `json:"success"`
+	IsNew    bool          `json:"is_new"`
 	Triggers []TaskTrigger `json:"task_trigger"`
 }
 

apps/go/manager/types/node_task_request.go

@@ -9,10 +9,10 @@ import (
 // ------------------------------------------------------------------------------
 
 type RequesterArgs struct {
-	Address string `bson:"address"`
-	Service string `bson:"service"`
-	Method  string `bson:"method"`
-	Path    string `bson:"path"`
+	Address string `json:"address"`
+	Service string `json:"service"`
+	Method  string `json:"method"`
+	Path    string `json:"path"`
 }
 
 // A pending request already processed by the Sampler

apps/go/manager/types/workflows.go

@@ -23,7 +23,7 @@ type NodeAnalysisChanResponse struct {
 }
 
 type SamplerWorkflowParams struct {
-	Evaluation    string        `json:"evaluation"`
+	Framework     string        `json:"framework"`
 	Task          string        `json:"tasks"`
 	RequesterArgs RequesterArgs `json:"requester_args"`
 	Blacklist     []int         `json:"blacklist"`

apps/go/manager/workflows/node_manager.go

@@ -114,6 +114,11 @@ func (wCtx *Ctx) NodeManager(ctx workflow.Context, params types.NodeManagerParam
 		response := <-nodeAnalysisResultsChan
 		// Append to triggers
 		allTriggers = append(allTriggers, response.Response.Triggers...)
+		// Keep count
+		// Update workflow result
+		if response.Response.IsNew {
+			result.NewNodes += 1
+		}
 	}
 
 	// -------------------------------------------------------------------------