Removed 'common' from map-executor and added 'getActions' to rest-con…

…troller

The 'common' dependency was removed from map-executor.go and the 'for-each' function is commented out. Furthermore, a 'getActions' function was added in rest-controller.go. This provides a new route '/action' that generates a JSON containing all available actions with their inputs and outputs.

internal/controllers/rest-controller.go

@@ -3,7 +3,10 @@ package controllers
 import (
 	"fmt"
 	"github.com/PiotrFerenc/mash2/api/types"
+	"github.com/PiotrFerenc/mash2/cmd/worker/actions"
+	"github.com/PiotrFerenc/mash2/internal/configuration"
 	Message "github.com/PiotrFerenc/mash2/internal/consts"
+	"github.com/PiotrFerenc/mash2/internal/executor"
 	"github.com/PiotrFerenc/mash2/internal/repositories"
 	"github.com/PiotrFerenc/mash2/internal/services"
 	"github.com/gin-gonic/gin"
@@ -38,6 +41,7 @@ func CreateRestController(pipelineService services.PipelineService, repository r
 func (controller *controller) Run(address, port string) error {
 	server := gin.Default()
 	server.GET("/process/:id", getByIdHandler(controller))
+	server.GET("/action", getActions(controller))
 	server.POST("/execute", executeHandler(controller))
 
 	err := server.Run(fmt.Sprintf(`%s:%s`, address, port))
@@ -48,6 +52,35 @@ func (controller *controller) Run(address, port string) error {
 
 }
 
+func getActions(c *controller) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		a := executor.CreateActionMap(&configuration.Config{})
+		actionsList := make([]Actions, 0, len(a))
+		for name, action := range a {
+			actionsList = append(actionsList, Actions{
+				Name:    name,
+				Inputs:  getPropertyNames(action.Inputs()),
+				Outputs: getPropertyNames(action.Outputs()),
+			})
+		}
+		c.JSON(http.StatusOK, gin.H{"actions": actionsList})
+		return
+	}
+}
+func getPropertyNames(properties []actions.Property) []string {
+	propertyNames := make([]string, len(properties))
+	for i, prop := range properties {
+		propertyNames[i] = prop.Name
+	}
+	return propertyNames
+}
+
+type Actions struct {
+	Name    string   `json:"name,omitempty"`
+	Inputs  []string `json:"inputs,omitempty"`
+	Outputs []string `json:"outputs,omitempty"`
+}
+
 // getByIdHandler is a handler function that retrieves a process by its ID and returns
 // the status of the process.
 // It takes a controller instance as a parameter and returns a function that has a

internal/executor/map-executor.go

@@ -5,7 +5,6 @@ import (
 	"errors"
 	"fmt"
 	"github.com/PiotrFerenc/mash2/cmd/worker/actions"
-	"github.com/PiotrFerenc/mash2/cmd/worker/actions/common"
 	"github.com/PiotrFerenc/mash2/cmd/worker/actions/docker"
 	"github.com/PiotrFerenc/mash2/cmd/worker/actions/file"
 	"github.com/PiotrFerenc/mash2/cmd/worker/actions/git"
@@ -124,6 +123,6 @@ func CreateActionMap(config *configuration.Config) map[string]actions.Action {
 		"docker-run":  docker.CreateDockerRun(),
 		"file-delete": file.CreateDeleteFileAction(config),
 		"file-append": file.CreateAppendContentToFile(config),
-		"for-each":    common.CreateForEachLoop(),
+		//"for-each":    common.CreateForEachLoop(),
 	}
 }