2024-07-14 09:44:49 +00:00
|
|
|
package logic
|
|
|
|
|
|
|
|
import (
|
|
|
|
"errors"
|
|
|
|
"framework_v2/consts"
|
|
|
|
"framework_v2/internal/providers"
|
|
|
|
"framework_v2/internal/providers/jwks"
|
2024-07-14 14:14:20 +00:00
|
|
|
"framework_v2/models"
|
2024-07-14 09:44:49 +00:00
|
|
|
"github.com/gin-gonic/gin"
|
|
|
|
"github.com/mitchellh/mapstructure"
|
|
|
|
"go.uber.org/zap"
|
|
|
|
"strings"
|
|
|
|
)
|
|
|
|
|
|
|
|
type AuthLogic struct {
|
|
|
|
}
|
|
|
|
|
|
|
|
var (
|
2024-07-14 10:14:01 +00:00
|
|
|
ErrNotValidToken = errors.New("无效的 JWT 令牌")
|
|
|
|
ErrJWTFormatError = errors.New("JWT 格式错误")
|
|
|
|
ErrNotBearerType = errors.New("不是 Bearer 类型")
|
|
|
|
ErrEmptyResponse = errors.New("我们的服务器返回了空请求,可能某些环节出了问题")
|
|
|
|
ErrTokenError = errors.New("token 类型错误")
|
2024-07-14 09:44:49 +00:00
|
|
|
config = *providers.MustGet[providers.GlobalConfig]()
|
|
|
|
logger = *providers.MustGet[zap.Logger]()
|
|
|
|
)
|
|
|
|
|
|
|
|
func NewAuthLogic() *AuthLogic {
|
|
|
|
return &AuthLogic{}
|
|
|
|
}
|
|
|
|
|
2024-07-14 14:14:20 +00:00
|
|
|
func (a *AuthLogic) GinMiddlewareAuth(tokenType models.JWTTokenTypes, c *gin.Context) (*models.User, error) {
|
2024-07-14 10:14:01 +00:00
|
|
|
var sub = consts.AnonymousUser
|
2024-07-14 14:14:20 +00:00
|
|
|
var jwtIdToken = &models.User{}
|
2024-07-14 09:44:49 +00:00
|
|
|
|
|
|
|
if config.DebugMode.Enable {
|
|
|
|
jwtIdToken.Token.Sub = sub
|
|
|
|
jwtIdToken.Valid = true
|
|
|
|
return jwtIdToken, nil
|
|
|
|
} else {
|
|
|
|
authorization := c.Request.Header.Get(consts.AuthHeader)
|
|
|
|
|
|
|
|
if authorization == "" {
|
|
|
|
return nil, ErrJWTFormatError
|
|
|
|
}
|
|
|
|
|
|
|
|
authSplit := strings.Split(authorization, " ")
|
|
|
|
if len(authSplit) != 2 {
|
|
|
|
return nil, ErrJWTFormatError
|
|
|
|
}
|
|
|
|
|
|
|
|
if authSplit[0] != consts.AuthPrefix {
|
|
|
|
return nil, ErrNotBearerType
|
|
|
|
}
|
|
|
|
|
|
|
|
token, err := jwks.ParseJWT(authSplit[1])
|
|
|
|
if err != nil {
|
2024-07-14 10:14:01 +00:00
|
|
|
return nil, ErrNotValidToken
|
2024-07-14 09:44:49 +00:00
|
|
|
}
|
|
|
|
sub, err = token.Claims.GetSubject()
|
|
|
|
if err != nil {
|
|
|
|
return nil, ErrNotValidToken
|
|
|
|
}
|
|
|
|
|
2024-07-14 10:14:01 +00:00
|
|
|
// 如果 token.Header 中没有 typ
|
|
|
|
if token.Header["typ"] == "" {
|
|
|
|
return nil, ErrEmptyResponse
|
|
|
|
}
|
|
|
|
|
|
|
|
// 验证 token 类型
|
|
|
|
if tokenType != "" && tokenType.String() != token.Header["typ"] {
|
|
|
|
return nil, ErrTokenError
|
|
|
|
}
|
|
|
|
|
|
|
|
jwtIdToken.Valid = true
|
|
|
|
|
2024-07-14 09:44:49 +00:00
|
|
|
err = mapstructure.Decode(token.Claims, &jwtIdToken.Token)
|
|
|
|
if err != nil {
|
|
|
|
logger.Error("Failed to map token claims to JwtIDToken struct.\nError: " + err.Error())
|
|
|
|
return nil, nil
|
|
|
|
}
|
2024-07-14 10:14:01 +00:00
|
|
|
|
2024-07-14 09:44:49 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return jwtIdToken, nil
|
|
|
|
}
|
|
|
|
|
2024-07-14 14:14:20 +00:00
|
|
|
func (a *AuthLogic) GinUser(c *gin.Context) *models.User {
|
2024-07-14 09:44:49 +00:00
|
|
|
user, _ := c.Get(consts.AuthMiddlewareKey)
|
2024-07-14 14:14:20 +00:00
|
|
|
return user.(*models.User)
|
2024-07-14 09:44:49 +00:00
|
|
|
}
|