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

Temporarily set stopped time when connection is lost

Browse source
This commit is contained in:
JonnyWong16 2016-10-08 22:56:43 -07:00
parent 62d05e5e08
commit 5dd04cb8ab
2 changed files with 13 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

16
plexpy/activity_pinger.py
View file

@ -173,11 +173,12 @@ def check_active_sessions(ws_request=False):
if stream['state'] != 'stopped': if stream['state'] != 'stopped':
logger.debug(u"PlexPy Monitor :: Session %s has stopped." % stream['session_key']) logger.debug(u"PlexPy Monitor :: Session %s has stopped." % stream['session_key'])
# Set the stream stop time if not stream['stopped']:
stream['stopped'] = int(time.time()) # Set the stream stop time
monitor_db.action('UPDATE sessions SET stopped = ?, state = ? ' stream['stopped'] = int(time.time())
'WHERE session_key = ? AND rating_key = ?', monitor_db.action('UPDATE sessions SET stopped = ?, state = ? '
[stream['stopped'], 'stopped', stream['session_key'], stream['rating_key']]) 'WHERE session_key = ? AND rating_key = ?',
[stream['stopped'], 'stopped', stream['session_key'], stream['rating_key']])
# 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
if stream['view_offset'] and stream['duration']: if stream['view_offset'] and stream['duration']:
@ -236,6 +237,11 @@ def check_active_sessions(ws_request=False):
else: else:
logger.debug(u"PlexPy Monitor :: Unable to read session list.") logger.debug(u"PlexPy Monitor :: Unable to read session list.")
if int_ping_count == 0:
# Temporarily set the stopped time for all sessions
stopped_time = int(time.time())
monitor_db.action('UPDATE sessions SET stopped = ?', [stopped_time])
int_ping_count += 1 int_ping_count += 1
logger.warn(u"PlexPy Monitor :: Unable to get an internal response from the server, ping attempt %s." \ logger.warn(u"PlexPy Monitor :: Unable to get an internal response from the server, ping attempt %s." \
% str(int_ping_count)) % str(int_ping_count))

3
plexpy/activity_processor.py
View file

@ -82,7 +82,8 @@ class ActivityProcessor(object):
'transcode_audio_codec': session['transcode_audio_codec'], 'transcode_audio_codec': session['transcode_audio_codec'],
'transcode_audio_channels': session['transcode_audio_channels'], 'transcode_audio_channels': session['transcode_audio_channels'],
'transcode_width': session['transcode_width'], 'transcode_width': session['transcode_width'],
'transcode_height': session['transcode_height'] 'transcode_height': session['transcode_height'],
'stopped': None
} }
# Add ip_address back into values # Add ip_address back into values