mirror of
https://github.com/imgproxy/imgproxy.git
synced 2024-12-09 09:56:01 +02:00
102 lines
1.9 KiB
Go
102 lines
1.9 KiB
Go
package main
|
|
|
|
import (
|
|
"net/http"
|
|
"regexp"
|
|
"strings"
|
|
|
|
nanoid "github.com/matoous/go-nanoid"
|
|
)
|
|
|
|
const (
|
|
xRequestIDHeader = "X-Request-ID"
|
|
)
|
|
|
|
var (
|
|
requestIDRe = regexp.MustCompile(`^[A-Za-z0-9_\-]+$`)
|
|
)
|
|
|
|
type routeHandler func(string, http.ResponseWriter, *http.Request)
|
|
type panicHandler func(string, http.ResponseWriter, *http.Request, error)
|
|
|
|
type route struct {
|
|
Method string
|
|
Prefix string
|
|
Handler routeHandler
|
|
Exact bool
|
|
}
|
|
|
|
type router struct {
|
|
Routes []*route
|
|
PanicHandler panicHandler
|
|
}
|
|
|
|
func (r *route) IsMatch(req *http.Request) bool {
|
|
if r.Method != req.Method {
|
|
return false
|
|
}
|
|
|
|
if r.Exact {
|
|
return req.URL.Path == r.Prefix
|
|
}
|
|
|
|
return strings.HasPrefix(req.URL.Path, r.Prefix)
|
|
}
|
|
|
|
func newRouter() *router {
|
|
return &router{
|
|
Routes: make([]*route, 0),
|
|
}
|
|
}
|
|
|
|
func (r *router) Add(method, prefix string, handler routeHandler, exact bool) {
|
|
r.Routes = append(
|
|
r.Routes,
|
|
&route{Method: method, Prefix: prefix, Handler: handler, Exact: exact},
|
|
)
|
|
}
|
|
|
|
func (r *router) GET(prefix string, handler routeHandler, exact bool) {
|
|
r.Add(http.MethodGet, prefix, handler, exact)
|
|
}
|
|
|
|
func (r *router) OPTIONS(prefix string, handler routeHandler, exact bool) {
|
|
r.Add(http.MethodOptions, prefix, handler, exact)
|
|
}
|
|
|
|
func (r *router) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
|
|
req = req.WithContext(setTimerSince(req.Context()))
|
|
|
|
reqID := req.Header.Get(xRequestIDHeader)
|
|
|
|
if len(reqID) == 0 || !requestIDRe.MatchString(reqID) {
|
|
reqID, _ = nanoid.Nanoid()
|
|
}
|
|
|
|
rw.Header().Set("Server", "imgproxy")
|
|
rw.Header().Set(xRequestIDHeader, reqID)
|
|
|
|
defer func() {
|
|
if rerr := recover(); rerr != nil {
|
|
if err, ok := rerr.(error); ok && r.PanicHandler != nil {
|
|
r.PanicHandler(reqID, rw, req, err)
|
|
} else {
|
|
panic(rerr)
|
|
}
|
|
}
|
|
}()
|
|
|
|
logRequest(reqID, req)
|
|
|
|
for _, rr := range r.Routes {
|
|
if rr.IsMatch(req) {
|
|
rr.Handler(reqID, rw, req)
|
|
return
|
|
}
|
|
}
|
|
|
|
logWarning("Route for %s is not defined", req.URL.Path)
|
|
|
|
rw.WriteHeader(404)
|
|
}
|