diff --git a/internal/server/data/server.go b/internal/server/data/server.go index 60ccf07..238b60c 100644 --- a/internal/server/data/server.go +++ b/internal/server/data/server.go @@ -1,6 +1,7 @@ package data import ( + "log" "net/http" "github.com/gorilla/mux" @@ -22,3 +23,28 @@ func configRouter(rs []routeSpec) (r *mux.Router) { func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusBadRequest) }) return r } + +func Run(bindAddr string) { + rs := []routeSpec{ + // request + {"/handlers/{handlerID}/request/method", "GET", getRequestMethod}, + {"/handlers/{handlerID}/request/host", "GET", getRequestHost}, + {"/handlers/{handlerID}/request/path", "GET", getRequestPath}, + {"/handlers/{handlerID}/request/matches/{name}", "GET", getRequestMatches}, + {"/handlers/{handlerID}/request/params/{name}", "GET", getRequestParams}, + {"/handlers/{handlerID}/request/headers/{name}", "GET", getRequestHeaders}, + {"/handlers/{handlerID}/request/cookies/{name}", "GET", getRequestCookies}, + {"/handlers/{handlerID}/request/form/{name}", "GET", getRequestForm}, + {"/handlers/{handlerID}/request/files/{name}/filename", "GET", getRequestFileName}, + {"/handlers/{handlerID}/request/files/{name}/content", "GET", getRequestFileContent}, + {"/handlers/{handlerID}/request/body", "GET", getRequestBody}, + + // response + {"/handlers/{handlerID}/response/status", "PUT", lockResponseWriter(setResponseStatus)}, + {"/handlers/{handlerID}/response/headers/name", "PUT", lockResponseWriter(setResponseHeaders)}, + {"/handlers/{handlerID}/response/cookies/name", "PUT", lockResponseWriter(setResponseCookies)}, + {"/handlers/{handlerID}/response/body", "PUT", lockResponseWriter(setResponseBody)}, + {"/handlers/{handlerID}/response/stream", "PUT", lockResponseWriter(setResponseBody)}, + } + log.Fatal(http.ListenAndServe(bindAddr, configRouter(rs))) +} diff --git a/internal/server/data/server_test.go b/internal/server/data/server_test.go index c61a2ed..74b728c 100644 --- a/internal/server/data/server_test.go +++ b/internal/server/data/server_test.go @@ -12,7 +12,7 @@ import ( func TestConfigRouterReturnsRouterWithDecoratedRoutes(t *testing.T) { var handlerID string - list := []routeSpec{ + rs := []routeSpec{ { "/handlers/{handlerID}/dummy", "GET", @@ -21,7 +21,7 @@ func TestConfigRouterReturnsRouterWithDecoratedRoutes(t *testing.T) { } Handlers = New() Handlers.Add(&model.Handler{ID: "FOO"}) - m := configRouter(list) + m := configRouter(rs) m.ServeHTTP(httptest.NewRecorder(), httptest.NewRequest("GET", "/handlers/FOO/dummy", nil)) diff --git a/internal/server/server_test.go b/internal/server/server_test.go deleted file mode 100644 index d104143..0000000 --- a/internal/server/server_test.go +++ /dev/null @@ -1,23 +0,0 @@ -package server_test - -import ( - "testing" - - "github.com/BBVA/kapow/internal/server" -) - -func TestStartServerWhenInvalidBindAddrReturnsError(t *testing.T) { - - err := server.StartServer("foo;bar", "", "", true) - if err == nil { - t.Errorf("Expected error not found") - } -} - -func TestStartServerWhenInvalidPortNumberReturnsError(t *testing.T) { - - err := server.StartServer("0.0.0.0:bar", "", "", true) - if err == nil { - t.Errorf("Expected error not found") - } -}