12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879 |
- package mux
- import (
- "net/http"
- "strings"
- )
- type MiddlewareFunc func(http.Handler) http.Handler
- type middleware interface {
- Middleware(handler http.Handler) http.Handler
- }
- func (mw MiddlewareFunc) Middleware(handler http.Handler) http.Handler {
- return mw(handler)
- }
- func (r *Router) Use(mwf ...MiddlewareFunc) {
- for _, fn := range mwf {
- r.middlewares = append(r.middlewares, fn)
- }
- }
- func (r *Router) useInterface(mw middleware) {
- r.middlewares = append(r.middlewares, mw)
- }
- func CORSMethodMiddleware(r *Router) MiddlewareFunc {
- return func(next http.Handler) http.Handler {
- return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
- allMethods, err := getAllMethodsForRoute(r, req)
- if err == nil {
- for _, v := range allMethods {
- if v == http.MethodOptions {
- w.Header().Set("Access-Control-Allow-Methods", strings.Join(allMethods, ","))
- }
- }
- }
- next.ServeHTTP(w, req)
- })
- }
- }
- func getAllMethodsForRoute(r *Router, req *http.Request) ([]string, error) {
- var allMethods []string
- err := r.Walk(func(route *Route, _ *Router, _ []*Route) error {
- for _, m := range route.matchers {
- if _, ok := m.(*routeRegexp); ok {
- if m.Match(req, &RouteMatch{}) {
- methods, err := route.GetMethods()
- if err != nil {
- return err
- }
- allMethods = append(allMethods, methods...)
- }
- break
- }
- }
- return nil
- })
- return allMethods, err
- }
|