2017-06-15 08:03:38 +02:00
|
|
|
package middleware
|
|
|
|
|
|
|
|
import (
|
2018-02-21 20:44:17 +02:00
|
|
|
"errors"
|
2017-06-15 08:03:38 +02:00
|
|
|
"io/ioutil"
|
|
|
|
"net/http"
|
|
|
|
"net/http/httptest"
|
|
|
|
"strings"
|
|
|
|
"testing"
|
|
|
|
|
|
|
|
"github.com/labstack/echo"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
)
|
|
|
|
|
|
|
|
func TestBodyDump(t *testing.T) {
|
|
|
|
e := echo.New()
|
|
|
|
hw := "Hello, World!"
|
|
|
|
req := httptest.NewRequest(echo.POST, "/", strings.NewReader(hw))
|
|
|
|
rec := httptest.NewRecorder()
|
|
|
|
c := e.NewContext(req, rec)
|
|
|
|
h := func(c echo.Context) error {
|
|
|
|
body, err := ioutil.ReadAll(c.Request().Body)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
return c.String(http.StatusOK, string(body))
|
|
|
|
}
|
|
|
|
|
|
|
|
requestBody := ""
|
|
|
|
responseBody := ""
|
|
|
|
mw := BodyDump(func(c echo.Context, reqBody, resBody []byte) {
|
|
|
|
requestBody = string(reqBody)
|
|
|
|
responseBody = string(resBody)
|
|
|
|
})
|
2018-02-21 20:44:17 +02:00
|
|
|
|
2017-06-15 08:03:38 +02:00
|
|
|
if assert.NoError(t, mw(h)(c)) {
|
|
|
|
assert.Equal(t, requestBody, hw)
|
|
|
|
assert.Equal(t, responseBody, hw)
|
|
|
|
assert.Equal(t, http.StatusOK, rec.Code)
|
|
|
|
assert.Equal(t, hw, rec.Body.String())
|
|
|
|
}
|
2018-02-21 20:44:17 +02:00
|
|
|
|
|
|
|
// Must set default skipper
|
|
|
|
BodyDumpWithConfig(BodyDumpConfig{
|
|
|
|
Skipper: nil,
|
|
|
|
Handler: func(c echo.Context, reqBody, resBody []byte) {
|
|
|
|
requestBody = string(reqBody)
|
|
|
|
responseBody = string(resBody)
|
|
|
|
},
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestBodyDumpFails(t *testing.T) {
|
|
|
|
e := echo.New()
|
|
|
|
hw := "Hello, World!"
|
|
|
|
req := httptest.NewRequest(echo.POST, "/", strings.NewReader(hw))
|
|
|
|
rec := httptest.NewRecorder()
|
|
|
|
c := e.NewContext(req, rec)
|
|
|
|
h := func(c echo.Context) error {
|
|
|
|
return errors.New("some error")
|
|
|
|
}
|
|
|
|
|
|
|
|
requestBody := ""
|
|
|
|
responseBody := ""
|
|
|
|
mw := BodyDump(func(c echo.Context, reqBody, resBody []byte) {
|
|
|
|
requestBody = string(reqBody)
|
|
|
|
responseBody = string(resBody)
|
|
|
|
})
|
|
|
|
|
|
|
|
if !assert.Error(t, mw(h)(c)) {
|
|
|
|
t.FailNow()
|
|
|
|
}
|
|
|
|
|
|
|
|
assert.Panics(t, func() {
|
|
|
|
mw = BodyDumpWithConfig(BodyDumpConfig{
|
|
|
|
Skipper: nil,
|
|
|
|
Handler: nil,
|
|
|
|
})
|
|
|
|
})
|
|
|
|
|
|
|
|
assert.NotPanics(t, func() {
|
|
|
|
mw = BodyDumpWithConfig(BodyDumpConfig{
|
|
|
|
Skipper: func(c echo.Context) bool {
|
|
|
|
return true
|
|
|
|
},
|
|
|
|
Handler: func(c echo.Context, reqBody, resBody []byte) {
|
|
|
|
requestBody = string(reqBody)
|
|
|
|
responseBody = string(resBody)
|
|
|
|
},
|
|
|
|
})
|
|
|
|
|
|
|
|
if !assert.Error(t, mw(h)(c)) {
|
|
|
|
t.FailNow()
|
|
|
|
}
|
|
|
|
})
|
2017-06-15 08:03:38 +02:00
|
|
|
}
|