Compare commits

...

6 Commits

Author SHA1 Message Date
Lakhan Samani
c716638725 fix(server): revert the state & code_challenge validation 2022-10-18 23:24:19 +05:30
Lakhan Samani
252cd1fa2d fix: make code_challenge optional 2022-10-18 23:14:24 +05:30
Lakhan Samani
7c2693b086 fix: form post template 2022-10-18 23:03:55 +05:30
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
2 changed files with 49 additions and 33 deletions

View File

@@ -64,7 +64,7 @@ func AuthorizeHandler() gin.HandlerFunc {
if err := validateAuthorizeRequest(responseType, responseMode, clientID, state, codeChallenge); err != nil { if err := validateAuthorizeRequest(responseType, responseMode, clientID, state, codeChallenge); err != nil {
log.Debug("invalid authorization request: ", err) log.Debug("invalid authorization request: ", err)
gc.JSON(http.StatusBadRequest, gin.H{"error": err}) gc.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return return
} }
@@ -80,18 +80,39 @@ func AuthorizeHandler() gin.HandlerFunc {
// 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
if responseMode == constants.ResponseModeFragment { if responseMode == constants.ResponseModeFragment {
loginURL = "/app#" + loginState loginURL = "/app#" + loginState
} }
if state == "" {
handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{
"type": "authorization_response",
"response": map[string]interface{}{
"error": "state_required",
"error_description": "state is required",
},
}, http.StatusOK)
return
}
if responseType == constants.ResponseTypeCode && codeChallenge == "" {
handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{
"type": "authorization_response",
"response": map[string]interface{}{
"error": "code_challenge_required",
"error_description": "code challenge is required",
},
}, http.StatusOK)
}
loginError := map[string]interface{}{ loginError := map[string]interface{}{
"type": "authorization_response", "type": "authorization_response",
"response": map[string]string{ "response": map[string]interface{}{
"error": "login_required", "error": "login_required",
"error_description": "Login is required", "error_description": "Login is required",
}, },
} }
sessionToken, err := cookie.GetSession(gc) sessionToken, err := cookie.GetSession(gc)
if err != nil { if err != nil {
log.Debug("GetSession failed: ", err) log.Debug("GetSession failed: ", err)
@@ -106,13 +127,14 @@ 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{}{
"type": "authorization_response", "type": "authorization_response",
"response": map[string]string{ "response": map[string]interface{}{
"error": "signup_required", "error": "signup_required",
"error_description": "Sign up required", "error_description": "Sign up required",
}, },
@@ -163,25 +185,27 @@ func AuthorizeHandler() gin.HandlerFunc {
// }, // },
// }) // })
// 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 } else {
// } else { redirectURI = redirectURI + "?" + params
// redirectURI = redirectURI + "?" + params }
// } } else if responseMode == constants.ResponseModeFragment {
// } else if responseMode == constants.ResponseModeFragment { if strings.Contains(redirectURI, "#") {
// if strings.Contains(redirectURI, "#") { redirectURI = redirectURI + "&" + params
// redirectURI = redirectURI + "&" + params } else {
// } else { redirectURI = redirectURI + "#" + params
// redirectURI = redirectURI + "#" + params }
// } }
// }
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]interface{}{
"code": code,
"state": state,
},
}, http.StatusOK) }, http.StatusOK)
return return
@@ -267,24 +291,16 @@ func validateAuthorizeRequest(responseType, responseMode, clientID, state, codeC
return fmt.Errorf("invalid response mode %s. 'query', 'fragment', 'form_post' and 'web_message' are valid response_mode", responseMode) return fmt.Errorf("invalid response mode %s. 'query', 'fragment', 'form_post' and 'web_message' are valid response_mode", responseMode)
} }
if responseType == constants.ResponseTypeCode && strings.TrimSpace(codeChallenge) == "" {
return fmt.Errorf("code_challenge is required for %s '%s'", responseType, constants.ResponseTypeCode)
}
if client, err := memorystore.Provider.GetStringStoreEnvVariable(constants.EnvKeyClientID); client != clientID || err != nil { if client, err := memorystore.Provider.GetStringStoreEnvVariable(constants.EnvKeyClientID); client != clientID || err != nil {
return fmt.Errorf("invalid client_id %s", clientID) return fmt.Errorf("invalid client_id %s", clientID)
} }
if strings.TrimSpace(state) == "" {
return fmt.Errorf("state is required")
}
return nil return nil
} }
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 _, ok := data["error"]; ok { if _, ok := data["response"].(map[string]interface{})["error"]; ok {
isAuthenticationRequired = true isAuthenticationRequired = true
} }
@@ -305,7 +321,7 @@ func handleResponse(gc *gin.Context, responseMode, loginURI, redirectURI string,
case constants.ResponseModeFormPost: case constants.ResponseModeFormPost:
gc.HTML(httpStatusCode, authorizeFormPostTemplate, gin.H{ gc.HTML(httpStatusCode, authorizeFormPostTemplate, gin.H{
"target_origin": redirectURI, "target_origin": redirectURI,
"authorization_response": data, "authorization_response": data["response"],
}) })
return return
} }

View File

@@ -4,9 +4,9 @@
<title>Authorization Response</title> <title>Authorization Response</title>
</head> </head>
<body onload="document.forms['authorize_form_post'].submit()"> <body onload="document.forms['authorize_form_post'].submit()">
<form action={{.target_origin}} name="authorize_form_post"> <form action="{{.target_origin}}" name="authorize_form_post" method="POST">
{{ range $key, $val := .authorization_response }} {{ range $key, $val := .authorization_response }}
<input type="hidden" key={{$key}} value={{$val}} name={{$key}} id={{$key}} /> <input type="hidden" key="{{$key}}" value="{{$val}}" name="{{$key}}" id="{{$key}}" />
{{ end }} {{ end }}
</form> </form>
</body> </body>