Merge pull request #48 from IdentityPython/certification_1

Changes necessary to complete OIDC certification.

Author: rohe

example/flask_rp/conf.json

@@ -162,9 +162,7 @@
       "redirect_uris": [
         "https://{domain}:{port}/authz_cb/local"
       ],
-      "post_logout_redirect_uris": [
-        "https://{domain}:{port}/session_logout/local"
-      ],
+      "post_logout_redirect_uri": "https://{domain}:{port}/session_logout/local",
       "frontchannel_logout_uri": "https://{domain}:{port}/fc_logout/local",
       "frontchannel_logout_session_required": true,
       "backchannel_logout_uri": "https://{domain}:{port}/bc_logout/local",
@@ -231,9 +229,7 @@
       "redirect_uris": [
         "https://{domain}:{port}/authz_cb/django"
       ],
-      "post_logout_redirect_uris": [
-        "https://{domain}:{port}/session_logout/django"
-      ],
+      "post_logout_redirect_uris": "https://{domain}:{port}/session_logout/django",
       "frontchannel_logout_uri": "https://{domain}:{port}/fc_logout/django",
       "frontchannel_logout_session_required": true,
       "backchannel_logout_uri": "https://{domain}:{port}/bc_logout/django",

example/flask_rp/templates/opresult.html

@@ -18,6 +18,10 @@ <h3>Endpoints</h3>
         <dd>{{ url }}</dd>
     {% endfor %}
 </dl>
+<dl>
+    <dt>ID Token</dt>
+    <dd>{{ id_token }}</dd>
+</dl>
 <h3>User information</h3>
 <dl>
     {% for key, value in userinfo.items() %}

example/flask_rp/views.py

@@ -53,10 +53,14 @@ def rp():
         uid = ''
 
     if iss or uid:
+        args = {
+            'req_args': {
+                "claims": {"id_token": {"acr": {"value": "https://refeds.org/profile/mfa"}}}
+            }
+        }
+
         if uid:
-            args = {'user_id': uid}
-        else:
-            args = {}
+            args['user_id'] = uid
 
         session['op_identifier'] = iss
         try:
@@ -145,14 +149,15 @@ def finalize(op_identifier, request_args):
         return render_template('opresult.html', endpoints=endpoints,
                                userinfo=res['userinfo'],
                                access_token=res['token'],
+                               id_token=res["id_token"],
                                **kwargs)
     else:
         return make_response(res['error'], 400)
 
 
 def get_op_identifier_by_cb_uri(url: str):
     uri = splitquery(url)[0]
-    for k,v in current_app.rph.issuer2rp.items():
+    for k, v in current_app.rph.issuer2rp.items():
         _cntx = v.get_service_context()
         for endpoint in ("redirect_uris",
                          "post_logout_redirect_uris",
@@ -180,10 +185,10 @@ def repost_fragment():
     return finalize(op_identifier, args)
 
 
-@oidc_rp_views.route('/ihf_cb')
-def ihf_cb(self, op_identifier='', **kwargs):
+@oidc_rp_views.route('/authz_im_cb')
+def authz_im_cb(op_identifier='', **kwargs):
     logger.debug('implicit_hybrid_flow kwargs: {}'.format(kwargs))
-    return render_template('repost_fragment.html')
+    return render_template('repost_fragment.html', op_identifier=op_identifier)
 
 
 @oidc_rp_views.route('/session_iframe')

setup.py

@@ -74,7 +74,7 @@ def run_tests(self):
         "Programming Language :: Python :: 3.9",
         "Topic :: Software Development :: Libraries :: Python Modules"],
     install_requires=[
-        'oidcmsg==1.3.3-1',
+        'oidcmsg==1.4.1',
         'pyyaml>=5.1.2',
         'responses'
     ],

src/oidcrp/__init__.py

@@ -1,7 +1,7 @@
 import logging
 
 __author__ = 'Roland Hedberg'
-__version__ = '2.0.1'
+__version__ = '2.1.0'
 
 logger = logging.getLogger(__name__)
 

src/oidcrp/client_auth.py

@@ -12,8 +12,8 @@
 from oidcmsg.oauth2 import SINGLE_OPTIONAL_STRING
 from oidcmsg.oidc import AuthnToken
 from oidcmsg.time_util import utc_time_sans_frac
+from oidcmsg.util import rndstr
 
-from oidcrp.util import rndstr
 from oidcrp.util import sanitize
 from .defaults import DEF_SIGN_ALG
 from .defaults import JWT_BEARER

src/oidcrp/configure.py

@@ -14,7 +14,7 @@
 try:
     from secrets import token_urlsafe as rnd_token
 except ImportError:
-    from oidcendpoint import rndstr as rnd_token
+    from cryptojwt import rndstr as rnd_token
 
 DEFAULT_FILE_ATTRIBUTE_NAMES = ['server_key', 'server_cert', 'filename', 'template_dir',
                                 'private_path', 'public_path', 'db_file']

src/oidcrp/oauth2/__init__.py

@@ -1,14 +1,19 @@
 from json import JSONDecodeError
 import logging
+from typing import Optional
 
 from oidcmsg.exception import FormatError
+from oidcmsg.message import Message
+from oidcmsg.oauth2 import is_error_message
 
 from oidcrp.entity import Entity
+from oidcrp.exception import ConfigurationError
 from oidcrp.exception import OidcServiceError
 from oidcrp.exception import ParseError
 from oidcrp.http import HTTPLib
 from oidcrp.service import REQUEST_INFO
 from oidcrp.service import SUCCESSFUL
+from oidcrp.service import Service
 from oidcrp.util import do_add_ons
 from oidcrp.util import get_deserialization_method
 
@@ -72,7 +77,11 @@ def __init__(self, client_authn_factory=None, keyjar=None, verify_ssl=True, conf
         # just ignore verify_ssl until it goes away
         self.verify_ssl = self.httpc_params.get("verify", True)
 
-    def do_request(self, request_type, response_body_type="", request_args=None, **kwargs):
+    def do_request(self,
+                   request_type: str,
+                   response_body_type: Optional[str] = "",
+                   request_args: Optional[dict] = None,
+                   behaviour_args: Optional[dict] = None, **kwargs):
         _srv = self._service[request_type]
 
         _info = _srv.get_request_parameters(request_args=request_args, **kwargs)
@@ -93,8 +102,13 @@ def set_client_id(self, client_id):
         self.client_id = client_id
         self._service_context.set('client_id', client_id)
 
-    def get_response(self, service, url, method="GET", body=None, response_body_type="",
-                     headers=None, **kwargs):
+    def get_response(self,
+                     service: Service,
+                     url: str,
+                     method: Optional[str] = "GET",
+                     body: Optional[dict] = None,
+                     response_body_type: Optional[str] = "",
+                     headers: Optional[dict] = None, **kwargs):
         """
 
         :param url:
@@ -129,8 +143,13 @@ def get_response(self, service, url, method="GET", body=None, response_body_type
         return self.parse_request_response(service, resp,
                                            response_body_type, **kwargs)
 
-    def service_request(self, service, url, method="GET", body=None,
-                        response_body_type="", headers=None, **kwargs):
+    def service_request(self,
+                        service: Service,
+                        url: str,
+                        method: Optional[str] = "GET",
+                        body: Optional[dict] = None,
+                        response_body_type: Optional[str] = "",
+                        headers: Optional[dict] = None, **kwargs) -> Message:
         """
         The method that sends the request and handles the response returned.
         This assumes that the response arrives in the HTTP response.
@@ -249,3 +268,27 @@ def parse_request_response(self, service, reqresp, response_body_type='',
                                                           reqresp.text))
             raise OidcServiceError("HTTP ERROR: %s [%s] on %s" % (
                 reqresp.text, reqresp.status_code, reqresp.url))
+
+
+def dynamic_provider_info_discovery(client: Client, behaviour_args: Optional[dict]=None):
+    """
+    This is about performing dynamic Provider Info discovery
+
+    :param behaviour_args:
+    :param client: A :py:class:`oidcrp.oidc.Client` instance
+    """
+    try:
+        client.get_service('provider_info')
+    except KeyError:
+        raise ConfigurationError(
+            'Can not do dynamic provider info discovery')
+    else:
+        _context = client.client_get("service_context")
+        try:
+            _context.set('issuer', _context.config['srv_discovery_url'])
+        except KeyError:
+            pass
+
+        response = client.do_request('provider_info', behaviour_args=behaviour_args)
+        if is_error_message(response):
+            raise OidcServiceError(response['error'])

src/oidcrp/oauth2/authorization.py

@@ -7,7 +7,7 @@
 from oidcmsg.time_util import time_sans_frac
 
 from oidcrp.oauth2.utils import get_state_parameter
-from oidcrp.oauth2.utils import pick_redirect_uris
+from oidcrp.oauth2.utils import pre_construct_pick_redirect_uri
 from oidcrp.oauth2.utils import set_state_parameter
 from oidcrp.service import Service
 
@@ -32,7 +32,7 @@ class Authorization(Service):
     def __init__(self, client_get, client_authn_factory=None, conf=None):
         Service.__init__(self, client_get,
                          client_authn_factory=client_authn_factory, conf=conf)
-        self.pre_construct.extend([pick_redirect_uris, set_state_parameter])
+        self.pre_construct.extend([pre_construct_pick_redirect_uri, set_state_parameter])
         self.post_construct.append(self.store_auth_request)
 
     def update_service_context(self, resp, key='', **kwargs):

src/oidcrp/oauth2/utils.py

@@ -1,4 +1,14 @@
+import logging
+from typing import Optional
+from typing import Union
+
 from oidcmsg.exception import MissingParameter
+from oidcmsg.exception import MissingRequiredAttribute
+from oidcmsg.message import Message
+
+from oidcrp.service import Service
+
+logger = logging.getLogger(__name__)
 
 
 def get_state_parameter(request_args, kwargs):
@@ -14,35 +24,48 @@ def get_state_parameter(request_args, kwargs):
     return _state
 
 
-def pick_redirect_uris(request_args=None, service=None, **kwargs):
-    """Pick one redirect_uri base on response_mode out of a list of such."""
-    _context = service.client_get("service_context")
+def pick_redirect_uri(context,
+                      request_args: Optional[Union[Message, dict]] = None,
+                      response_type: Optional[str] = ''):
+    if request_args is None:
+        request_args = {}
 
     if 'redirect_uri' in request_args:
-        return request_args, {}
+        return request_args["redirect_uri"]
 
-    _callback = _context.callback
-    if _callback:
-        try:
-            _response_type = request_args['response_type']
-        except KeyError:
-            _response_type = _context.behaviour['response_types'][0]
-            request_args['response_type'] = _response_type
+    if context.redirect_uris:
+        redirect_uri = context.redirect_uris[0]
+    elif context.callback:
+        if not response_type:
+            _conf_resp_types = context.behaviour.get('response_types', [])
+            response_type = request_args.get('response_type')
+            if not response_type and _conf_resp_types:
+                response_type = _conf_resp_types[0]
 
-        try:
-            _response_mode = request_args['response_mode']
-        except KeyError:
-            _response_mode = ''
+        _response_mode = request_args.get('response_mode')
 
-        if _response_mode == 'form_post':
-            request_args['redirect_uri'] = _callback['form_post']
-        elif _response_type == 'code':
-            request_args['redirect_uri'] = _callback['code']
+        if _response_mode == 'form_post' or response_type == ["form_post"]:
+            redirect_uri = context.callback['form_post']
+        elif response_type == 'code' or response_type == ["code"]:
+            redirect_uri = context.callback['code']
         else:
-            request_args['redirect_uri'] = _callback['implicit']
+            redirect_uri = context.callback['implicit']
+
+        logger.debug(
+            f"pick_redirect_uris: response_type={response_type}, response_mode={_response_mode}, "
+            f"redirect_uri={redirect_uri}")
     else:
-        request_args['redirect_uri'] = _context.redirect_uris[0]
+        logger.error("No redirect_uri")
+        raise MissingRequiredAttribute('redirect_uri')
 
+    return redirect_uri
+
+
+def pre_construct_pick_redirect_uri(request_args: Optional[Union[Message, dict]] = None,
+                                    service: Optional[Service] = None, **kwargs):
+    _context = service.client_get("service_context")
+    request_args["redirect_uri"] = pick_redirect_uri(_context,
+                                                     request_args=request_args)
     return request_args, {}