Compare commits

..

5 Commits

Author SHA1 Message Date
Lakhan Samani
eaa10ec5bc fix: error detection 2022-10-18 22:34:57 +05:30
Lakhan Samani
253128ca0c fix: query params for code response 2022-10-18 22:00:54 +05:30
Lakhan Samani
cddfe1e088 fix: response 2022-10-18 21:46:37 +05:30
Lakhan Samani
8e655bcb5b fix: authorize response 2022-10-18 21:29:09 +05:30
Lakhan Samani
9a411e673c fix: reponse 2022-10-18 21:08:53 +05:30

View File

@@ -68,6 +68,15 @@ func AuthorizeHandler() gin.HandlerFunc {
return return
} }
log := log.WithFields(log.Fields{
"response_mode": responseMode,
"response_type": responseType,
"state": state,
"code_challenge": codeChallenge,
"scope": scope,
"redirect_uri": redirectURI,
})
// used for response mode query or fragment // used for response mode query or fragment
loginState := "state=" + state + "&scope=" + strings.Join(scope, " ") + "&redirect_uri=" + redirectURI loginState := "state=" + state + "&scope=" + strings.Join(scope, " ") + "&redirect_uri=" + redirectURI
loginURL := "/app?" + loginState loginURL := "/app?" + loginState
@@ -76,8 +85,11 @@ func AuthorizeHandler() gin.HandlerFunc {
} }
loginError := map[string]interface{}{ loginError := map[string]interface{}{
"error": "login_required", "type": "authorization_response",
"error_description": "Login is required", "response": map[string]string{
"error": "login_required",
"error_description": "Login is required",
},
} }
sessionToken, err := cookie.GetSession(gc) sessionToken, err := cookie.GetSession(gc)
@@ -94,13 +106,17 @@ func AuthorizeHandler() gin.HandlerFunc {
handleResponse(gc, responseMode, loginURL, redirectURI, loginError, http.StatusOK) handleResponse(gc, responseMode, loginURL, redirectURI, loginError, http.StatusOK)
return return
} }
userID := claims.Subject userID := claims.Subject
user, err := db.Provider.GetUserByID(gc, userID) user, err := db.Provider.GetUserByID(gc, userID)
if err != nil { if err != nil {
log.Debug("GetUserByID failed: ", err) log.Debug("GetUserByID failed: ", err)
handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{ handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{
"error": "signup_required", "type": "authorization_response",
"error_description": "Sign up required", "response": map[string]string{
"error": "signup_required",
"error_description": "Sign up required",
},
}, http.StatusOK) }, http.StatusOK)
return return
} }
@@ -137,32 +153,18 @@ func AuthorizeHandler() gin.HandlerFunc {
// in case, response type is code and user is already logged in send the code and state // in case, response type is code and user is already logged in send the code and state
// and cookie session will already be rolled over and set // and cookie session will already be rolled over and set
// if responseMode == constants.ResponseModeFormPost { // gc.HTML(http.StatusOK, authorizeWebMessageTemplate, gin.H{
// gc.HTML(http.StatusOK, authorizeFormPostTemplate, gin.H{ // "target_origin": redirectURI,
// "target_origin": redirectURI, // "authorization_response": map[string]interface{}{
// "authorization_response": map[string]interface{}{ // "type": "authorization_response",
// "type": "authorization_response", // "response": map[string]string{
// "response": map[string]string{ // "code": code,
// "code": code, // "state": state,
// "state": state,
// },
// }, // },
// }) // },
// } else { // })
// gc.HTML(http.StatusOK, authorizeWebMessageTemplate, gin.H{
// "target_origin": redirectURI,
// "authorization_response": map[string]interface{}{
// "type": "authorization_response",
// "response": map[string]string{
// "code": code,
// "state": state,
// },
// },
// })
// }
params := "code=" + code + "&state=" + state params := "code=" + code + "&state=" + state
if responseMode == constants.ResponseModeQuery { if responseMode == constants.ResponseModeQuery {
if strings.Contains(redirectURI, "?") { if strings.Contains(redirectURI, "?") {
redirectURI = redirectURI + "&" + params redirectURI = redirectURI + "&" + params
@@ -178,8 +180,11 @@ func AuthorizeHandler() gin.HandlerFunc {
} }
handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{ handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{
"code": code, "type": "authorization_response",
"state": state, "response": map[string]string{
"code": code,
"state": state,
},
}, http.StatusOK) }, http.StatusOK)
return return
@@ -282,10 +287,8 @@ func validateAuthorizeRequest(responseType, responseMode, clientID, state, codeC
func handleResponse(gc *gin.Context, responseMode, loginURI, redirectURI string, data map[string]interface{}, httpStatusCode int) { func handleResponse(gc *gin.Context, responseMode, loginURI, redirectURI string, data map[string]interface{}, httpStatusCode int) {
isAuthenticationRequired := false isAuthenticationRequired := false
if val, ok := data["error"]; ok { if _, ok := data["response"].(map[string]string)["error"]; ok {
if val == "login_required" || val == "signup_required" { isAuthenticationRequired = true
isAuthenticationRequired = true
}
} }
switch responseMode { switch responseMode {