Inputs for HTTP api

krabapi/agent.go

@@ -24,7 +24,14 @@ func (a *Agent) Run() error {
 		switch cmd.HttpMethod() {
 		case http.MethodPost:
 			api.POST(path, func(c *gin.Context) {
-				resp, err := cmd.Do(c.Request.Context(), krab.CmdOpts{})
+
+				inputs, err := bindInputs(c)
+				if err != nil {
+					c.JSON(http.StatusUnprocessableEntity, gin.H{"error": err.Error()})
+					return
+				}
+
+				resp, err := cmd.Do(c.Request.Context(), krab.CmdOpts{Inputs: inputs})
 				if err != nil {
 					c.JSON(http.StatusUnprocessableEntity, gin.H{"error": err.Error()})
 					return
@@ -38,7 +45,15 @@ func (a *Agent) Run() error {
 			})
 		case http.MethodGet:
 			api.GET(path, func(c *gin.Context) {
-				resp, err := cmd.Do(c.Request.Context(), krab.CmdOpts{})
+				c.Header("Cache-Control", "no-store")
+
+				inputs, err := bindInputs(c)
+				if err != nil {
+					c.JSON(http.StatusUnprocessableEntity, gin.H{"error": err.Error()})
+					return
+				}
+
+				resp, err := cmd.Do(c.Request.Context(), krab.CmdOpts{Inputs: inputs})
 				if err != nil {
 					c.JSON(http.StatusUnprocessableEntity, gin.H{"error": err.Error()})
 					return

krabapi/params.go

@@ -0,0 +1,29 @@
+package krabapi
+
+import (
+	"fmt"
+
+	"github.com/gin-gonic/gin"
+	"github.com/ohkrab/krab/krab"
+)
+
+func bindInputs(c *gin.Context) (krab.Inputs, error) {
+	params := map[string]interface{}{}
+	if c.Request.ContentLength == 0 {
+		return krab.Inputs{}, nil
+	}
+	err := c.BindJSON(&params)
+	if err != nil {
+		return krab.Inputs{}, fmt.Errorf("Can't bind inputs: %w", err)
+	}
+	inputs, ok := params["inputs"]
+	if !ok {
+		return krab.Inputs{}, nil
+	}
+
+	if inputs, ok := inputs.(map[string]interface{}); ok {
+		return krab.Inputs(inputs), nil
+	}
+
+	return krab.Inputs{}, fmt.Errorf("Failed to fetch inputs")
+}