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

Merge 447caa9e9e into bea82c6640

Browse source
This commit is contained in:
drzoidberg33 2016-03-04 10:42:19 +00:00
commit 77af41a611
1 changed files with 13 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

19
plexpy/activity_handler.py
View file

@ -16,7 +16,7 @@
import time import time
import plexpy import plexpy
from plexpy import logger, pmsconnect, activity_processor, threading, notification_handler, helpers from plexpy import logger, pmsconnect, activity_processor, threading, notification_handler, helpers, notifiers
class ActivityHandler(object): class ActivityHandler(object):
@ -201,11 +201,18 @@ class ActivityHandler(object):
self.on_start() self.on_start()
# Monitor if the stream has reached the watch percentage for notifications # Monitor if the stream has reached the watch percentage for notifications
# The only purpose of this is for notifications # The only purpose of this is for notifications. Only process if any agents have on_watched toggled.
progress_percent = helpers.get_percent(self.timeline['viewOffset'], db_session['duration']) if any(d['on_watched'] == 1 for d in notifiers.available_notification_agents()):
if progress_percent >= plexpy.CONFIG.NOTIFY_WATCHED_PERCENT and this_state != 'buffering': progress_percent = helpers.get_percent(self.timeline['viewOffset'], db_session['duration'])
threading.Thread(target=notification_handler.notify, if progress_percent >= plexpy.CONFIG.NOTIFY_WATCHED_PERCENT and this_state != 'buffering':
kwargs=dict(stream_data=db_session, notify_action='watched')).start() # This is cheaper than having to send the request to notify each time.
notify_states = notification_handler.get_notify_state(db_session)
# This is a bit hacky but we're unaware of agents here so just check if any watched
# notifications are pending and allow it.
if any(d['on_watched'] is None for d in notify_states):
# Rather not put this on it's own thread so we know it completes before our next event.
notification_handler.notify(stream_data=db_session, notify_action='watched')
else: else:
# We don't have this session in our table yet, start a new one. # We don't have this session in our table yet, start a new one.