2015-05-12 00:43:54 +02:00
|
|
|
package middleware
|
2015-05-20 23:38:51 +02:00
|
|
|
|
|
|
|
import (
|
2015-10-21 22:39:51 +02:00
|
|
|
"bytes"
|
2015-05-31 00:20:36 +02:00
|
|
|
"errors"
|
2015-05-20 23:38:51 +02:00
|
|
|
"net/http"
|
|
|
|
"testing"
|
2015-09-18 01:17:54 +02:00
|
|
|
|
|
|
|
"github.com/labstack/echo"
|
2016-01-29 09:46:11 +02:00
|
|
|
"github.com/labstack/echo/test"
|
2016-02-05 05:29:49 +02:00
|
|
|
"github.com/labstack/gommon/log"
|
2015-10-21 22:39:51 +02:00
|
|
|
"github.com/stretchr/testify/assert"
|
2015-05-20 23:38:51 +02:00
|
|
|
)
|
|
|
|
|
2016-02-08 09:02:37 +02:00
|
|
|
func TestLog(t *testing.T) {
|
2015-09-18 01:17:54 +02:00
|
|
|
// Note: Just for the test coverage, not a real test.
|
2015-05-20 23:38:51 +02:00
|
|
|
e := echo.New()
|
2016-01-29 09:46:11 +02:00
|
|
|
req := test.NewRequest(echo.GET, "/", nil)
|
2016-02-05 00:40:08 +02:00
|
|
|
rec := test.NewResponseRecorder()
|
|
|
|
c := echo.NewContext(req, rec, e)
|
2015-12-04 03:23:53 +02:00
|
|
|
h := func(c echo.Context) error {
|
2015-09-18 01:17:54 +02:00
|
|
|
return c.String(http.StatusOK, "test")
|
|
|
|
}
|
2016-02-08 09:02:37 +02:00
|
|
|
mw := Log()(h)
|
|
|
|
|
|
|
|
// Status 2xx
|
|
|
|
mw(c)
|
2015-09-18 01:17:54 +02:00
|
|
|
|
2015-05-30 19:54:55 +02:00
|
|
|
// Status 3xx
|
2016-02-05 00:40:08 +02:00
|
|
|
rec = test.NewResponseRecorder()
|
|
|
|
c = echo.NewContext(req, rec, e)
|
2015-12-04 03:23:53 +02:00
|
|
|
h = func(c echo.Context) error {
|
2015-05-30 19:54:55 +02:00
|
|
|
return c.String(http.StatusTemporaryRedirect, "test")
|
|
|
|
}
|
2016-02-08 09:02:37 +02:00
|
|
|
mw(c)
|
2015-05-30 19:54:55 +02:00
|
|
|
|
2015-05-20 23:38:51 +02:00
|
|
|
// Status 4xx
|
2016-02-05 00:40:08 +02:00
|
|
|
rec = test.NewResponseRecorder()
|
|
|
|
c = echo.NewContext(req, rec, e)
|
2015-12-04 03:23:53 +02:00
|
|
|
h = func(c echo.Context) error {
|
2015-05-20 23:38:51 +02:00
|
|
|
return c.String(http.StatusNotFound, "test")
|
|
|
|
}
|
2016-02-08 09:02:37 +02:00
|
|
|
mw(c)
|
2015-05-20 23:38:51 +02:00
|
|
|
|
2015-05-30 19:54:55 +02:00
|
|
|
// Status 5xx with empty path
|
2016-01-29 09:46:11 +02:00
|
|
|
req = test.NewRequest(echo.GET, "", nil)
|
2016-02-05 00:40:08 +02:00
|
|
|
rec = test.NewResponseRecorder()
|
|
|
|
c = echo.NewContext(req, rec, e)
|
2015-12-04 03:23:53 +02:00
|
|
|
h = func(c echo.Context) error {
|
2015-05-30 19:54:55 +02:00
|
|
|
return errors.New("error")
|
2015-05-20 23:38:51 +02:00
|
|
|
}
|
2016-02-08 09:02:37 +02:00
|
|
|
mw(c)
|
2015-05-20 23:38:51 +02:00
|
|
|
}
|
2015-10-21 22:39:51 +02:00
|
|
|
|
2016-02-08 09:02:37 +02:00
|
|
|
func TestLogIPAddress(t *testing.T) {
|
2015-10-21 22:39:51 +02:00
|
|
|
e := echo.New()
|
2016-01-29 09:46:11 +02:00
|
|
|
req := test.NewRequest(echo.GET, "/", nil)
|
2016-02-05 00:40:08 +02:00
|
|
|
rec := test.NewResponseRecorder()
|
|
|
|
c := echo.NewContext(req, rec, e)
|
2015-12-01 21:22:45 +02:00
|
|
|
buf := new(bytes.Buffer)
|
2016-02-05 05:29:49 +02:00
|
|
|
e.Logger().(*log.Logger).SetOutput(buf)
|
2015-12-01 21:22:45 +02:00
|
|
|
ip := "127.0.0.1"
|
2015-12-04 03:23:53 +02:00
|
|
|
h := func(c echo.Context) error {
|
2015-10-21 22:39:51 +02:00
|
|
|
return c.String(http.StatusOK, "test")
|
|
|
|
}
|
2016-02-08 09:02:37 +02:00
|
|
|
mw := Log()(h)
|
2015-10-21 22:39:51 +02:00
|
|
|
|
|
|
|
// With X-Real-IP
|
2016-01-29 09:46:11 +02:00
|
|
|
req.Header().Add(echo.XRealIP, ip)
|
2016-02-08 09:02:37 +02:00
|
|
|
mw(c)
|
2015-10-21 22:39:51 +02:00
|
|
|
assert.Contains(t, buf.String(), ip)
|
|
|
|
|
|
|
|
// With X-Forwarded-For
|
|
|
|
buf.Reset()
|
2016-01-29 09:46:11 +02:00
|
|
|
req.Header().Del(echo.XRealIP)
|
|
|
|
req.Header().Add(echo.XForwardedFor, ip)
|
2016-02-08 09:02:37 +02:00
|
|
|
mw(c)
|
2015-10-21 22:39:51 +02:00
|
|
|
assert.Contains(t, buf.String(), ip)
|
|
|
|
|
|
|
|
// with req.RemoteAddr
|
|
|
|
buf.Reset()
|
2016-02-08 09:02:37 +02:00
|
|
|
mw(c)
|
2015-10-21 22:39:51 +02:00
|
|
|
assert.Contains(t, buf.String(), ip)
|
|
|
|
}
|