Ozwillo » Modules CKAN Ozwillo

import logging

import ckan.plugins.toolkit as toolkit

plugin_config_prefix = 'ckanext.ozwillo_pyoidc.'

log = logging.getLogger(__name__)

class Clients(object):

    @classmethod

        params['client_registration'].update({

            'client_id': g._extras['client_id'].value,

            'client_secret': g._extras['client_secret'].value,

                                      controller=plugin_controller,

                                      action='callback',

                                      id=g.name,

                                      qualified=True)]

        return create_client(**params)

class OzwilloPyoidcPlugin(plugins.SingletonPlugin):

    plugins.implements(plugins.IConfigurer)

    plugins.implements(plugins.IAuthenticator, inherit=True)

                    controller=plugin_controller,

                    action='sso')

        map.connect('/organization/{id:.*}/callback',

                    controller=plugin_controller,

                    action='callback')

                    controller=plugin_controller,

    def after_map(self, map):

        return map

    def identify(self):

        if user and not toolkit.c.userobj:

            userobj = model.User.get(user)

            toolkit.c.user = userobj.name

            toolkit.c.userobj = userobj

    def login(self):

            value = request.cookies.get(cookie)

            response.set_cookie(cookie, value, secure=True, httponly=True)

            g = model.Group.get(session['organization_id'])

            url, ht_args, state = client.create_authn_request(conf.ACR_VALUES)

            session['state'] = state

            session.save()

                toolkit.request.headers.update(ht_args)

    def logout(self):

        g = model.Group.get(session['organization_id'])

            response.delete_cookie(cookie)

                                      controller='organization',

                                      action='read',

                                      id=g.name,

                                      qualified=True)

    def update_config(self, config_):

        toolkit.add_template_directory(config_, 'templates')

        toolkit.add_public_directory(config_, 'public')

        toolkit.add_resource('fanstatic', 'ozwillo_pyoidc')

class OpenidController(base.BaseController):

        log.info('SSO for organization "%s"' % id)

        session['organization_id'] = id

        session.save()

        log.info('redirecting to login page')

        login_url = toolkit.url_for(host=request.host,

                                    controller='user',

                                    action='login',

                                    qualified=True)

    def callback(self):

                                      action='read',

                                      id=g.name))

        try:

                = client.callback(session['state'], request.GET)

            session['access_token'] = access_token

            session['id_token'] = id_token

            session.save()

            flash_error('Login failed')

            redirect_to(org_url, qualified=True)

            if '-' in locale:

                locale, country = locale.split('-')

                user_dict = {'id': userinfo['sub'],

                             'name': userinfo['sub'].replace('-', ''),

                             'email': userinfo['email'],

                             'password': userinfo['sub']

                             }

                context = {'ignore_auth': True, 'model': model,

                           'session': model.Session}

                user_create(context, user_dict)

                userobj = model.User.get(userinfo['sub'])

                        'id': g.id,

                        'object': userinfo['sub'],

                        'object_type': 'user',

                        'capacity': 'admin',

                    }

                    member_create_context = {

                        'model': model,

                        'user': userobj.name,

                        'ignore_auth': True,

                        'session': session

                    }

                    member_create(member_create_context, member_dict)

                userobj.fullname = userinfo['given_name']

            if 'family_name' in userinfo:

                userobj.fullname += ' ' + userinfo['family_name']

            userobj.save()

                userobj.name = userinfo['nickname']

            try:

                userobj.save()

            except Exception, e:

                log.warning('Error while saving user name: %s' % e)

            session.save()

        """

        Revokes the delivered access token. Logs out the user

        """

        if not request.referer or request.host not in request.referer:

            redirect_to('/')

                          controller='organization',

                          action='read',

                          id=g.name,

                          qualified=True)

            redirect_uri = org_url + '/logout'

            # revoke the access token

            headers = {'Content-Type': 'application/x-www-form-urlencoded'}

            client.http_request(client.revocation_endpoint, 'POST',

                                data=data, headers=headers)

            # redirect to IDP logout