package jwt import ( "strings" "errors" "encoding/base64" "encoding/json" "time" "net/http" ) // A JWT Token type Token struct { Header map[string]interface{} Claims map[string]interface{} Method SigningMethod Signature string Valid bool } // Parse, validate, and return a token. // keyFunc will receive the parsed token and should return the key for validating. // If everything is kosher, err will be nil func Parse(tokenString string, keyFunc func(*Token)([]byte, error)) (token *Token, err error) { parts := strings.Split(tokenString, ".") if len(parts) == 3 { token = new(Token) // parse Header var headerBytes []byte if headerBytes, err = DecodeSegment(parts[0]); err != nil { return } if err = json.Unmarshal(headerBytes, &token.Header); err != nil { return } // parse Claims var claimBytes []byte if claimBytes, err = DecodeSegment(parts[1]); err != nil { return } if err = json.Unmarshal(claimBytes, &token.Claims); err != nil { return } // Lookup signature method if method, ok := token.Header["alg"].(string); ok { if token.Method, err = GetSigningMethod(method); err != nil { return } } else { err = errors.New("Signing method (alg) is unspecified.") return } // Check expiry times if exp, ok := token.Claims["exp"].(float64); ok { if time.Now().Unix() > int64(exp) { err = errors.New("Token is expired") } } // Lookup key var key []byte if key, err = keyFunc(token); err != nil { return } // Perform validation if err = token.Method.Verify(strings.Join(parts[0:2], "."), parts[2], key); err == nil { token.Valid = true } } else { err = errors.New("Token contains an invalid number of segments") } return } func ParseFromRequest(req *http.Request, keyFunc func(*Token)([]byte, error))(token *Token, err error) { return nil, nil } func DecodeSegment(seg string)([]byte, error) { // len % 4 switch len(seg) % 4 { case 2: seg = seg + "==" case 3: seg = seg + "===" } return base64.URLEncoding.DecodeString(seg) }