alihan/fn-serverless
1
0
Fork 0
mirror of https://github.com/fnproject/fn.git synced 2022-10-28 21:29:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

added json validation and route not found

Browse Source
This commit is contained in:
Pedro Nasser
2016-07-30 18:57:59 -03:00
parent d2babb33ce
commit 616d9df8fa
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
api/server/router/runner.go
View File

@@ -6,6 +6,8 @@ import (
"strings" "strings"
"time" "time"
"encoding/json"
"github.com/Sirupsen/logrus" "github.com/Sirupsen/logrus"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"github.com/iron-io/functions/api/models" "github.com/iron-io/functions/api/models"
@@ -34,6 +36,15 @@ func handleRunner(c *gin.Context) {
} }
} }
if len(payload) > 0 {
var emptyJson map[string]interface{}
if err := json.Unmarshal(payload, &emptyJson); err != nil {
log.WithError(err).Error(models.ErrInvalidJSON)
c.JSON(http.StatusBadRequest, simpleError(models.ErrInvalidJSON))
return
}
}
log.WithField("payload", string(payload)).Debug("Got payload") log.WithField("payload", string(payload)).Debug("Got payload")
appName := c.Param("app") appName := c.Param("app")
@@ -60,6 +71,11 @@ func handleRunner(c *gin.Context) {
c.JSON(http.StatusInternalServerError, simpleError(models.ErrRoutesList)) c.JSON(http.StatusInternalServerError, simpleError(models.ErrRoutesList))
} }
if routes == nil || len(routes) == 0 {
log.WithError(err).Error(models.ErrRunnerRouteNotFound)
c.JSON(http.StatusNotFound, simpleError(models.ErrRunnerRouteNotFound))
}
log.WithField("routes", routes).Debug("Got routes from datastore") log.WithField("routes", routes).Debug("Got routes from datastore")
for _, el := range routes { for _, el := range routes {