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

Fix paused counter

Browse source 
Fix bad key name
This commit is contained in:
Tim 2015-09-22 20:22:13 +02:00
parent 3afa52b607
commit 6ee5eb13f0
2 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
plexpy/activity_pinger.py
View file

@ -126,8 +126,8 @@ def check_active_sessions(ws_request=False):
# Check if the user has reached the offset in the media we defined as the "watched" percent # Check if the user has reached the offset in the media we defined as the "watched" percent
# Don't trigger if state is buffer as some clients push the progress to the end when # Don't trigger if state is buffer as some clients push the progress to the end when
# buffering on start. # buffering on start.
if session['progress'] and session['duration'] and session['state'] != 'buffering': if session['view_offset'] and session['duration'] and session['state'] != 'buffering':
if helpers.get_percent(session['progress'], if helpers.get_percent(session['view_offset'],
session['duration']) > plexpy.CONFIG.NOTIFY_WATCHED_PERCENT: session['duration']) > plexpy.CONFIG.NOTIFY_WATCHED_PERCENT:
# Push any notifications - # Push any notifications -
# Push it on it's own thread so we don't hold up our db actions # Push it on it's own thread so we don't hold up our db actions

9
plexpy/datafactory.py
View file

@ -830,14 +830,17 @@ class DataFactory(object):
'FROM sessions ' 'FROM sessions '
'WHERE session_key = ?', args=[session_key]) 'WHERE session_key = ?', args=[session_key])
paused_counter = 0 paused_counter = None
for session in result: for session in result:
if session['last_paused']: if session['last_paused']:
paused_offset = int(time.time()) - int(session['last_paused']) paused_offset = int(time.time()) - int(session['last_paused'])
paused_counter = int(session['paused_counter']) + int(paused_offset) paused_counter = int(session['paused_counter']) + int(paused_offset)
values = {'state': 'playing', values = {'state': 'playing',
'last_paused': timestamp, 'last_paused': timestamp
'paused_counter': paused_counter} }
if paused_counter:
values['paused_counter'] = paused_counter
keys = {'session_key': session_key} keys = {'session_key': session_key}
monitor_db.upsert('sessions', values, keys) monitor_db.upsert('sessions', values, keys)