github/plexpy
1
0
Fork 0
mirror of https://github.com/Tautulli/Tautulli.git synced 2025-07-10 23:42:37 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update history grouping for Live TV only if the user's last session has a matching guid

Browse source
This commit is contained in:
JonnyWong16 2020-02-20 18:59:12 -08:00
parent 751b97a39c
commit 7de82d87f7
1 changed files with 48 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

76
plexpy/activity_processor.py
View file

@ -293,38 +293,57 @@ class ActivityProcessor(object):
# % session['session_key']) # % session['session_key'])
self.db.upsert(table_name='session_history', key_dict=keys, value_dict=values) self.db.upsert(table_name='session_history', key_dict=keys, value_dict=values)
# Check if we should group the session, select the last two rows from the user
query = 'SELECT id, rating_key, view_offset, user_id, reference_id FROM session_history ' \
'WHERE user_id = ? AND rating_key = ? ORDER BY id DESC LIMIT 2 '
args = [session['user_id'], session['rating_key']]
result = self.db.select(query=query, args=args)
new_session = prev_session = None
prev_progress_percent = media_watched_percent = 0
# Get the last insert row id # Get the last insert row id
last_id = self.db.last_insert_id() last_id = self.db.last_insert_id()
new_session = prev_session = None
prev_progress_percent = media_watched_percent = 0
if len(result) > 1: if session['live']:
new_session = {'id': result[0]['id'], # Check if we should group the session, select the last guid from the user
'rating_key': result[0]['rating_key'], query = 'SELECT session_history.id, session_history_metadata.guid, session_history.reference_id ' \
'view_offset': result[0]['view_offset'], 'FROM session_history ' \
'user_id': result[0]['user_id'], 'JOIN session_history_metadata ON session_history.id == session_history_metadata.id ' \
'reference_id': result[0]['reference_id']} 'WHERE session_history.user_id = ? ORDER BY id DESC LIMIT 1 '
prev_session = {'id': result[1]['id'], args = [session['user_id']]
'rating_key': result[1]['rating_key'],
'view_offset': result[1]['view_offset'],
'user_id': result[1]['user_id'],
'reference_id': result[1]['reference_id']}
watched_percent = {'movie': plexpy.CONFIG.MOVIE_WATCHED_PERCENT, result = self.db.select(query=query, args=args)
'episode': plexpy.CONFIG.TV_WATCHED_PERCENT,
'track': plexpy.CONFIG.MUSIC_WATCHED_PERCENT if len(result) > 0:
} new_session = {'id': last_id,
prev_progress_percent = helpers.get_percent(prev_session['view_offset'], session['duration']) 'guid': metadata['guid'],
media_watched_percent = watched_percent.get(session['media_type'], 0) 'reference_id': last_id}
prev_session = {'id': result[0]['id'],
'guid': result[0]['guid'],
'reference_id': result[0]['reference_id']}
else:
# Check if we should group the session, select the last two rows from the user
query = 'SELECT id, rating_key, view_offset, reference_id FROM session_history ' \
'WHERE user_id = ? AND rating_key = ? ORDER BY id DESC LIMIT 2 '
args = [session['user_id'], session['rating_key']]
result = self.db.select(query=query, args=args)
if len(result) > 1:
new_session = {'id': result[0]['id'],
'rating_key': result[0]['rating_key'],
'view_offset': result[0]['view_offset'],
'reference_id': result[0]['reference_id']}
prev_session = {'id': result[1]['id'],
'rating_key': result[1]['rating_key'],
'view_offset': result[1]['view_offset'],
'reference_id': result[1]['reference_id']}
watched_percent = {'movie': plexpy.CONFIG.MOVIE_WATCHED_PERCENT,
'episode': plexpy.CONFIG.TV_WATCHED_PERCENT,
'track': plexpy.CONFIG.MUSIC_WATCHED_PERCENT
}
prev_progress_percent = helpers.get_percent(prev_session['view_offset'], session['duration'])
media_watched_percent = watched_percent.get(session['media_type'], 0)
query = 'UPDATE session_history SET reference_id = ? WHERE id = ? ' query = 'UPDATE session_history SET reference_id = ? WHERE id = ? '
@ -335,7 +354,8 @@ class ActivityProcessor(object):
if prev_session is None and new_session is None: if prev_session is None and new_session is None:
args = [last_id, last_id] args = [last_id, last_id]
elif prev_progress_percent < media_watched_percent and \ elif prev_progress_percent < media_watched_percent and \
prev_session['view_offset'] <= new_session['view_offset']: prev_session['view_offset'] <= new_session['view_offset'] or \
session['live'] and prev_session['guid'] == new_session['guid']:
args = [prev_session['reference_id'], new_session['id']] args = [prev_session['reference_id'], new_session['id']]
else: else:
args = [new_session['id'], new_session['id']] args = [new_session['id'], new_session['id']]