2015-01-13 14:43:45 -05:00
|
|
|
package middleware
|
|
|
|
|
|
|
|
import (
|
2015-03-27 00:39:36 -05:00
|
|
|
"net"
|
2015-01-13 14:43:45 -05:00
|
|
|
"net/http"
|
|
|
|
"strconv"
|
|
|
|
"strings"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
|
|
|
// replacer is a type which can replace placeholder
|
|
|
|
// substrings in a string with actual values from a
|
|
|
|
// http.Request and responseRecorder. Always use
|
2015-01-30 00:06:53 -05:00
|
|
|
// NewReplacer to get one of these.
|
2015-01-13 14:43:45 -05:00
|
|
|
type replacer map[string]string
|
|
|
|
|
2015-03-27 00:39:36 -05:00
|
|
|
// NewReplacer makes a new replacer based on r and rr.
|
|
|
|
// Do not create a new replacer until r and rr have all
|
2015-01-13 14:43:45 -05:00
|
|
|
// the needed values, because this function copies those
|
|
|
|
// values into the replacer.
|
2015-03-27 00:39:36 -05:00
|
|
|
func NewReplacer(r *http.Request, rr *responseRecorder) replacer {
|
2015-01-13 14:43:45 -05:00
|
|
|
rep := replacer{
|
|
|
|
"{method}": r.Method,
|
|
|
|
"{scheme}": func() string {
|
|
|
|
if r.TLS != nil {
|
|
|
|
return "https"
|
|
|
|
}
|
|
|
|
return "http"
|
|
|
|
}(),
|
|
|
|
"{host}": r.Host,
|
|
|
|
"{path}": r.URL.Path,
|
|
|
|
"{query}": r.URL.RawQuery,
|
|
|
|
"{fragment}": r.URL.Fragment,
|
|
|
|
"{proto}": r.Proto,
|
|
|
|
"{remote}": func() string {
|
2015-03-27 00:39:36 -05:00
|
|
|
host, _, err := net.SplitHostPort(r.RemoteAddr)
|
|
|
|
if err != nil {
|
2015-01-13 14:43:45 -05:00
|
|
|
return r.RemoteAddr
|
|
|
|
}
|
2015-03-27 00:39:36 -05:00
|
|
|
return host
|
2015-01-13 14:43:45 -05:00
|
|
|
}(),
|
|
|
|
"{port}": func() string {
|
2015-03-27 00:39:36 -05:00
|
|
|
_, port, err := net.SplitHostPort(r.RemoteAddr)
|
|
|
|
if err != nil {
|
|
|
|
return ""
|
2015-01-13 14:43:45 -05:00
|
|
|
}
|
2015-03-27 00:39:36 -05:00
|
|
|
return port
|
2015-01-13 14:43:45 -05:00
|
|
|
}(),
|
|
|
|
"{uri}": r.RequestURI,
|
2015-01-19 19:12:38 -05:00
|
|
|
"{when}": func() string {
|
2015-01-13 14:43:45 -05:00
|
|
|
return time.Now().Format(timeFormat)
|
|
|
|
}(),
|
2015-03-27 00:39:36 -05:00
|
|
|
"{status}": strconv.Itoa(rr.status),
|
|
|
|
"{size}": strconv.Itoa(rr.size),
|
2015-01-13 14:43:45 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
// Header placeholders
|
|
|
|
for header, val := range r.Header {
|
|
|
|
rep[headerReplacer+header+"}"] = strings.Join(val, ",")
|
|
|
|
}
|
|
|
|
|
|
|
|
return rep
|
|
|
|
}
|
|
|
|
|
2015-01-30 00:52:21 -05:00
|
|
|
// Replace performs a replacement of values on s and returns
|
2015-01-13 14:43:45 -05:00
|
|
|
// the string with the replaced values.
|
2015-01-30 00:06:53 -05:00
|
|
|
func (r replacer) Replace(s string) string {
|
2015-01-13 14:43:45 -05:00
|
|
|
for placeholder, replacement := range r {
|
|
|
|
if replacement == "" {
|
2015-01-30 00:06:53 -05:00
|
|
|
replacement = EmptyStringReplacer
|
2015-01-13 14:43:45 -05:00
|
|
|
}
|
|
|
|
s = strings.Replace(s, placeholder, replacement, -1)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Replace any header placeholders that weren't found
|
|
|
|
for strings.Contains(s, headerReplacer) {
|
|
|
|
idxStart := strings.Index(s, headerReplacer)
|
|
|
|
endOffset := idxStart + len(headerReplacer)
|
|
|
|
idxEnd := strings.Index(s[endOffset:], "}")
|
|
|
|
if idxEnd > -1 {
|
2015-01-30 00:06:53 -05:00
|
|
|
s = s[:idxStart] + EmptyStringReplacer + s[endOffset+idxEnd+1:]
|
2015-01-13 14:43:45 -05:00
|
|
|
} else {
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return s
|
|
|
|
}
|
|
|
|
|
|
|
|
const (
|
|
|
|
timeFormat = "02/Jan/2006:15:04:05 -0700"
|
|
|
|
headerReplacer = "{>"
|
2015-01-30 00:06:53 -05:00
|
|
|
EmptyStringReplacer = "-"
|
2015-01-13 14:43:45 -05:00
|
|
|
)
|