github/plexpy
1
0
Fork 0
mirror of https://github.com/Tautulli/Tautulli.git synced 2025-07-14 09:12:58 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update write_session_history to include the reference_id

Browse source
This commit is contained in:
Jonathan Wong 2015-09-16 11:37:50 -07:00
parent 881142d4a1
commit c85ee3aec0
1 changed files with 23 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

23
plexpy/monitor.py
View file

@ -293,6 +293,29 @@ class MonitorProcessing(object):
# logger.debug(u"PlexPy Monitor :: Writing session_history transaction...") # logger.debug(u"PlexPy Monitor :: Writing session_history transaction...")
self.db.action(query=query, args=args) self.db.action(query=query, args=args)
# Check if we should group the session
query = 'SELECT id, rating_key, user_id, reference_id FROM session_history ORDER BY id DESC LIMIT 2 '
result = self.db.select(query)
if len(result) == 2:
new_session = {'id': result[0][0],
'rating_key': result[0][1],
'user_id': result[0][2],
'reference_id': result[0][3]}
prev_session = {'id': result[1][0],
'rating_key': result[1][1],
'user_id': result[1][2],
'reference_id': result[1][3]}
query = 'UPDATE session_history SET reference_id = ? WHERE id = ? '
# If rating_key and user are the same in the previous session, then set the reference_id to the previous row
if prev_session['rating_key'] == new_session['rating_key'] and prev_session['user_id'] == new_session['user_id']:
args = [prev_session['reference_id'], new_session['id']]
else:
args = [new_session['id'], new_session['id']]
self.db.action(query=query, args=args)
# logger.debug(u"PlexPy Monitor :: Successfully written history item, last id for session_history is %s" # logger.debug(u"PlexPy Monitor :: Successfully written history item, last id for session_history is %s"
# % last_id) # % last_id)