|
|
|
@@ -64,7 +64,7 @@ func AuthorizeHandler() gin.HandlerFunc {
|
|
|
|
|
|
|
|
|
|
if err := validateAuthorizeRequest(responseType, responseMode, clientID, state, codeChallenge); err != nil {
|
|
|
|
|
log.Debug("invalid authorization request: ", err)
|
|
|
|
|
gc.JSON(http.StatusBadRequest, gin.H{"error": err})
|
|
|
|
|
gc.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -80,18 +80,39 @@ func AuthorizeHandler() gin.HandlerFunc {
|
|
|
|
|
// used for response mode query or fragment
|
|
|
|
|
loginState := "state=" + state + "&scope=" + strings.Join(scope, " ") + "&redirect_uri=" + redirectURI
|
|
|
|
|
loginURL := "/app?" + loginState
|
|
|
|
|
|
|
|
|
|
if responseMode == constants.ResponseModeFragment {
|
|
|
|
|
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{}{
|
|
|
|
|
"type": "authorization_response",
|
|
|
|
|
"response": map[string]string{
|
|
|
|
|
"response": map[string]interface{}{
|
|
|
|
|
"error": "login_required",
|
|
|
|
|
"error_description": "Login is required",
|
|
|
|
|
},
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
sessionToken, err := cookie.GetSession(gc)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Debug("GetSession failed: ", err)
|
|
|
|
@@ -113,7 +134,7 @@ func AuthorizeHandler() gin.HandlerFunc {
|
|
|
|
|
log.Debug("GetUserByID failed: ", err)
|
|
|
|
|
handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{
|
|
|
|
|
"type": "authorization_response",
|
|
|
|
|
"response": map[string]string{
|
|
|
|
|
"response": map[string]interface{}{
|
|
|
|
|
"error": "signup_required",
|
|
|
|
|
"error_description": "Sign up required",
|
|
|
|
|
},
|
|
|
|
@@ -181,7 +202,7 @@ func AuthorizeHandler() gin.HandlerFunc {
|
|
|
|
|
|
|
|
|
|
handleResponse(gc, responseMode, loginURL, redirectURI, map[string]interface{}{
|
|
|
|
|
"type": "authorization_response",
|
|
|
|
|
"response": map[string]string{
|
|
|
|
|
"response": map[string]interface{}{
|
|
|
|
|
"code": code,
|
|
|
|
|
"state": state,
|
|
|
|
|
},
|
|
|
|
@@ -270,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)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
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 {
|
|
|
|
|
return fmt.Errorf("invalid client_id %s", clientID)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if strings.TrimSpace(state) == "" {
|
|
|
|
|
return fmt.Errorf("state is required")
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func handleResponse(gc *gin.Context, responseMode, loginURI, redirectURI string, data map[string]interface{}, httpStatusCode int) {
|
|
|
|
|
isAuthenticationRequired := false
|
|
|
|
|
if _, ok := data["response"].(map[string]string)["error"]; ok {
|
|
|
|
|
if _, ok := data["response"].(map[string]interface{})["error"]; ok {
|
|
|
|
|
isAuthenticationRequired = true
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -308,7 +321,7 @@ func handleResponse(gc *gin.Context, responseMode, loginURI, redirectURI string,
|
|
|
|
|
case constants.ResponseModeFormPost:
|
|
|
|
|
gc.HTML(httpStatusCode, authorizeFormPostTemplate, gin.H{
|
|
|
|
|
"target_origin": redirectURI,
|
|
|
|
|
"authorization_response": data,
|
|
|
|
|
"authorization_response": data["response"],
|
|
|
|
|
})
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|