Logo Search packages:      
Sourcecode: python-openid version File versions


00001 class YadisServiceManager(object):
    """Holds the state of a list of selected Yadis services, managing
    storing it in a session and iterating over the services in order."""

    def __init__(self, starting_url, yadis_url, services, session_key):
        # The URL that was used to initiate the Yadis protocol
        self.starting_url = starting_url

        # The URL after following redirects (the identifier)
        self.yadis_url = yadis_url

        # List of service elements
        self.services = list(services)

        self.session_key = session_key

        # Reference to the current service object
        self._current = None

00020     def __len__(self):
        """How many untried services remain?"""
        return len(self.services)

    def __iter__(self):
        return self

00027     def next(self):
        """Return the next service

        self.current() will continue to return that service until the
        next call to this method."""
            self._current = self.services.pop(0)
        except IndexError:
            raise StopIteration
            return self._current

00039     def current(self):
        """Return the current service.

        Returns None if there are no services left.
        return self._current

    def forURL(self, url):
        return url in [self.starting_url, self.yadis_url]

00049     def started(self):
        """Has the first service been returned?"""
        return self._current is not None

00053     def store(self, session):
        """Store this object in the session, by its session key."""
        session[self.session_key] = self

00057 class Discovery(object):
    """State management for discovery.

    High-level usage pattern is to call .getNextService(discover) in
    order to find the next available service for this user for this
    session. Once a request completes, call .finish() to clean up the
    session state.

    @ivar session: a dict-like object that stores state unique to the
        requesting user-agent. This object must be able to store
        serializable objects.

    @ivar url: the URL that is used to make the discovery request

    @ivar session_key_suffix: The suffix that will be used to identify
        this object in the session object.

    DEFAULT_SUFFIX = 'auth'
    PREFIX = '_yadis_services_'

00078     def __init__(self, session, url, session_key_suffix=None):
        """Initialize a discovery object"""
        self.session = session
        self.url = url
        if session_key_suffix is None:
            session_key_suffix = self.DEFAULT_SUFFIX

        self.session_key_suffix = session_key_suffix

00087     def getNextService(self, discover):
        """Return the next authentication service for the pair of
        user_input and session.  This function handles fallback.

        @param discover: a callable that takes a URL and returns a
            list of services

        @type discover: str -> [service]

        @return: the next available service
        manager = self.getManager()
        if manager is not None and not manager:

        if not manager:
            yadis_url, services = discover(self.url)
            manager = self.createManager(services, yadis_url)

        if manager:
            service = manager.next()
            service = None

        return service

00116     def cleanup(self):
        """Clean up Yadis-related services in the session and return
        the most-recently-attempted service from the manager, if one

        @return: current service endpoint object or None if there is
            no current service
        manager = self.getManager()
        if manager is not None:
            service = manager.current()
            service = None

        return service

    ### Lower-level methods

00135     def getSessionKey(self):
        """Get the session key for this starting URL and suffix

        @return: The session key
        @rtype: str
        return self.PREFIX + self.session_key_suffix

00143     def getManager(self):
        """Extract the YadisServiceManager for this object's URL and
        suffix from the session.

        @return: The current YadisServiceManager, if it's for this
            URL, or else None
        manager = self.session.get(self.getSessionKey())
        if (manager is not None and manager.forURL(self.url)):
            return manager
            return None

00156     def createManager(self, services, yadis_url=None):
        """Create a new YadisService Manager for this starting URL and
        suffix, and store it in the session.

        @raises KeyError: When I already have a manager.

        @return: A new YadisServiceManager or None
        key = self.getSessionKey()
        if self.getManager():
            raise KeyError('There is already a %r manager for %r' %
                           (key, self.url))

        if not services:
            return None

        manager = YadisServiceManager(self.url, yadis_url, services, key)
        return manager

00176     def destroyManager(self):
        """Delete any YadisServiceManager with this starting URL and
        suffix from the session.

        If there is no service manager or the service manager is for a
        different URL, it silently does nothing.
        if self.getManager() is not None:
            key = self.getSessionKey()
            del self.session[key]

Generated by  Doxygen 1.6.0   Back to index