Marius/JBOPS
1
0
Fork 0
mirror of https://github.com/blacktwin/JBOPS.git synced 2025-12-14 04:25:36 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

if ratingKey section cleanup.

Browse Source
This commit is contained in:
Blacktwin 2019-03-17 09:56:52 -04:00
parent ef87f88e05
commit 5ae2e9f6d7
1 changed files with 21 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
utility/sync_watch_status.py
View File

@ -230,7 +230,7 @@ class Plex:
""" """
data = {} data = {}
servers = self.admin_servers() servers = self.admin_servers()
print('Connecting to admin server(s) for section info...') print("Connecting to admin server(s) for access info...")
for name, server in servers.items(): for name, server in servers.items():
connect = server.connect() connect = server.connect()
sections = {section.title: section for section in connect.library.sections()} sections = {section.title: section for section in connect.library.sections()}
@ -294,7 +294,7 @@ def connect_to_server(server_obj, user_account):
print('Connecting {} to {}...'.format(user, server_name)) print('Connecting {} to {}...'.format(user, server_name))
server_connection = server_obj.connect() server_connection = server_obj.connect()
baseurl = server_connection._baseurl.split('.') baseurl = server_connection._baseurl.split('.')
url = ''.join([baseurl[0].replace('-', '.'), url = "".join([baseurl[0].replace('-', '.'),
baseurl[-1].replace('direct', '')]) baseurl[-1].replace('direct', '')])
if user_account.title == Plex(PLEX_TOKEN).account.title: if user_account.title == Plex(PLEX_TOKEN).account.title:
token = PLEX_TOKEN token = PLEX_TOKEN
@ -487,9 +487,22 @@ if __name__ == '__main__':
username, server = user username, server = user
sync_watch_status(watched_lst, _library.title, server, username) sync_watch_status(watched_lst, _library.title, server, username)
elif opts.ratingKey and userFrom == "Tautulli" and serverFrom == "Tautulli": elif opts.ratingKey and serverFrom == "Tautulli":
print('Request from Tautulli notification agent to update watch status')
plexTo = [] plexTo = []
watched_item = []
if userFrom != "Tautulli":
print("Request manually triggered to update watch status")
tt_watched = tautulli_server.get_watched_history(user=userFrom, rating_key=opts.ratingKey)
if tt_watched:
watched_item = Metadata(tautulli_server.get_metadata(opts.ratingKey))
else:
print("Rating Key {} was not reported as watched in Tautulli for user {}".format(opts.ratingKey, userFrom))
exit()
elif userFrom == "Tautulli":
print("Request from Tautulli notification agent to update watch status")
watched_item = Metadata(tautulli_server.get_metadata(opts.ratingKey))
for user, server_name in opts.userTo: for user, server_name in opts.userTo:
# Check access and connect # Check access and connect
@ -497,27 +510,7 @@ if __name__ == '__main__':
for user in plexTo: for user in plexTo:
username, server = user username, server = user
item = Metadata(tautulli_server.get_metadata(opts.ratingKey)) sync_watch_status([watched_item], watched_item.libraryName, server, username)
sync_watch_status([item], item.libraryName, server, username)
elif opts.ratingKey and userFrom != "Tautulli" and serverFrom == "Tautulli":
print('Request manually triggered to update watch status')
plexTo = []
watched_lst = []
tt_watched = tautulli_server.get_watched_history(user=userFrom, rating_key=opts.ratingKey)
if tt_watched:
watched_lst = Metadata(tautulli_server.get_metadata(opts.ratingKey))
else:
print("Rating Key {} was not reported as watched in Tautulli for user {}".format(opts.ratingKey, userFrom))
exit()
for user, server_name in opts.userTo:
# Check access and connect
plexTo.append([user, check_users_access(plex_access, user, server_name, libraries)])
for user in plexTo:
username, server = user
sync_watch_status([watched_lst], watched_lst.libraryName, server, username)
else: else:
print("You aren't using this script correctly... bye!") print("You aren't using this script correctly... bye!")