merge hernani > trunk

[osqa.git] / forum_modules / openidauth / consumer.py

diff --git a/forum_modules/openidauth/consumer.py b/forum_modules/openidauth/consumer.py
index cc1e97d78ef30c75bef87fd9258d623efd3fd5eb..4c3818cbc41c47c6fa43e2cfe6b20dcc551a003f 100644 (file)
--- a/forum_modules/openidauth/consumer.py
+++ b/forum_modules/openidauth/consumer.py
@@ -26,6 +26,13 @@ class OpenIdAbstractAuthConsumer(AuthenticationConsumer):
         #'birthdate': 'http://axschema.org/birthDate',
     }
 
         #'birthdate': 'http://axschema.org/birthDate',
     }
 

+    sreg_attributes = {
+        "required": {
+            "email": "email",
+            "nickname": "username"
+        }
+    }
+

     def get_user_url(self, request):
         try:
             return request.POST['openid_identifier']
     def get_user_url(self, request):
         try:
             return request.POST['openid_identifier']


@@ -50,23 +57,26 @@ class OpenIdAbstractAuthConsumer(AuthenticationConsumer):
         except DiscoveryFailure:
             raise InvalidAuthentication(_('Sorry, but your input is not a valid OpenId'))
 
         except DiscoveryFailure:
             raise InvalidAuthentication(_('Sorry, but your input is not a valid OpenId'))
 

-        #sreg = getattr(settings, 'OPENID_SREG', False)
+        sreg = getattr(self, 'sreg_attributes', False)
+
+        if sreg:
+            s = SRegRequest()
+
+            for k, attr_dic in sreg.items():
+                if k == "policy_url":
+                    s.policy_url = attr_dic
+                    continue

 
 

-        #if sreg:
-        #    s = SRegRequest()
-        #    for sarg in sreg:
-        #        if sarg.lower().lstrip() == "policy_url":
-        #            s.policy_url = sreg[sarg]
-        #        else:
-        #            for v in sreg[sarg].split(','):
-        #                s.requestField(field_name=v.lower().lstrip(), required=(sarg.lower().lstrip() == "required"))
-        #    auth_request.addExtension(s)
+                for attr_name in attr_dic.keys():
+                    s.requestField(field_name=attr_name, required=(k == "required"))

 
 

-        #auth_request.addExtension(SRegRequest(required=['email']))
+            auth_request.addExtension(s)

 
 

-        if request.session.get('force_email_request', True):
+        ax_schema = getattr(self, 'dataype2ax_schema', False)
+
+        if ax_schema and request.session.get('force_email_request', True):

             axr = AXFetchRequest()
             axr = AXFetchRequest()

-            for data_type, schema in self.dataype2ax_schema.items():
+            for data_type, schema in ax_schema.items():

                 if isinstance(schema, tuple):
                     axr.add(AttrInfo(schema[0], 1, True, schema[1]))
                 else:
                 if isinstance(schema, tuple):
                     axr.add(AttrInfo(schema[0], 1, True, schema[1]))
                 else:


@@ -94,31 +104,41 @@ class OpenIdAbstractAuthConsumer(AuthenticationConsumer):
         openid_response = consumer.complete(query_dict, url)
 
         if openid_response.status == SUCCESS:
         openid_response = consumer.complete(query_dict, url)
 
         if openid_response.status == SUCCESS:

-            if request.session.get('force_email_request', True):
-                try:
-                    ax = AXFetchResponse.fromSuccessResponse(openid_response)

 
 

-                    axargs = ax.getExtensionArgs()
+            consumer_data = {}
+
+            sreg_attrs = getattr(self, 'sreg_attributes', False)
+
+            if sreg_attrs:
+                sreg_response = SRegResponse.fromSuccessResponse(openid_response)

 
 

-                    ax_schema2data_type = dict([(s, t) for t, s in self.dataype2ax_schema.items()])
+                all_attrs = {}
+                [all_attrs.update(d) for k,d in sreg_attrs.items() if k != "policy_url"]

 
 

-                    available_types = dict([
-                        (ax_schema2data_type[s], re.sub('^type\.', '', n))
-                        for n, s in axargs.items() if s in ax_schema2data_type
-                    ])
+                for attr_name, local_name in all_attrs.items():
+                    if attr_name in sreg_response:
+                        consumer_data[local_name] = sreg_response[attr_name]

 
 

-                    available_data = dict([
-                        (t, axargs["value.%s.1" % s]) for t, s in available_types.items()
-                    ])
+            ax_schema = getattr(self, 'dataype2ax_schema', False)
+
+            if ax_schema:
+                ax = AXFetchResponse.fromSuccessResponse(openid_response)
+
+                axargs = ax.getExtensionArgs()
+
+                ax_schema2data_type = dict([(s, t) for t, s in ax_schema.items()])
+
+                available_types = dict([
+                    (ax_schema2data_type[s], re.sub('^type\.', '', n))
+                    for n, s in axargs.items() if s in ax_schema2data_type
+                ])
+
+                for t, s in available_types.items():
+                    if not t in consumer_data:
+                        consumer_data[t] = axargs["value.%s.1" % s]

                     
                     

-                    request.session['auth_consumer_data'] = {
-                        'email': available_data.get('email', None),
-                    }
-
-                except Exception, e:
-                    pass
-                    #import sys, traceback
-                    #traceback.print_exc(file=sys.stdout)
+            request.session['auth_consumer_data'] = consumer_data
+

 
             return request.GET['openid.identity']
         elif openid_response.status == CANCEL:
 
             return request.GET['openid.identity']
         elif openid_response.status == CANCEL: