mirror of
https://github.com/acepanel/panel.git
synced 2026-02-04 12:40:25 +08:00
47 lines
1.1 KiB
Go
47 lines
1.1 KiB
Go
package middleware
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/goravel/framework/auth"
|
|
"github.com/goravel/framework/contracts/http"
|
|
"github.com/goravel/framework/facades"
|
|
)
|
|
|
|
// Jwt 确保通过 JWT 鉴权
|
|
func Jwt() http.Middleware {
|
|
return func(ctx http.Context) {
|
|
token := ctx.Request().Header("Authorization", ctx.Request().Header("Sec-WebSocket-Protocol"))
|
|
if len(token) == 0 {
|
|
ctx.Request().AbortWithStatusJson(http.StatusUnauthorized, http.Json{
|
|
"message": "未登录",
|
|
})
|
|
return
|
|
}
|
|
|
|
// JWT 鉴权
|
|
if _, err := facades.Auth(ctx).Parse(token); err != nil {
|
|
if errors.Is(err, auth.ErrorTokenExpired) {
|
|
token, err = facades.Auth(ctx).Refresh()
|
|
if err != nil {
|
|
// 到达刷新时间上限
|
|
ctx.Request().AbortWithStatusJson(http.StatusUnauthorized, http.Json{
|
|
"message": "登录已过期",
|
|
})
|
|
return
|
|
}
|
|
|
|
token = "Bearer " + token
|
|
} else {
|
|
ctx.Request().AbortWithStatusJson(http.StatusUnauthorized, http.Json{
|
|
"message": "登录已过期",
|
|
})
|
|
return
|
|
}
|
|
}
|
|
|
|
ctx.Response().Header("Authorization", token)
|
|
ctx.Request().Next()
|
|
}
|
|
}
|