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

Fix history grouping incorrect for watched content

Browse source
This commit is contained in:
JonnyWong16 2023-07-07 11:51:54 -07:00
commit 085cfa4bef
No known key found for this signature in database
GPG key ID: B1F1F9807184697A
1 changed files with 11 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

21
plexpy/activity_processor.py
View file

@ -1,4 +1,4 @@
# This file is part of Tautulli. # This file is part of Tautulli.
# #
# Tautulli is free software: you can redistribute it and/or modify # Tautulli is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by # it under the terms of the GNU General Public License as published by
@ -327,7 +327,7 @@ class ActivityProcessor(object):
# 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 new_session = prev_session = None
watched = False prev_watched = None
if session['live']: if session['live']:
# Check if we should group the session, select the last guid from the user # Check if we should group the session, select the last guid from the user
@ -370,24 +370,25 @@ class ActivityProcessor(object):
'reference_id': result[1]['reference_id']} 'reference_id': result[1]['reference_id']}
marker_first, marker_final = helpers.get_first_final_marker(metadata['markers']) marker_first, marker_final = helpers.get_first_final_marker(metadata['markers'])
watched = helpers.check_watched( prev_watched = helpers.check_watched(
session['media_type'], session['view_offset'], session['duration'], session['media_type'], prev_session['view_offset'], session['duration'],
marker_first, marker_final marker_first, marker_final
) )
query = "UPDATE session_history SET reference_id = ? WHERE id = ? " query = "UPDATE session_history SET reference_id = ? WHERE id = ? "
# If previous session view offset less than watched percent, # If previous session view offset less than watched threshold,
# and new session view offset is greater, # and new session view offset is greater,
# then set the reference_id to the previous row, # then set the reference_id to the previous row,
# else set the reference_id to the new id # else set the reference_id to the new id
if prev_session is None and new_session is None: if (prev_watched is False and prev_session['view_offset'] <= new_session['view_offset'] or
args = [last_id, last_id] session['live'] and prev_session['guid'] == new_session['guid']):
elif watched and prev_session['view_offset'] <= new_session['view_offset'] or \ logger.debug("Tautulli ActivityProcessor :: Grouping history for sessionKey %s", session['session_key'])
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']] logger.debug("Tautulli ActivityProcessor :: Not grouping history for sessionKey %s", session['session_key'])
args = [last_id, last_id]
self.db.action(query=query, args=args) self.db.action(query=query, args=args)