0
Fork 0
mirror of https://github.com/caddyserver/caddy.git synced 2024-12-23 22:27:38 -05:00

Refactored redirect middleware

This commit is contained in:
Matthew Holt 2015-04-11 17:06:09 -06:00
parent abeb337f45
commit 40bf7c5285

View file

@ -9,12 +9,45 @@ import (
"github.com/mholt/caddy/middleware" "github.com/mholt/caddy/middleware"
) )
// New creates a new redirect middleware. // New instantiates a new Rewrites middleware.
func New(c middleware.Controller) (middleware.Middleware, error) { func New(c middleware.Controller) (middleware.Middleware, error) {
var redirects []Redirect rules, err := parse(c)
if err != nil {
return nil, err
}
return func(next middleware.Handler) middleware.Handler {
return Redirect{Next: next, Rules: rules}
}, nil
}
// Redirect is middleware to respond with HTTP redirects
type Redirect struct {
Next middleware.Handler
Rules []Rule
}
// ServeHTTP implements the middleware.Handler interface.
func (rd Redirect) ServeHTTP(w http.ResponseWriter, r *http.Request) (int, error) {
for _, rule := range rd.Rules {
if middleware.Path(r.URL.Path).Matches(rule.From) {
if rule.From == "/" {
// Catchall redirect preserves path (TODO: This should be made more consistent...)
http.Redirect(w, r, strings.TrimSuffix(rule.To, "/")+r.URL.Path, rule.Code)
return 0, nil
}
http.Redirect(w, r, rule.To, rule.Code)
return 0, nil
}
}
return rd.Next.ServeHTTP(w, r)
}
func parse(c middleware.Controller) ([]Rule, error) {
var redirects []Rule
for c.Next() { for c.Next() {
var rule Redirect var rule Rule
args := c.RemainingArgs() args := c.RemainingArgs()
if len(args) == 1 { if len(args) == 1 {
@ -28,39 +61,23 @@ func New(c middleware.Controller) (middleware.Middleware, error) {
rule.From = args[0] rule.From = args[0]
rule.To = args[1] rule.To = args[1]
if code, ok := httpRedirs[args[2]]; !ok { if code, ok := httpRedirs[args[2]]; !ok {
return nil, c.Err("Invalid redirect code '" + c.Val() + "'") return redirects, c.Err("Invalid redirect code '" + c.Val() + "'")
} else { } else {
rule.Code = code rule.Code = code
} }
redirects = append(redirects, rule) redirects = append(redirects, rule)
} else { } else {
return nil, c.ArgErr() return redirects, c.ArgErr()
} }
} }
return func(next middleware.Handler) middleware.Handler { return redirects, nil
return middleware.HandlerFunc(func(w http.ResponseWriter, r *http.Request) (int, error) {
for _, rule := range redirects {
if middleware.Path(r.URL.Path).Matches(rule.From) {
if rule.From == "/" {
// Catchall redirect preserves path (TODO: This should be made more consistent...)
http.Redirect(w, r, strings.TrimSuffix(rule.To, "/")+r.URL.Path, rule.Code)
return 0, nil
}
http.Redirect(w, r, rule.To, rule.Code)
return 0, nil
}
}
return next.ServeHTTP(w, r)
})
}, nil
} }
// redirect describes an HTTP redirect rule. // Rule describes an HTTP redirect rule.
type Redirect struct { type Rule struct {
From string From, To string
To string Code int
Code int
} }
// httpRedirs is a list of supported HTTP redirect codes. // httpRedirs is a list of supported HTTP redirect codes.