mirror of
https://github.com/SickGear/SickGear.git
synced 2024-12-13 14:43:37 +00:00
8d9406d5fc
Add episode watched state system that integrates with Kodi, Plex, and/or Emby, instructions at Shows/History/Layout/"Watched". Add installable SickGear Kodi repository containing addon "SickGear Watched State Updater". Change add Emby setting for watched state scheduler at Config/Notifications/Emby/"Update watched interval". Change add Plex setting for watched state scheduler at Config/Notifications/Plex/"Update watched interval". Add API cmd=sg.updatewatchedstate, instructions for use are linked to in layout "Watched" at /history. Change history page table filter input values are saved across page refreshes. Change history page table filter inputs, accept values like "dvd or web" to only display both. Change history page table filter inputs, press 'ESC' key inside a filter input to reset it. Add provider activity stats to Shows/History/Layout/ drop down. Change move provider failures table from Manage/Media Search to Shows/History/Layout/Provider fails. Change sort provider failures by most recent failure, and with paused providers at the top. Change remove table form non-testing version 20007, that was reassigned.
83 lines
2.9 KiB
Python
83 lines
2.9 KiB
Python
#
|
|
# This file is part of SickGear.
|
|
#
|
|
# SickGear is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# SickGear is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with SickGear. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
from __future__ import with_statement
|
|
|
|
from sickbeard import generic_queue, logger
|
|
from sickbeard.webserve import History
|
|
|
|
EMBYWATCHEDSTATE = 10
|
|
PLEXWATCHEDSTATE = 20
|
|
|
|
|
|
class WatchedStateQueue(generic_queue.GenericQueue):
|
|
def __init__(self):
|
|
super(WatchedStateQueue, self).__init__()
|
|
# self.queue_name = 'WATCHEDSTATEQUEUE'
|
|
self.queue_name = 'Q'
|
|
|
|
def is_in_queue(self, itemtype):
|
|
with self.lock:
|
|
for cur_item in self.queue + [self.currentItem]:
|
|
if isinstance(cur_item, itemtype):
|
|
return True
|
|
return False
|
|
|
|
# method for possible UI usage, can be removed if not used
|
|
def queue_length(self):
|
|
length = {'emby': 0, 'plex': 0}
|
|
with self.lock:
|
|
for cur_item in [self.currentItem] + self.queue:
|
|
if isinstance(cur_item, EmbyWatchedStateQueueItem):
|
|
length['emby'] += 1
|
|
elif isinstance(cur_item, PlexWatchedStateQueueItem):
|
|
length['plex'] += 1
|
|
|
|
return length
|
|
|
|
def add_item(self, item):
|
|
if isinstance(item, EmbyWatchedStateQueueItem) and not self.is_in_queue(EmbyWatchedStateQueueItem):
|
|
# emby watched state item
|
|
generic_queue.GenericQueue.add_item(self, item)
|
|
elif isinstance(item, PlexWatchedStateQueueItem) and not self.is_in_queue(PlexWatchedStateQueueItem):
|
|
# plex watched state item
|
|
generic_queue.GenericQueue.add_item(self, item)
|
|
else:
|
|
logger.log(u'Not adding item, it\'s already in the queue', logger.DEBUG)
|
|
|
|
|
|
class EmbyWatchedStateQueueItem(generic_queue.QueueItem):
|
|
def __init__(self):
|
|
super(EmbyWatchedStateQueueItem, self).__init__('Emby Watched', EMBYWATCHEDSTATE)
|
|
|
|
def run(self):
|
|
super(EmbyWatchedStateQueueItem, self).run()
|
|
try:
|
|
History.update_watched_state_emby()
|
|
finally:
|
|
self.finish()
|
|
|
|
|
|
class PlexWatchedStateQueueItem(generic_queue.QueueItem):
|
|
def __init__(self):
|
|
super(PlexWatchedStateQueueItem, self).__init__('Plex Watched', PLEXWATCHEDSTATE)
|
|
|
|
def run(self):
|
|
super(PlexWatchedStateQueueItem, self).run()
|
|
try:
|
|
History.update_watched_state_plex()
|
|
finally:
|
|
self.finish()
|