mirror of
https://github.com/labstack/echo.git
synced 2024-12-22 20:06:21 +02:00
6d9e043284
This reintroduces support for Go modules, as v4. CloseNotifier() is removed as it has been obsoleted, see https://golang.org/doc/go1.11#net/http It was already NOT working (not sending signals) as of 1.11 the functionality was gone, we merely deleted the functions that exposed it. If anyone still relies on it they should migrate to using `c.Request().Context().Done()` instead. Closes #1268, #1255
108 lines
2.4 KiB
Go
108 lines
2.4 KiB
Go
package middleware
|
|
|
|
import (
|
|
"bufio"
|
|
"bytes"
|
|
"io"
|
|
"io/ioutil"
|
|
"net"
|
|
"net/http"
|
|
|
|
"github.com/labstack/echo/v4"
|
|
)
|
|
|
|
type (
|
|
// BodyDumpConfig defines the config for BodyDump middleware.
|
|
BodyDumpConfig struct {
|
|
// Skipper defines a function to skip middleware.
|
|
Skipper Skipper
|
|
|
|
// Handler receives request and response payload.
|
|
// Required.
|
|
Handler BodyDumpHandler
|
|
}
|
|
|
|
// BodyDumpHandler receives the request and response payload.
|
|
BodyDumpHandler func(echo.Context, []byte, []byte)
|
|
|
|
bodyDumpResponseWriter struct {
|
|
io.Writer
|
|
http.ResponseWriter
|
|
}
|
|
)
|
|
|
|
var (
|
|
// DefaultBodyDumpConfig is the default BodyDump middleware config.
|
|
DefaultBodyDumpConfig = BodyDumpConfig{
|
|
Skipper: DefaultSkipper,
|
|
}
|
|
)
|
|
|
|
// BodyDump returns a BodyDump middleware.
|
|
//
|
|
// BodyLimit middleware captures the request and response payload and calls the
|
|
// registered handler.
|
|
func BodyDump(handler BodyDumpHandler) echo.MiddlewareFunc {
|
|
c := DefaultBodyDumpConfig
|
|
c.Handler = handler
|
|
return BodyDumpWithConfig(c)
|
|
}
|
|
|
|
// BodyDumpWithConfig returns a BodyDump middleware with config.
|
|
// See: `BodyDump()`.
|
|
func BodyDumpWithConfig(config BodyDumpConfig) echo.MiddlewareFunc {
|
|
// Defaults
|
|
if config.Handler == nil {
|
|
panic("echo: body-dump middleware requires a handler function")
|
|
}
|
|
if config.Skipper == nil {
|
|
config.Skipper = DefaultBodyDumpConfig.Skipper
|
|
}
|
|
|
|
return func(next echo.HandlerFunc) echo.HandlerFunc {
|
|
return func(c echo.Context) (err error) {
|
|
if config.Skipper(c) {
|
|
return next(c)
|
|
}
|
|
|
|
// Request
|
|
reqBody := []byte{}
|
|
if c.Request().Body != nil { // Read
|
|
reqBody, _ = ioutil.ReadAll(c.Request().Body)
|
|
}
|
|
c.Request().Body = ioutil.NopCloser(bytes.NewBuffer(reqBody)) // Reset
|
|
|
|
// Response
|
|
resBody := new(bytes.Buffer)
|
|
mw := io.MultiWriter(c.Response().Writer, resBody)
|
|
writer := &bodyDumpResponseWriter{Writer: mw, ResponseWriter: c.Response().Writer}
|
|
c.Response().Writer = writer
|
|
|
|
if err = next(c); err != nil {
|
|
c.Error(err)
|
|
}
|
|
|
|
// Callback
|
|
config.Handler(c, reqBody, resBody.Bytes())
|
|
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
func (w *bodyDumpResponseWriter) WriteHeader(code int) {
|
|
w.ResponseWriter.WriteHeader(code)
|
|
}
|
|
|
|
func (w *bodyDumpResponseWriter) Write(b []byte) (int, error) {
|
|
return w.Writer.Write(b)
|
|
}
|
|
|
|
func (w *bodyDumpResponseWriter) Flush() {
|
|
w.ResponseWriter.(http.Flusher).Flush()
|
|
}
|
|
|
|
func (w *bodyDumpResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) {
|
|
return w.ResponseWriter.(http.Hijacker).Hijack()
|
|
}
|