accepts topic from api

Signed-off-by: Derek Anderson <[email protected]>

api/execute.go

@@ -16,7 +16,7 @@ import (
 // ExecuteRequest describes the payload for the REST API request for function execution.
 type ExecuteRequest struct {
 	execute.Request
-	Subgroup string `json:"subgroup,omitempty"`
+	Topic string `json:"topic,omitempty"`
 }
 
 // ExecuteResponse describes the REST API response for function execution.
@@ -47,7 +47,7 @@ func (a *API) Execute(ctx echo.Context) error {
 	}
 
 	// Get the execution result.
-	code, id, results, cluster, err := a.Node.ExecuteFunction(ctx.Request().Context(), execute.Request(req.Request), req.Subgroup)
+	code, id, results, cluster, err := a.Node.ExecuteFunction(ctx.Request().Context(), execute.Request(req.Request), req.Topic)
 	if err != nil {
 		a.Log.Warn().Str("function", req.FunctionID).Err(err).Msg("node failed to execute function")
 	}

models/request/execute.go

@@ -13,7 +13,8 @@ type Execute struct {
 	Type string  `json:"type,omitempty"`
 	From peer.ID `json:"from,omitempty"`
 	Code string  `json:"code,omitempty"`
-
+	Topic string `json:"topic,omitempty"`
+
 	execute.Request // execute request is embedded.
 
 	// RequestID may be set initially, if the execution request is relayed via roll-call.

node/head_execute.go

@@ -35,7 +35,7 @@ func (n *Node) headProcessExecute(ctx context.Context, from peer.ID, payload []b
 
 	log := n.log.With().Str("request", req.RequestID).Str("peer", from.String()).Str("function", req.FunctionID).Logger()
 
-	code, results, cluster, err := n.headExecute(ctx, requestID, req.Request, "")
+	code, results, cluster, err := n.headExecute(ctx, requestID, req.Request, req.Topic)
 	if err != nil {
 		log.Error().Err(err).Msg("execution failed")
 	}