52 lines
1.1 KiB
Go
52 lines
1.1 KiB
Go
package handler
|
|
|
|
import (
|
|
"mstore/app/router"
|
|
"mstore/pkg/auxhttp"
|
|
)
|
|
|
|
const (
|
|
authTag = "authpass"
|
|
userTag = "username"
|
|
)
|
|
|
|
func (hand *Handler) AuthMiddleware(next router.Handler) router.Handler {
|
|
var handlerFunc router.HandlerFunc
|
|
|
|
handlerFunc = func(rctx *router.Context) {
|
|
hand.logg.Debugf("Call authorization middleware")
|
|
success, username, err := hand.CheckAccess(rctx)
|
|
if success && err == nil {
|
|
rctx.SetBool(authTag, true)
|
|
rctx.SetString(userTag, username)
|
|
}
|
|
if err != nil {
|
|
hand.logg.Errorf("Authorization middleware error: %v", err)
|
|
}
|
|
next.ServeHTTP(rctx)
|
|
|
|
}
|
|
return handlerFunc
|
|
}
|
|
|
|
func (hand *Handler) CheckAccess(rctx *router.Context) (bool, string, error) {
|
|
var err error
|
|
var success bool
|
|
var username string
|
|
var password string
|
|
|
|
authHeader := rctx.GetHeader("Authorization")
|
|
if authHeader != "" {
|
|
hand.logg.Debugf("Authorization header is %s", authHeader)
|
|
username, password, err = auxhttp.ParseBasicAuth(authHeader)
|
|
if err != nil {
|
|
return success, username, err
|
|
}
|
|
hand.logg.Debugf("Authorization username is %s:%s", username, password)
|
|
}
|
|
|
|
success = true
|
|
|
|
return success, username, err
|
|
}
|