Source code for spotify

from __future__ import unicode_literals

import threading

import pkg_resources

__version__ = pkg_resources.get_distribution("pyspotify").version

# Global reentrant lock to be held whenever libspotify functions are called or
# libspotify owned data is worked on. This is the heart of pyspotify's thread
# safety.
_lock = threading.RLock()

# Reference to the spotify.Session instance. Used to enforce that one and only
# one session exists in each process.
_session_instance = None

def _setup_logging():
    """Setup logging to log to nowhere by default.

    For details, see:

    Internal function.
    import logging

    logger = logging.getLogger("spotify")
    handler = logging.NullHandler()

[docs]def serialized(f): """Decorator that serializes access to all decorated functions. The decorator acquires pyspotify's single global lock while calling any wrapped function. It is used to serialize access to: - All calls to functions on :attr:`spotify.lib`. - All code blocks working on pointers returned from functions on :attr:`spotify.lib`. - All code blocks working on other internal data structures in pyspotify. Together this is what makes pyspotify safe to use from multiple threads and enables convenient features like the :class:`~spotify.EventLoop`. Internal function. """ import functools @functools.wraps(f) def wrapper(*args, **kwargs): if _lock is None: # During process teardown, objects wrapped with `ffi.gc()` might be # freed and their libspotify release functions called after the lock # has been freed. When this happens, `_lock` will be `None`. # Since we're already shutting down the process, we just abort the # call when the lock is gone. return with _lock: return f(*args, **kwargs) if not hasattr(wrapper, "__wrapped__"): # Workaround for Python < 3.2 wrapper.__wrapped__ = f return wrapper
class _SerializedLib(object): """CFFI library wrapper to serialize all calls to library functions. Internal class. """ def __init__(self, lib): for name in dir(lib): attr = getattr(lib, name) if name.startswith("sp_") and callable(attr): attr = serialized(attr) setattr(self, name, attr) _setup_logging() from spotify._spotify import ffi, lib # noqa lib = _SerializedLib(lib) from spotify.album import * # noqa from spotify.artist import * # noqa from import * # noqa from spotify.config import * # noqa from spotify.connection import * # noqa from spotify.error import * # noqa from spotify.eventloop import * # noqa from spotify.image import * # noqa from spotify.inbox import * # noqa from import * # noqa from spotify.offline import * # noqa from spotify.player import * # noqa from spotify.playlist import * # noqa from spotify.playlist_container import * # noqa from spotify.playlist_track import * # noqa from spotify.playlist_unseen_tracks import * # noqa from import * # noqa from spotify.session import * # noqa from spotify.sink import * # noqa from import * # noqa from spotify.toplist import * # noqa from spotify.track import * # noqa from spotify.user import * # noqa from spotify.version import * # noqa