Mirrored_Repos/JBOPS
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

comment updates

Browse Source
This commit is contained in:
Blacktwin 2019-03-18 21:06:36 -04:00
parent 0321b883eb
commit 599d9970ea
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
utility/sync_watch_status.py
View File

@ -198,7 +198,7 @@ class Plex:
self.server = PlexServer(baseurl=url, token=token, session=session) self.server = PlexServer(baseurl=url, token=token, session=session)
def admin_servers(self): def admin_servers(self):
""" """All owned servers
Returns Returns
------- -------
data: dict data: dict
@ -211,7 +211,7 @@ class Plex:
return resources return resources
def all_users(self): def all_users(self):
""" """All users
Returns Returns
------- -------
data: dict data: dict
@ -223,7 +223,7 @@ class Plex:
return users return users
def all_sections(self): def all_sections(self):
""" """All sections from all owned servers
Returns Returns
------- -------
data: dict data: dict
@ -239,7 +239,7 @@ class Plex:
return data return data
def users_access(self): def users_access(self):
""" """Users access across all owned servers
Returns Returns
------- -------
data: dict data: dict
@ -278,7 +278,7 @@ class Plex:
def connect_to_server(server_obj, user_account): def connect_to_server(server_obj, user_account):
""" """Find server url and connect using user token
Parameters Parameters
---------- ----------
server_obj: class server_obj: class
@ -359,12 +359,10 @@ def sync_watch_status(watched, section, accountTo, userTo):
User's server class of sync to user User's server class of sync to user
""" """
# Check sections for watched items
print('Marking watched...') print('Marking watched...')
sectionTo = accountTo.library.section(section) sectionTo = accountTo.library.section(section)
for item in watched: for item in watched:
try: try:
# .get retrieves a partial object
if item.type == 'episode': if item.type == 'episode':
show_name = item.grandparentTitle show_name = item.grandparentTitle
ep_name = item.title ep_name = item.title
@ -374,6 +372,7 @@ def sync_watch_status(watched, section, accountTo, userTo):
else: else:
title = item.title title = item.title
watch_check = sectionTo.get(title) watch_check = sectionTo.get(title)
# .get retrieves a partial object
# .fetchItem retrieves a full object # .fetchItem retrieves a full object
fetch_check = sectionTo.fetchItem(watch_check.key) fetch_check = sectionTo.fetchItem(watch_check.key)
# If item is already watched ignore # If item is already watched ignore
@ -423,14 +422,15 @@ if __name__ == '__main__':
verify_ssl=VERIFY_SSL)) verify_ssl=VERIFY_SSL))
if serverFrom == "Tautulli" and opts.libraries: if serverFrom == "Tautulli" and opts.libraries:
_sections = {}
# Pull all libraries from Tautulli # Pull all libraries from Tautulli
_sections = {}
tautulli_sections = tautulli_server.get_libraries() tautulli_sections = tautulli_server.get_libraries()
for section in tautulli_sections: for section in tautulli_sections:
section_obj = Library(section) section_obj = Library(section)
_sections[section_obj.title] = section_obj _sections[section_obj.title] = section_obj
all_sections[serverFrom] = _sections all_sections[serverFrom] = _sections
elif serverFrom != "Tautulli" and opts.libraries: elif serverFrom != "Tautulli" and opts.libraries:
# Pull all libraries from admin access dict
admin_access = plex_access.get(plex_admin.account.title).get("access") admin_access = plex_access.get(plex_admin.account.title).get("access")
for server in admin_access: for server in admin_access:
if server.get("server").get(serverFrom): if server.get("server").get(serverFrom):
@ -445,7 +445,8 @@ if __name__ == '__main__':
print("No matching library name '{}'".format(library)) print("No matching library name '{}'".format(library))
exit() exit()
if serverFrom != "Tautulli" and opts.libraries: # If server is Plex and synciing libraries, check access
if serverFrom != "Tautulli" and libraries:
print("Checking {}'s access to {}".format(userFrom, serverFrom)) print("Checking {}'s access to {}".format(userFrom, serverFrom))
watchedFrom = check_users_access(plex_access, userFrom, serverFrom, libraries) watchedFrom = check_users_access(plex_access, userFrom, serverFrom, libraries)