enable microservice-based flow to replay AuthnRequest

(requires wsgi_app in registered callback)

Author: rhoerbe

src/satosa/backends/base.py

@@ -32,7 +32,7 @@ def __init__(self, auth_callback_func, internal_attributes, base_url, name):
         self.base_url = base_url
         self.name = name
 
-    def start_auth(self, context, internal_request):
+    def start_auth(self, context, internal_request, **kwargs):
         """
         This is the start up function of the backend authorization.
 

src/satosa/backends/github.py

@@ -45,7 +45,7 @@ def __init__(self, outgoing, internal_attributes, config, base_url, name):
             outgoing, internal_attributes, config, base_url, name, 'github',
             'id')
 
-    def start_auth(self, context, internal_request, get_state=stateID):
+    def start_auth(self, context, internal_request, get_state=stateID, **kwargs):
         """
         :param get_state: Generates a state to be used in authentication call
 
@@ -75,7 +75,7 @@ def auth_info(self, requrest):
             UNSPECIFIED, None,
             self.config['server_info']['authorization_endpoint'])
 
-    def _authn_response(self, context):
+    def _authn_response(self, context, **kwargs):
         state_data = context.state[self.name]
         aresp = self.consumer.parse_response(
             AuthorizationResponse, info=json.dumps(context.request))

src/satosa/backends/linkedin.py

@@ -46,7 +46,7 @@ def __init__(self, outgoing, internal_attributes, config, base_url, name):
             outgoing, internal_attributes, config, base_url, name, 'linkedin',
             'id')
 
-    def start_auth(self, context, internal_request, get_state=stateID):
+    def start_auth(self, context, internal_request, get_state=stateID, **kwargs):
         """
         :param get_state: Generates a state to be used in authentication call
 
@@ -76,7 +76,7 @@ def auth_info(self, requrest):
             UNSPECIFIED, None,
             self.config['server_info']['authorization_endpoint'])
 
-    def _authn_response(self, context):
+    def _authn_response(self, context, **kwargs):
         state_data = context.state[self.name]
         aresp = self.consumer.parse_response(
             AuthorizationResponse, info=json.dumps(context.request))

src/satosa/backends/oauth.py

@@ -64,7 +64,7 @@ def __init__(self, outgoing, internal_attributes, config, base_url, name, extern
             response_type=self.config["response_type"])
         self.consumer.client_secret = self.config["client_secret"]
 
-    def start_auth(self, context, internal_request, get_state=stateID):
+    def start_auth(self, context, internal_request, get_state=stateID, **kwargs):
         """
         See super class method satosa.backends.base#start_auth
         :param get_state: Generates a state to be used in the authentication call.
@@ -118,7 +118,7 @@ def _verify_state(self, resp, state_data, state):
                                             "Missing or invalid state [%s] in response!" %
                                             received_state)
 
-    def _authn_response(self, context):
+    def _authn_response(self, context, **kwargs):
         """
         Handles the authentication response from the AS.
 

src/satosa/backends/openid_connect.py

@@ -64,7 +64,7 @@ def __init__(self, auth_callback_func, internal_attributes, config, base_url, na
         if "response_type" not in config["client"]["auth_req_params"]:
             config["auth_req_params"]["response_type"] = "code"
 
-    def start_auth(self, context, request_info):
+    def start_auth(self, context, request_info, **kwargs):
         """
         See super class method satosa.backends.base#start_auth
         :type context: satosa.context.Context
@@ -167,7 +167,7 @@ def _get_userinfo(self, state, context):
         self._check_error_response(userinfo_resp, context)
         return userinfo_resp.to_dict()
 
-    def response_endpoint(self, context, *args):
+    def response_endpoint(self, context, *args, **kwargs):
         """
         Handles the authentication response from the OP.
         :type context: satosa.context.Context

src/satosa/backends/orcid.py

@@ -60,7 +60,7 @@ def auth_info(self, requrest):
             UNSPECIFIED, None,
             self.config['server_info']['authorization_endpoint'])
 
-    def _authn_response(self, context):
+    def _authn_response(self, context, **kwargs):
         state_data = context.state[self.name]
         aresp = self.consumer.parse_response(
             AuthorizationResponse, info=json.dumps(context.request))

src/satosa/backends/saml2.py

@@ -129,7 +129,7 @@ def __init__(self, outgoing, internal_attributes, config, base_url, name):
             with open(p) as key_file:
                 self.encryption_keys.append(key_file.read())
 
-    def get_idp_entity_id(self, context):
+    def get_idp_entity_id(self, context, **kwargs):
         """
         :type context: satosa.context.Context
         :rtype: str | None
@@ -164,7 +164,7 @@ def get_idp_entity_id(self, context):
         )
         return entity_id
 
-    def start_auth(self, context, internal_req):
+    def start_auth(self, context, internal_req, **kwargs):
         """
         See super class method satosa.backends.base.BackendModule#start_auth
 
@@ -184,7 +184,7 @@ def start_auth(self, context, internal_req):
 
         return self.authn_request(context, entity_id)
 
-    def disco_query(self, context):
+    def disco_query(self, context, **kwargs):
         """
         Makes a request to the discovery server
 
@@ -236,7 +236,7 @@ def construct_requested_authn_context(self, entity_id):
 
         return authn_context
 
-    def authn_request(self, context, entity_id):
+    def authn_request(self, context, entity_id, **kwargs):
         """
         Do an authorization request on idp with given entity id.
         This is the start of the authorization.
@@ -294,7 +294,7 @@ def authn_request(self, context, entity_id):
         context.state[self.name] = {"relay_state": relay_state}
         return make_saml_response(binding, ht_args)
 
-    def authn_response(self, context, binding):
+    def authn_response(self, context, binding, **kwargs):
         """
         Endpoint for the idp response
         :type context: satosa.context,Context
@@ -326,11 +326,12 @@ def authn_response(self, context, binding):
                 raise SATOSAAuthenticationError(context.state, errmsg)
             del self.outstanding_queries[req_id]
 
-        # check if the relay_state matches the cookie state
-        if context.state[self.name]["relay_state"] != context.request["RelayState"]:
-            satosa_logging(logger, logging.DEBUG,
-                           "State did not match relay state for state", context.state)
-            raise SATOSAAuthenticationError(context.state, "State did not match relay state")
+        # if the response relay_state exists it must match that from the request
+        if self.name in context.state and "relay_state" in context.state[self.name]:
+            if context.state[self.name]["relay_state"] != context.request["RelayState"]:
+                logger.debug("State did not match relay state for state", extra={'state': context.state})
+                raise SATOSAAuthenticationError(context.state, "State did not match relay state")
+            del context.state[self.name]
 
         context.decorate(Context.KEY_BACKEND_METADATA_STORE, self.sp.metadata)
         if self.config.get(SAMLBackend.KEY_MEMORIZE_IDP):
@@ -340,7 +341,7 @@ def authn_response(self, context, binding):
         context.state.pop(Context.KEY_FORCE_AUTHN, None)
         return self.auth_callback_func(context, self._translate_response(authn_response, context.state))
 
-    def disco_response(self, context):
+    def disco_response(self, context, **kwargs):
         """
         Endpoint for the discovery server response
 
@@ -406,7 +407,7 @@ def _translate_response(self, response, state):
                        json.dumps(response.ava, indent=4), state)
         return internal_resp
 
-    def _metadata_endpoint(self, context):
+    def _metadata_endpoint(self, context, **kwargs):
         """
         Endpoint for retrieving the backend metadata
         :type context: satosa.context.Context

src/satosa/base.py

@@ -226,7 +226,7 @@ def _run_bound_endpoint(self, context, spec):
         :return: response
         """
         try:
-            return spec(context)
+            return spec(context, wsgi_app=self)
         except SATOSAAuthenticationError as error:
             error.error_id = uuid.uuid4().urn
             state = json.dumps(error.state.state_dict, indent=4)

src/satosa/frontends/base.py

@@ -26,7 +26,7 @@ def __init__(self, auth_req_callback_func, internal_attributes, base_url, name):
         self.base_url = base_url
         self.name = name
 
-    def handle_authn_response(self, context, internal_resp):
+    def handle_authn_response(self, context, internal_resp, **kwargs):
         """
         If an authorization has been successful in a backend, this function is called and is
         supposed to send an authorization response to the client.

src/satosa/frontends/openid_connect.py

@@ -117,7 +117,7 @@ def _init_authorization_state(self):
         return AuthorizationState(HashBasedSubjectIdentifierFactory(sub_hash_salt), authz_code_db, access_token_db,
                                   refresh_token_db, sub_db, **token_lifetimes)
 
-    def handle_authn_response(self, context, internal_resp, extra_id_token_claims=None):
+    def handle_authn_response(self, context, internal_resp, extra_id_token_claims=None, **kwargs):
         """
         See super class method satosa.frontends.base.FrontendModule#handle_authn_response
         :type context: satosa.context.Context
@@ -232,7 +232,7 @@ def _get_authn_request_from_state(self, state):
         """
         return AuthorizationRequest().deserialize(state[self.name]["oidc_request"])
 
-    def client_registration(self, context):
+    def client_registration(self, context, **kwargs):
         """
         Handle the OIDC dynamic client registration.
         :type context: satosa.context.Context
@@ -247,7 +247,7 @@ def client_registration(self, context):
         except InvalidClientRegistrationRequest as e:
             return BadRequest(e.to_json(), content="application/json")
 
-    def provider_config(self, context):
+    def provider_config(self, context, **kwargs):
         """
         Construct the provider configuration information (served at /.well-known/openid-configuration).
         :type context: satosa.context.Context
@@ -270,7 +270,7 @@ def _get_approved_attributes(self, provider_supported_claims, authn_req):
                     requested_claims.extend(authn_req["claims"][k].keys())
         return set(provider_supported_claims).intersection(set(requested_claims))
 
-    def _handle_authn_request(self, context):
+    def _handle_authn_request(self, context, **kwargs):
         """
         Parse and verify the authentication request into an internal request.
         :type context: satosa.context.Context
@@ -315,7 +315,7 @@ def _handle_authn_request(self, context):
                                                     authn_req))
         return internal_req
 
-    def handle_authn_request(self, context):
+    def handle_authn_request(self, context, **kwargs):
         """
         Handle an authentication request and pass it on to the backend.
         :type context: satosa.context.Context
@@ -329,7 +329,7 @@ def handle_authn_request(self, context):
             return internal_req
         return self.auth_req_callback_func(context, internal_req)
 
-    def jwks(self, context):
+    def jwks(self, context, **kwargs):
         """
         Construct the JWKS document (served at /jwks).
         :type context: satosa.context.Context
@@ -340,7 +340,7 @@ def jwks(self, context):
         """
         return Response(json.dumps(self.provider.jwks), content="application/json")
 
-    def token_endpoint(self, context):
+    def token_endpoint(self, context, **kwargs):
         """
         Handle token requests (served at /token).
         :type context: satosa.context.Context
@@ -364,7 +364,7 @@ def token_endpoint(self, context):
             error_resp = TokenErrorResponse(error=e.oauth_error, error_description=str(e))
             return BadRequest(error_resp.to_json(), content="application/json")
 
-    def userinfo_endpoint(self, context):
+    def userinfo_endpoint(self, context, **kwargs):
         headers = {"Authorization": context.request_authorization}
 
         try: