First green in control server
This commit is contained in:
@@ -1,12 +1,12 @@
|
|||||||
package control
|
package control
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"io"
|
||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"github.com/gorilla/mux"
|
"github.com/gorilla/mux"
|
||||||
|
|
||||||
"github.com/BBVA/kapow/internal/server/model"
|
|
||||||
"github.com/BBVA/kapow/internal/server/user"
|
"github.com/BBVA/kapow/internal/server/user"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -34,8 +34,7 @@ func listRoutes(http.ResponseWriter, *http.Request) {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func addRoute(http.ResponseWriter, *http.Request) {
|
func addRoute(res http.ResponseWriter, req *http.Request) {
|
||||||
var routeSpec model.Route
|
res.WriteHeader(http.StatusCreated)
|
||||||
|
_, _ = io.Copy(res, req.Body)
|
||||||
user.Routes.Append(routeSpec)
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,14 +1,22 @@
|
|||||||
package control
|
package control
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"encoding/json"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/http/httptest"
|
"net/http/httptest"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"github.com/BBVA/kapow/internal/server/model"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestAppendNerRouteFromRequest(t *testing.T) {
|
func TestAppendNewRouteFromRequest(t *testing.T) {
|
||||||
reqPayload := "{}"
|
reqPayload := `{
|
||||||
|
"method": "GET",
|
||||||
|
"url_pattern": "/hello",
|
||||||
|
"entrypoint": null,
|
||||||
|
"command": "echo Hello World | kapow set /response/body"
|
||||||
|
}`
|
||||||
|
|
||||||
req := httptest.NewRequest(http.MethodPost, "/routes", strings.NewReader(reqPayload))
|
req := httptest.NewRequest(http.MethodPost, "/routes", strings.NewReader(reqPayload))
|
||||||
resp := httptest.NewRecorder()
|
resp := httptest.NewRecorder()
|
||||||
@@ -20,8 +28,27 @@ func TestAppendNerRouteFromRequest(t *testing.T) {
|
|||||||
t.Errorf("HTTP status mistmacht. Expected: %d, got: %d", http.StatusCreated, resp.Code)
|
t.Errorf("HTTP status mistmacht. Expected: %d, got: %d", http.StatusCreated, resp.Code)
|
||||||
}
|
}
|
||||||
|
|
||||||
expectedPayload := "{}"
|
// expectedPayload := `{
|
||||||
if resp.Body.String() != expectedPayload {
|
// "method": "GET",
|
||||||
t.Errorf("HTTP status mistmacht. Expected: %d, got: %d", http.StatusCreated, resp.Code)
|
// "url_pattern": "/hello",
|
||||||
}
|
// "entrypoint": null,
|
||||||
|
// "command": "echo Hello World | kapow set /response/body"
|
||||||
|
//}`
|
||||||
|
respJsonRoute := model.Route{}
|
||||||
|
json.Unmarshal(resp.Body.Bytes(), &respJsonRoute)
|
||||||
|
if respJsonRoute.Method != "GET" {
|
||||||
|
t.Errorf("Method missmatch. Expected: %s, got: %s", "GET", respJsonRoute.Method)
|
||||||
|
}
|
||||||
|
|
||||||
|
if respJsonRoute.Entrypoint != "" {
|
||||||
|
t.Errorf("Entrypoint missmatch. Expected: %s, got: %s", "", respJsonRoute.Entrypoint)
|
||||||
|
}
|
||||||
|
|
||||||
|
if respJsonRoute.Command != "echo Hello World | kapow set /response/body" {
|
||||||
|
t.Errorf("Command missmatch. Expected: %s, got: %s", "echo Hello World | kapow set /response/body", respJsonRoute.Command)
|
||||||
|
}
|
||||||
|
|
||||||
|
if respJsonRoute.Pattern != "/hello" {
|
||||||
|
t.Errorf("Pattern missmatch. Expected: %s, got: %s", "/hello", respJsonRoute.Pattern)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user