authorizer/server/handlers/token.go

package handlers

import (
	"crypto/sha256"
	"encoding/base64"
	"net/http"
	"strings"

	"github.com/authorizerdev/authorizer/server/cookie"
	"github.com/authorizerdev/authorizer/server/db"
	"github.com/authorizerdev/authorizer/server/sessionstore"
	"github.com/authorizerdev/authorizer/server/token"
	"github.com/gin-gonic/gin"
)

func TokenHandler() gin.HandlerFunc {
	return func(gc *gin.Context) {
		var reqBody map[string]string
		if err := gc.BindJSON(&reqBody); err != nil {
			gc.JSON(http.StatusBadRequest, gin.H{
				"error":             "error_binding_json",
				"error_description": err.Error(),
			})
			return
		}

		codeVerifier := strings.TrimSpace(reqBody["code_verifier"])
		code := strings.TrimSpace(reqBody["code"])
		redirectURI := strings.TrimSpace(reqBody["redirect_uri"])

		if codeVerifier == "" {
			gc.JSON(http.StatusBadRequest, gin.H{
				"error":             "invalid_code_verifier",
				"error_description": "The code verifier is required",
			})
			return
		}

		if code == "" {
			gc.JSON(http.StatusBadRequest, gin.H{
				"error":             "invalid_code",
				"error_description": "The code is required",
			})
			return
		}

		if redirectURI == "" {
			gc.JSON(http.StatusBadRequest, gin.H{
				"error":             "invalid_redirect_uri",
				"error_description": "The redirect URI is required",
			})
			return
		}

		hash := sha256.New()
		hash.Write([]byte(codeVerifier))
		encryptedCode := strings.TrimSuffix(base64.URLEncoding.EncodeToString(hash.Sum(nil)), "=")
		sessionData := sessionstore.GetState(encryptedCode)
		if sessionData == "" {
			gc.JSON(http.StatusBadRequest, gin.H{
				"error":             "invalid_code_verifier",
				"error_description": "The code verifier is invalid",
			})
			return
		}

		// split session data
		// it contains code@sessiontoken
		sessionDataSplit := strings.Split(sessionData, "@")

		if sessionDataSplit[0] != code {
			gc.JSON(http.StatusBadRequest, gin.H{
				"error":             "invalid_code_verifier",
				"error_description": "The code verifier is invalid",
			})
			return
		}

		// validate session
		claims, err := token.ValidateBrowserSession(gc, sessionDataSplit[1])
		if err != nil {
			gc.JSON(http.StatusUnauthorized, gin.H{
				"error":             "unauthorized",
				"error_description": "Invalid session data",
			})
			return
		}
		userID := claims.Subject
		user, err := db.Provider.GetUserByID(userID)
		if err != nil {
			gc.JSON(http.StatusUnauthorized, gin.H{
				"error":             "unauthorized",
				"error_description": "User not found",
			})
			return
		}
		// rollover the session for security
		sessionstore.RemoveState(sessionDataSplit[1])
		authToken, err := token.CreateAuthToken(gc, user, claims.Roles, claims.Scope)
		if err != nil {
			gc.JSON(http.StatusUnauthorized, gin.H{
				"error":             "unauthorized",
				"error_description": "User not found",
			})
			return
		}
		sessionstore.SetState(authToken.FingerPrintHash, authToken.FingerPrint+"@"+user.ID)
		sessionstore.SetState(authToken.AccessToken.Token, authToken.FingerPrint+"@"+user.ID)
		cookie.SetSession(gc, authToken.FingerPrintHash)

		expiresIn := int64(1800)
		res := map[string]interface{}{
			"access_token": authToken.AccessToken.Token,
			"id_token":     authToken.IDToken.Token,
			"scope":        claims.Scope,
			"expires_in":   expiresIn,
		}

		if authToken.RefreshToken != nil {
			res["refresh_token"] = authToken.RefreshToken.Token
			sessionstore.SetState(authToken.AccessToken.Token, authToken.FingerPrint+"@"+user.ID)
		}

		gc.JSON(http.StatusOK, res)
	}
}