1
Fork 0
mirror of https://github.com/caddyserver/caddy.git synced 2024-12-16 21:56:40 -05:00
caddy/modules/caddyhttp/headers/headers.go

103 lines
2.6 KiB
Go
Raw Normal View History

2019-05-20 16:46:47 -05:00
package headers
import (
"net/http"
"strings"
"bitbucket.org/lightcodelabs/caddy2"
"bitbucket.org/lightcodelabs/caddy2/modules/caddyhttp"
)
func init() {
caddy2.RegisterModule(caddy2.Module{
Name: "http.middleware.headers",
New: func() (interface{}, error) { return new(Headers), nil },
})
}
// Headers is a middleware which can mutate HTTP headers.
type Headers struct {
2019-05-20 23:00:54 -05:00
Request HeaderOps `json:"request"`
Response RespHeaderOps `json:"response"`
2019-05-20 16:46:47 -05:00
}
// HeaderOps defines some operations to
// perform on HTTP headers.
type HeaderOps struct {
2019-05-20 23:00:54 -05:00
Add http.Header `json:"add"`
Set http.Header `json:"set"`
Delete []string `json:"delete"`
2019-05-20 16:46:47 -05:00
}
// RespHeaderOps is like HeaderOps, but
// optionally deferred until response time.
type RespHeaderOps struct {
HeaderOps
Deferred bool `json:"deferred"`
}
func (h Headers) ServeHTTP(w http.ResponseWriter, r *http.Request, next caddyhttp.Handler) error {
repl := r.Context().Value(caddy2.ReplacerCtxKey).(caddy2.Replacer)
apply(h.Request, r.Header, repl)
2019-05-20 16:46:47 -05:00
if h.Response.Deferred {
w = &responseWriterWrapper{
ResponseWriterWrapper: &caddyhttp.ResponseWriterWrapper{ResponseWriter: w},
replacer: repl,
2019-05-20 16:46:47 -05:00
headerOps: h.Response.HeaderOps,
}
} else {
apply(h.Response.HeaderOps, w.Header(), repl)
2019-05-20 16:46:47 -05:00
}
return next.ServeHTTP(w, r)
}
func apply(ops HeaderOps, hdr http.Header, repl caddy2.Replacer) {
2019-05-20 16:46:47 -05:00
for fieldName, vals := range ops.Add {
fieldName = repl.ReplaceAll(fieldName, "")
2019-05-20 16:46:47 -05:00
for _, v := range vals {
hdr.Add(fieldName, repl.ReplaceAll(v, ""))
2019-05-20 16:46:47 -05:00
}
}
for fieldName, vals := range ops.Set {
fieldName = repl.ReplaceAll(fieldName, "")
for i := range vals {
vals[i] = repl.ReplaceAll(vals[i], "")
}
2019-05-20 16:46:47 -05:00
hdr.Set(fieldName, strings.Join(vals, ","))
}
for _, fieldName := range ops.Delete {
hdr.Del(repl.ReplaceAll(fieldName, ""))
2019-05-20 16:46:47 -05:00
}
}
// responseWriterWrapper defers response header
// operations until WriteHeader is called.
type responseWriterWrapper struct {
*caddyhttp.ResponseWriterWrapper
replacer caddy2.Replacer
2019-05-20 23:00:54 -05:00
headerOps HeaderOps
wroteHeader bool
}
func (rww *responseWriterWrapper) Write(d []byte) (int, error) {
if !rww.wroteHeader {
rww.WriteHeader(http.StatusOK)
}
return rww.ResponseWriterWrapper.Write(d)
2019-05-20 16:46:47 -05:00
}
func (rww *responseWriterWrapper) WriteHeader(status int) {
2019-05-20 23:00:54 -05:00
if rww.wroteHeader {
return
}
rww.wroteHeader = true
apply(rww.headerOps, rww.ResponseWriterWrapper.Header(), rww.replacer)
2019-05-20 16:46:47 -05:00
rww.ResponseWriterWrapper.WriteHeader(status)
}
// Interface guards
var (
_ caddyhttp.MiddlewareHandler = (*Headers)(nil)
_ caddyhttp.HTTPInterfaces = (*responseWriterWrapper)(nil)
)