mirror of
https://github.com/gravitl/netmaker.git
synced 2024-11-10 17:48:25 +08:00
119 lines
3.5 KiB
Go
119 lines
3.5 KiB
Go
package logic
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/golang-jwt/jwt/v4"
|
|
"github.com/gravitl/netmaker/logger"
|
|
"github.com/gravitl/netmaker/models"
|
|
"github.com/gravitl/netmaker/servercfg"
|
|
)
|
|
|
|
var jwtSecretKey []byte
|
|
|
|
// SetJWTSecret - sets the jwt secret on server startup
|
|
func SetJWTSecret() {
|
|
currentSecret, jwtErr := FetchJWTSecret()
|
|
if jwtErr != nil {
|
|
newValue, err := GenerateCryptoString(64)
|
|
if err != nil {
|
|
logger.FatalLog("something went wrong when generating JWT signature")
|
|
}
|
|
jwtSecretKey = []byte(newValue) // 512 bit random password
|
|
if err := StoreJWTSecret(string(jwtSecretKey)); err != nil {
|
|
logger.FatalLog("something went wrong when configuring JWT authentication")
|
|
}
|
|
} else {
|
|
jwtSecretKey = []byte(currentSecret)
|
|
}
|
|
}
|
|
|
|
// CreateJWT func will used to create the JWT while signing in and signing out
|
|
func CreateJWT(uuid string, macAddress string, network string) (response string, err error) {
|
|
expirationTime := time.Now().Add(5 * time.Minute)
|
|
claims := &models.Claims{
|
|
ID: uuid,
|
|
Network: network,
|
|
MacAddress: macAddress,
|
|
RegisteredClaims: jwt.RegisteredClaims{
|
|
Issuer: "Netmaker",
|
|
Subject: fmt.Sprintf("node|%s", uuid),
|
|
IssuedAt: jwt.NewNumericDate(time.Now()),
|
|
ExpiresAt: jwt.NewNumericDate(expirationTime),
|
|
},
|
|
}
|
|
|
|
token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
|
|
tokenString, err := token.SignedString(jwtSecretKey)
|
|
if err == nil {
|
|
return tokenString, nil
|
|
}
|
|
return "", err
|
|
}
|
|
|
|
// CreateUserJWT - creates a user jwt token
|
|
func CreateUserJWT(username string, networks []string, isadmin bool) (response string, err error) {
|
|
expirationTime := time.Now().Add(60 * 12 * time.Minute)
|
|
claims := &models.UserClaims{
|
|
UserName: username,
|
|
Networks: networks,
|
|
IsAdmin: isadmin,
|
|
RegisteredClaims: jwt.RegisteredClaims{
|
|
Issuer: "Netmaker",
|
|
Subject: fmt.Sprintf("user|%s", username),
|
|
IssuedAt: jwt.NewNumericDate(time.Now()),
|
|
ExpiresAt: jwt.NewNumericDate(expirationTime),
|
|
},
|
|
}
|
|
|
|
token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
|
|
tokenString, err := token.SignedString(jwtSecretKey)
|
|
if err == nil {
|
|
return tokenString, nil
|
|
}
|
|
return "", err
|
|
}
|
|
|
|
// VerifyToken func will used to Verify the JWT Token while using APIS
|
|
func VerifyUserToken(tokenString string) (username string, networks []string, isadmin bool, err error) {
|
|
claims := &models.UserClaims{}
|
|
|
|
if tokenString == servercfg.GetMasterKey() && servercfg.GetMasterKey() != "" {
|
|
return "masteradministrator", nil, true, nil
|
|
}
|
|
|
|
token, err := jwt.ParseWithClaims(tokenString, claims, func(token *jwt.Token) (interface{}, error) {
|
|
return jwtSecretKey, nil
|
|
})
|
|
|
|
if token != nil && token.Valid {
|
|
// check that user exists
|
|
if user, err := GetUser(claims.UserName); user.UserName != "" && err == nil {
|
|
return claims.UserName, claims.Networks, claims.IsAdmin, nil
|
|
}
|
|
err = errors.New("user does not exist")
|
|
}
|
|
return "", nil, false, err
|
|
}
|
|
|
|
// VerifyToken - [nodes] Only
|
|
func VerifyToken(tokenString string) (nodeID string, mac string, network string, err error) {
|
|
claims := &models.Claims{}
|
|
|
|
//this may be a stupid way of serving up a master key
|
|
//TODO: look into a different method. Encryption?
|
|
if tokenString == servercfg.GetMasterKey() && servercfg.GetMasterKey() != "" {
|
|
return "mastermac", "", "", nil
|
|
}
|
|
|
|
token, err := jwt.ParseWithClaims(tokenString, claims, func(token *jwt.Token) (interface{}, error) {
|
|
return jwtSecretKey, nil
|
|
})
|
|
|
|
if token != nil {
|
|
return claims.ID, claims.MacAddress, claims.Network, nil
|
|
}
|
|
return "", "", "", err
|
|
}
|