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

More template filters for Libraries, Users, and Sync

Browse source
This commit is contained in:
JonnyWong16 2016-04-24 00:59:01 -07:00
parent 4f8a5211f8
commit 89694b5069
13 changed files with 74 additions and 43 deletions
Download patch file Download diff file Expand all files Collapse all files

6
plexpy/datafactory.py
View file

@ -148,7 +148,7 @@ class DataFactory(object):
dict = {'recordsFiltered': query['filteredCount'],
'recordsTotal': query['totalCount'],
'data': rows,
'data': helpers.filter_datatable_session(rows),
'draw': query['draw'],
'filter_duration': helpers.human_duration(filter_duration, sig='dhm'),
'total_duration': helpers.human_duration(total_duration, sig='dhm')
@ -470,7 +470,7 @@ class DataFactory(object):
home_stats.append({'stat_id': stat,
'stat_type': sort_type,
'rows': top_users})
'rows': helpers.filter_datatable_session(top_users)})
elif stat == 'top_platforms':
top_platform = []
@ -567,7 +567,7 @@ class DataFactory(object):
last_watched.append(row)
home_stats.append({'stat_id': stat,
'rows': last_watched})
'rows': helpers.filter_datatable_session(last_watched)})
elif stat == 'most_concurrent':

16
plexpy/helpers.py
View file

@ -562,4 +562,18 @@ def uploadToImgur(imgPath, imgTitle=''):
except (urllib2.HTTPError, urllib2.URLError) as e:
logger.warn(u"PlexPy Helpers :: Unable to upload image to Imgur: %s" % e)
return img_url
return img_url
def filter_datatable_session(list_of_dicts):
import cherrypy
from plexpy.webauth import SESSION_KEY
_cp_session = cherrypy.session.get(SESSION_KEY)
_session = {}
_session['username'], _session['user_id'], _session['user_group'], _session['expiry'] = \
_cp_session if _cp_session else (None, None, None, None)
if _session['user_id']:
return [d for d in list_of_dicts if str(d.get('user_id')) == str(_session['user_id'])]
else:
return list_of_dicts

2
plexpy/libraries.py
View file

@ -700,7 +700,7 @@ class Libraries(object):
}
user_stats.append(row)
return user_stats
return helpers.filter_datatable_session(user_stats)
def get_recently_watched(self, section_id=None, limit='10'):
monitor_db = database.MonitorDatabase()

2
plexpy/plextv.py
View file

@ -401,7 +401,7 @@ class PlexTV(object):
synced_items.append(sync_details)
return synced_items
return helpers.filter_datatable_session(synced_items)
def get_server_urls(self, include_https=True):

7
plexpy/users.py
View file

@ -190,7 +190,7 @@ class Users(object):
dict = {'recordsFiltered': query['filteredCount'],
'recordsTotal': query['totalCount'],
'data': rows,
'data': helpers.filter_datatable_session(rows),
'draw': query['draw']
}
@ -276,14 +276,15 @@ class Users(object):
'media_index': item['media_index'],
'parent_media_index': item['parent_media_index'],
'transcode_decision': item['transcode_decision'],
'friendly_name': item['friendly_name']
'friendly_name': item['friendly_name'],
'user_id': item['custom_user_id']
}
rows.append(row)
dict = {'recordsFiltered': query['filteredCount'],
'recordsTotal': query['totalCount'],
'data': rows,
'data': helpers.filter_datatable_session(rows),
'draw': query['draw']
}

2
plexpy/webauth.py
View file

@ -58,7 +58,7 @@ def check_auth(*args, **kwargs):
for condition in conditions:
# A condition is just a callable that returns true or false
if not condition():
raise cherrypy.HTTPRedirect("auth/login")
raise cherrypy.HTTPRedirect(plexpy.HTTP_ROOT)
else:
raise cherrypy.HTTPRedirect("auth/login")

51
plexpy/webserve.py
View file

@ -286,7 +286,7 @@ class WebInterface(object):
##### Libraries #####
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def libraries(self):
config = {
"update_section_ids": plexpy.CONFIG.UPDATE_SECTION_IDS
@ -295,7 +295,7 @@ class WebInterface(object):
return serve_template(templatename="libraries.html", title="Libraries", config=config)
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
@addtoapi()
def get_library_list(self, **kwargs):
@ -340,7 +340,7 @@ class WebInterface(object):
return True
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def library(self, section_id=None):
config = {
"get_file_sizes": plexpy.CONFIG.GET_FILE_SIZES,
@ -398,7 +398,7 @@ class WebInterface(object):
return status_message
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_library_watch_time_stats(self, section_id=None, **kwargs):
if section_id:
library_data = libraries.Libraries()
@ -413,7 +413,7 @@ class WebInterface(object):
return serve_template(templatename="user_watch_time_stats.html", data=None, title="Watch Stats")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_library_user_stats(self, section_id=None, **kwargs):
if section_id:
library_data = libraries.Libraries()
@ -428,7 +428,7 @@ class WebInterface(object):
return serve_template(templatename="library_user_stats.html", data=None, title="Player Stats")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_library_recently_watched(self, section_id=None, limit='10', **kwargs):
if section_id:
library_data = libraries.Libraries()
@ -443,7 +443,7 @@ class WebInterface(object):
return serve_template(templatename="user_recently_watched.html", data=None, title="Recently Watched")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_library_recently_added(self, section_id=None, limit='10', **kwargs):
if section_id:
pms_connect = pmsconnect.PmsConnect()
@ -458,7 +458,7 @@ class WebInterface(object):
return serve_template(templatename="library_recently_added.html", data=None, title="Recently Added")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
@addtoapi()
def get_library_media_info(self, section_id=None, section_type=None, rating_key=None, refresh='', **kwargs):
@ -613,12 +613,12 @@ class WebInterface(object):
##### Users #####
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def users(self):
return serve_template(templatename="users.html", title="Users")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
@addtoapi()
def get_user_list(self, **kwargs):
@ -638,7 +638,7 @@ class WebInterface(object):
return True
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def user(self, user_id=None):
user_data = users.Users()
if user_id:
@ -691,7 +691,7 @@ class WebInterface(object):
return status_message
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_user_watch_time_stats(self, user=None, user_id=None, **kwargs):
if user_id or user:
user_data = users.Users()
@ -706,7 +706,7 @@ class WebInterface(object):
return serve_template(templatename="user_watch_time_stats.html", data=None, title="Watch Stats")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_user_player_stats(self, user=None, user_id=None, **kwargs):
if user_id or user:
user_data = users.Users()
@ -721,7 +721,7 @@ class WebInterface(object):
return serve_template(templatename="user_player_stats.html", data=None, title="Player Stats")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_user_recently_watched(self, user=None, user_id=None, limit='10', **kwargs):
if user_id or user:
user_data = users.Users()
@ -736,7 +736,7 @@ class WebInterface(object):
return serve_template(templatename="user_recently_watched.html", data=None, title="Recently Watched")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_user_ips(self, user_id=None, **kwargs):
user_data = users.Users()
@ -1094,12 +1094,12 @@ class WebInterface(object):
##### Sync #####
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def sync(self):
return serve_template(templatename="sync.html", title="Synced Items")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_sync(self, machine_id=None, user_id=None, **kwargs):
if not machine_id:
@ -1226,7 +1226,7 @@ class WebInterface(object):
raise cherrypy.HTTPRedirect("logs")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def log_js_errors(self, page, message, file, line):
""" Logs javascript errors from the web interface. """
logger.error(u"WebUI :: /%s : %s. (%s:%s)" % (page.rpartition('/')[-1],
@ -1812,7 +1812,7 @@ class WebInterface(object):
##### Info #####
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def info(self, rating_key=None, source=None, query=None, **kwargs):
metadata = None
@ -1840,7 +1840,7 @@ class WebInterface(object):
return self.update_metadata(rating_key, query)
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_item_children(self, rating_key='', **kwargs):
pms_connect = pmsconnect.PmsConnect()
@ -1902,7 +1902,7 @@ class WebInterface(object):
##### Search #####
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def search(self, query=''):
return serve_template(templatename="search.html", title="Search", query=query)
@ -1921,7 +1921,7 @@ class WebInterface(object):
logger.warn(u"Unable to retrieve data for search_results.")
@cherrypy.expose
@requireAuth(member_of("admin"))
@requireAuth()
def get_search_results_children(self, query, media_type=None, season_index=None, **kwargs):
pms_connect = pmsconnect.PmsConnect()
@ -2438,9 +2438,4 @@ class WebInterface(object):
def check_pms_updater(self):
pms_connect = pmsconnect.PmsConnect()
result = pms_connect.get_update_staus()
return json.dumps(result)
@cherrypy.expose
def test_guest_login(self, username=None, password=None):
result = users.user_login(username=username, password=password)
return result
return json.dumps(result)