package middleware import ( "net/http" "solacenet-gateway/config" "strings" "github.com/gin-gonic/gin" "github.com/golang-jwt/jwt/v5" ) // AuthMiddleware validates JWT tokens func AuthMiddleware(cfg *config.Config) gin.HandlerFunc { return func(c *gin.Context) { authHeader := c.GetHeader("Authorization") if authHeader == "" { c.JSON(http.StatusUnauthorized, gin.H{ "error": "Authorization header required", }) c.Abort() return } // Extract token parts := strings.Split(authHeader, " ") if len(parts) != 2 || parts[0] != "Bearer" { c.JSON(http.StatusUnauthorized, gin.H{ "error": "Invalid authorization header format", }) c.Abort() return } tokenString := parts[1] // Parse and validate token token, err := jwt.Parse(tokenString, func(token *jwt.Token) (interface{}, error) { return []byte(cfg.JWTSecret), nil }) if err != nil || !token.Valid { c.JSON(http.StatusUnauthorized, gin.H{ "error": "Invalid token", }) c.Abort() return } // Extract claims if claims, ok := token.Claims.(jwt.MapClaims); ok { c.Set("userID", claims["sub"]) c.Set("tenantID", claims["tenantId"]) } c.Next() } }