jwts.go 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. package logic
  2. import (
  3. "errors"
  4. "fmt"
  5. "time"
  6. "github.com/golang-jwt/jwt/v4"
  7. "github.com/gravitl/netmaker/logger"
  8. "github.com/gravitl/netmaker/models"
  9. "github.com/gravitl/netmaker/servercfg"
  10. )
  11. var jwtSecretKey []byte
  12. // SetJWTSecret - sets the jwt secret on server startup
  13. func SetJWTSecret() {
  14. currentSecret, jwtErr := FetchJWTSecret()
  15. if jwtErr != nil {
  16. newValue, err := GenerateCryptoString(64)
  17. if err != nil {
  18. logger.FatalLog("something went wrong when generating JWT signature")
  19. }
  20. jwtSecretKey = []byte(newValue) // 512 bit random password
  21. if err := StoreJWTSecret(string(jwtSecretKey)); err != nil {
  22. logger.FatalLog("something went wrong when configuring JWT authentication")
  23. }
  24. } else {
  25. jwtSecretKey = []byte(currentSecret)
  26. }
  27. }
  28. // CreateJWT func will used to create the JWT while signing in and signing out
  29. func CreateJWT(uuid string, macAddress string, network string) (response string, err error) {
  30. expirationTime := time.Now().Add(5 * time.Minute)
  31. claims := &models.Claims{
  32. ID: uuid,
  33. Network: network,
  34. MacAddress: macAddress,
  35. RegisteredClaims: jwt.RegisteredClaims{
  36. Issuer: "Netmaker",
  37. Subject: fmt.Sprintf("node|%s", uuid),
  38. IssuedAt: jwt.NewNumericDate(time.Now()),
  39. ExpiresAt: jwt.NewNumericDate(expirationTime),
  40. },
  41. }
  42. token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
  43. tokenString, err := token.SignedString(jwtSecretKey)
  44. if err == nil {
  45. return tokenString, nil
  46. }
  47. return "", err
  48. }
  49. // CreateProUserJWT - creates a user jwt token
  50. func CreateProUserJWT(username string, networks, groups []string, isadmin bool) (response string, err error) {
  51. expirationTime := time.Now().Add(60 * 12 * time.Minute)
  52. claims := &models.UserClaims{
  53. UserName: username,
  54. Networks: networks,
  55. IsAdmin: isadmin,
  56. Groups: groups,
  57. RegisteredClaims: jwt.RegisteredClaims{
  58. Issuer: "Netmaker",
  59. Subject: fmt.Sprintf("user|%s", username),
  60. IssuedAt: jwt.NewNumericDate(time.Now()),
  61. ExpiresAt: jwt.NewNumericDate(expirationTime),
  62. },
  63. }
  64. token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
  65. tokenString, err := token.SignedString(jwtSecretKey)
  66. if err == nil {
  67. return tokenString, nil
  68. }
  69. return "", err
  70. }
  71. // CreateUserJWT - creates a user jwt token
  72. func CreateUserJWT(username string, networks []string, isadmin bool) (response string, err error) {
  73. expirationTime := time.Now().Add(60 * 12 * time.Minute)
  74. claims := &models.UserClaims{
  75. UserName: username,
  76. Networks: networks,
  77. IsAdmin: isadmin,
  78. RegisteredClaims: jwt.RegisteredClaims{
  79. Issuer: "Netmaker",
  80. Subject: fmt.Sprintf("user|%s", username),
  81. IssuedAt: jwt.NewNumericDate(time.Now()),
  82. ExpiresAt: jwt.NewNumericDate(expirationTime),
  83. },
  84. }
  85. token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
  86. tokenString, err := token.SignedString(jwtSecretKey)
  87. if err == nil {
  88. return tokenString, nil
  89. }
  90. return "", err
  91. }
  92. // VerifyUserToken func will used to Verify the JWT Token while using APIS
  93. func VerifyUserToken(tokenString string) (username string, networks []string, isadmin bool, err error) {
  94. claims := &models.UserClaims{}
  95. if tokenString == servercfg.GetMasterKey() && servercfg.GetMasterKey() != "" {
  96. return "masteradministrator", nil, true, nil
  97. }
  98. token, err := jwt.ParseWithClaims(tokenString, claims, func(token *jwt.Token) (interface{}, error) {
  99. return jwtSecretKey, nil
  100. })
  101. if token != nil && token.Valid {
  102. var user *models.User
  103. // check that user exists
  104. user, err = GetUser(claims.UserName)
  105. if err != nil {
  106. return "", nil, false, err
  107. }
  108. if user.UserName != "" {
  109. return claims.UserName, claims.Networks, claims.IsAdmin, nil
  110. }
  111. err = errors.New("user does not exist")
  112. }
  113. return "", nil, false, err
  114. }
  115. // VerifyToken - [nodes] Only
  116. func VerifyToken(tokenString string) (hostID string, mac string, network string, err error) {
  117. claims := &models.Claims{}
  118. // this may be a stupid way of serving up a master key
  119. // TODO: look into a different method. Encryption?
  120. if tokenString == servercfg.GetMasterKey() && servercfg.GetMasterKey() != "" {
  121. return "mastermac", "", "", nil
  122. }
  123. token, err := jwt.ParseWithClaims(tokenString, claims, func(token *jwt.Token) (interface{}, error) {
  124. return jwtSecretKey, nil
  125. })
  126. if token != nil {
  127. return claims.ID, claims.MacAddress, claims.Network, nil
  128. }
  129. return "", "", "", err
  130. }