Working Last.fm scrobbler

mopidy/frontends/lastfm.py

@@ -1,14 +1,80 @@
+import logging
+import socket
+import time
+
+import pylast
+
+from mopidy import get_version, settings, SettingsError
 from mopidy.frontends.base import BaseFrontend
 
+logger = logging.getLogger('mopidy.frontends.lastfm')
+
+CLIENT_ID = u'mop'
+CLIENT_VERSION = get_version()
+
 class LastfmFrontend(BaseFrontend):
+    """
+    Frontend which scrobbles the music you plays to your Last.fm profile.
+
+    **Settings:**
+
+    - :mod:`mopidy.settings.LASTFM_USERNAME`
+    - :mod:`mopidy.settings.LASTFM_PASSWORD`
+    """
+
     def __init__(self, *args, **kwargs):
         super(LastfmFrontend, self).__init__(*args, **kwargs)
+        self.lastfm = None
+        self.scrobbler = None
 
     def start(self):
-        pass
+        # TODO Split into own thread/process
+        try:
+            username = settings.LASTFM_USERNAME
+            password_hash = pylast.md5(settings.LASTFM_PASSWORD)
+            self.lastfm = pylast.get_lastfm_network(
+                username=username, password_hash=password_hash)
+            self.scrobbler = self.lastfm.get_scrobbler(
+                CLIENT_ID, CLIENT_VERSION)
+            logger.info(u'Connected to Last.fm')
+        except SettingsError as e:
+            logger.info(u'Last.fm scrobbler did not start.')
+            logger.debug(u'Last.fm settings error: %s', e)
+        except (pylast.WSError, socket.error) as e:
+            logger.error(u'Last.fm connection error: %s', e)
 
     def destroy(self):
         pass
 
     def process_message(self, message):
-        pass
+        if message['command'] == 'now_playing':
+            self.report_now_playing(message['track'])
+        elif message['command'] == 'end_of_track':
+            self.scrobble(message['track'])
+        else:
+            pass # Ignore commands for other frontends
+
+    def report_now_playing(self, track):
+        artists = ', '.join([a.name for a in track.artists])
+        logger.debug(u'Now playing track: %s - %s', artists, track.name)
+        duration = track.length // 1000
+        try:
+            self.scrobbler.report_now_playing(artists, track.name,
+                album=track.album.name, duration=duration,
+                track_number=track.track_no)
+        except (pylast.ScrobblingError, socket.error) as e:
+            logger.error(u'Last.fm now playing error: %s', e)
+
+    def scrobble(self, track):
+        artists = ', '.join([a.name for a in track.artists])
+        logger.debug(u'Scrobbling track: %s - %s', artists, track.name)
+        # FIXME Get actual time when track started playing
+        duration = track.length // 1000
+        time_started = int(time.time()) - duration
+        try:
+            self.scrobbler.scrobble(artists, track.name,
+                time_started=time_started, source=pylast.SCROBBLE_SOURCE_USER,
+                mode=pylast.SCROBBLE_MODE_PLAYED, duration=duration,
+                album=track.album.name, track_number=track.track_no)
+        except (pylast.ScrobblingError, socket.error) as e:
+            logger.error(u'Last.fm scrobbling error: %s', e)