diff --git a/plexpy/activity_handler.py b/plexpy/activity_handler.py index 708eb0df..313fef77 100644 --- a/plexpy/activity_handler.py +++ b/plexpy/activity_handler.py @@ -45,6 +45,12 @@ class ActivityHandler(object): return None + def get_rating_key(self): + if self.is_valid_session(): + return int(self.timeline['ratingKey']) + + return None + def get_live_session(self): pms_connect = pmsconnect.PmsConnect() session_list = pms_connect.get_current_activity() @@ -63,7 +69,8 @@ class ActivityHandler(object): def on_start(self): if self.is_valid_session() and self.get_live_session(): - logger.debug(u"PlexPy ActivityHandler :: Session %s has started." % str(self.get_session_key())) + logger.debug(u"PlexPy ActivityHandler :: Session %s has started with ratingKey %s." + % (str(self.get_session_key()), str(self.get_rating_key()))) session = self.get_live_session() @@ -127,7 +134,8 @@ class ActivityHandler(object): monitor_proc.write_session_history(session=db_session) # Remove the session from our temp session table - logger.debug(u"PlexPy ActivityHandler :: Removing session %s from session queue" % str(self.get_session_key())) + logger.debug(u"PlexPy ActivityHandler :: Removing sessionKey %s ratingKey %s from session queue" + % (str(self.get_session_key()), str(self.get_rating_key()))) ap.delete_session(session_key=self.get_session_key()) def on_pause(self): diff --git a/plexpy/activity_pinger.py b/plexpy/activity_pinger.py index 8ab3bf31..c07ea77b 100644 --- a/plexpy/activity_pinger.py +++ b/plexpy/activity_pinger.py @@ -230,7 +230,8 @@ def check_active_sessions(ws_request=False): new_session = monitor_process.write_session(session) if new_session: - logger.debug(u"PlexPy Monitor :: Session %s has started." % session['session_key']) + logger.debug(u"PlexPy Monitor :: Session %s has started with ratingKey %s." + % (session['session_key'], session['rating_key'])) else: logger.debug(u"PlexPy Monitor :: Unable to read session list.")