mirror of
https://github.com/0xJacky/nginx-ui.git
synced 2025-05-11 02:15:48 +02:00
feat: add ip whitelist
This commit is contained in:
parent
7a9aa3a33b
commit
3b937ee0f4
17 changed files with 1026 additions and 927 deletions
32
internal/user/login.go
Normal file
32
internal/user/login.go
Normal file
|
@ -0,0 +1,32 @@
|
|||
package user
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"github.com/0xJacky/Nginx-UI/model"
|
||||
"github.com/0xJacky/Nginx-UI/query"
|
||||
"golang.org/x/crypto/bcrypt"
|
||||
)
|
||||
|
||||
var (
|
||||
ErrPasswordIncorrect = errors.New("password incorrect")
|
||||
ErrUserBanned = errors.New("user banned")
|
||||
)
|
||||
|
||||
func Login(name string, password string) (user *model.Auth, err error) {
|
||||
u := query.Auth
|
||||
|
||||
user, err = u.Where(u.Name.Eq(name)).First()
|
||||
if err != nil {
|
||||
return nil, ErrPasswordIncorrect
|
||||
}
|
||||
|
||||
if err = bcrypt.CompareHashAndPassword([]byte(user.Password), []byte(password)); err != nil {
|
||||
return nil, ErrPasswordIncorrect
|
||||
}
|
||||
|
||||
if !user.Status {
|
||||
return nil, ErrUserBanned
|
||||
}
|
||||
|
||||
return
|
||||
}
|
57
internal/user/user.go
Normal file
57
internal/user/user.go
Normal file
|
@ -0,0 +1,57 @@
|
|||
package user
|
||||
|
||||
import (
|
||||
"github.com/0xJacky/Nginx-UI/model"
|
||||
"github.com/0xJacky/Nginx-UI/settings"
|
||||
"github.com/dgrijalva/jwt-go"
|
||||
"time"
|
||||
)
|
||||
|
||||
type JWTClaims struct {
|
||||
Name string `json:"name"`
|
||||
jwt.StandardClaims
|
||||
}
|
||||
|
||||
func GetUser(name string) (user model.Auth, err error) {
|
||||
db := model.UseDB()
|
||||
err = db.Where("name", name).First(&user).Error
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func DeleteToken(token string) error {
|
||||
db := model.UseDB()
|
||||
return db.Where("token", token).Delete(&model.AuthToken{}).Error
|
||||
}
|
||||
|
||||
func CheckToken(token string) int64 {
|
||||
db := model.UseDB()
|
||||
return db.Where("token", token).Find(&model.AuthToken{}).RowsAffected
|
||||
}
|
||||
|
||||
func GenerateJWT(name string) (string, error) {
|
||||
claims := JWTClaims{
|
||||
Name: name,
|
||||
StandardClaims: jwt.StandardClaims{
|
||||
ExpiresAt: time.Now().Add(24 * time.Hour).Unix(),
|
||||
},
|
||||
}
|
||||
unsignedToken := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
|
||||
signedToken, err := unsignedToken.SignedString([]byte(settings.ServerSettings.JwtSecret))
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
db := model.UseDB()
|
||||
err = db.Create(&model.AuthToken{
|
||||
Token: signedToken,
|
||||
}).Error
|
||||
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
return signedToken, err
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue