From d62f7b2a5fb6d56d66c925bfa86bd3b206cc665e Mon Sep 17 00:00:00 2001
From: Otger <otgerp@users.noreply.github.com>
Date: Sat, 9 Apr 2016 23:54:31 +0200
Subject: [PATCH 01/11] Added ability to view per-user graphs

---
 data/interfaces/default/css/plexpy.css |   2 +
 data/interfaces/default/graphs.html    |  61 ++++++++++---
 plexpy/graphs.py                       | 120 ++++++++++++++-----------
 plexpy/users.py                        |  17 ++++
 plexpy/webserve.py                     |  48 ++++++----
 5 files changed, 167 insertions(+), 81 deletions(-)

diff --git a/data/interfaces/default/css/plexpy.css b/data/interfaces/default/css/plexpy.css
index 0be38e59..845dc554 100644
--- a/data/interfaces/default/css/plexpy.css
+++ b/data/interfaces/default/css/plexpy.css
@@ -113,6 +113,8 @@ img {
 }
 .btn {
     outline:0px !important;
+}
+.btn:not(select) {
     -webkit-appearance:none;
 }
 .btn-dark {
diff --git a/data/interfaces/default/graphs.html b/data/interfaces/default/graphs.html
index 1592f0f3..310546ad 100644
--- a/data/interfaces/default/graphs.html
+++ b/data/interfaces/default/graphs.html
@@ -12,6 +12,14 @@
             <span><i class="fa fa-bar-chart"></i> Graphs</span>
         </div>
         <div class="button-bar hidden-xs">
+            <div class="btn-group" id="user-selection">
+                <label>
+                    <select name="graph-user" id="graph-user" class="btn" style="color: inherit;">
+                        <option value="">All Users</option>
+                        <option disabled>&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;&#9472;</option>
+                    </select>
+                </label>
+            </div>
             <div class="btn-group" data-toggle="buttons" id="yaxis-selection">
                 % if config['graph_type'] == 'duration':
                 <label class="btn btn-dark">
@@ -281,6 +289,10 @@
                 complete: function(xhr, status) {
                     $('#history-modal').modal('show');
                     $("#history-modal").html(xhr.responseText);
+                    var opt = $('#graph-user :selected');
+                    if (opt.prev().length) {
+                        $('#history_table_modal_filter input[type=search]').val(opt.text()).trigger("input");
+                    }
                 }
             });
         }
@@ -307,9 +319,28 @@
         // Initial values for graph from config
         var yaxis = "${config['graph_type']}";
         var current_range = ${config['graph_days']};
+        var current_user = undefined;
         var current_tab = "${'#' + config['graph_tab']}";
         
         $('.days').html(current_range);
+        
+        // Load user ids and names (for the selector)
+        $.ajax({
+            url: 'get_user_names',
+            type: 'get',
+            dataType: "json",
+            success: function (data) {
+                var select = $('#graph-user');
+                data.sort(function(a, b) {
+                    return a.friendly_name.localeCompare(b.friendly_name);
+                });
+                data.forEach(function(item) {
+                    select.append('<option value="' + item.user_id + '">' +
+                        item.friendly_name + '</option>');
+                });
+            }
+        });
+
 
         var music_visible = (${config['music_logging_enable']} == 1 ? true : false);
 
@@ -321,7 +352,7 @@
             $.ajax({
                 url: "get_plays_by_date",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     var dateArray = [];
@@ -348,7 +379,7 @@
             $.ajax({
                 url: "get_plays_by_dayofweek",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_dayofweek_options.xAxis.categories = data.categories;
@@ -361,7 +392,7 @@
             $.ajax({
                 url: "get_plays_by_hourofday",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_hourofday_options.xAxis.categories = data.categories;
@@ -374,7 +405,7 @@
             $.ajax({
                 url: "get_plays_by_top_10_platforms",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_platform_options.xAxis.categories = data.categories;
@@ -406,7 +437,7 @@
             $.ajax({
                 url: "get_plays_by_stream_type",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     var dateArray = [];
@@ -432,7 +463,7 @@
             $.ajax({
                 url: "get_plays_by_source_resolution",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_source_resolution_options.xAxis.categories = data.categories;
@@ -444,7 +475,7 @@
             $.ajax({
                 url: "get_plays_by_stream_resolution",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_stream_resolution_options.xAxis.categories = data.categories;
@@ -456,7 +487,7 @@
             $.ajax({
                 url: "get_stream_type_by_top_10_platforms",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_platform_by_stream_type_options.xAxis.categories = data.categories;
@@ -468,7 +499,7 @@
             $.ajax({
                 url: "get_stream_type_by_top_10_users",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_user_by_stream_type_options.xAxis.categories = data.categories;
@@ -486,7 +517,7 @@
             $.ajax({
                 url: "get_plays_per_month",
                 type: 'get',
-                data: { y_axis: yaxis },
+                data: { y_axis: yaxis, user_id: current_user },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_month_options.yAxis.min = 0;
@@ -556,6 +587,14 @@
             });
         });
 
+        // User changed
+        $('#graph-user').on('change', function() {
+            current_user = $(this).val() || undefined;
+            if (current_tab == '#tabs-1') { loadGraphsTab1(current_range, yaxis); }
+            if (current_tab == '#tabs-2') { loadGraphsTab2(current_range, yaxis); }
+            if (current_tab == '#tabs-3') { loadGraphsTab3(yaxis); }
+        });
+        
         // Y-axis changed
         $('#yaxis-selection').on('change', function() {
             yaxis = $('input[name=yaxis-options]:checked', '#yaxis-selection').val();
@@ -598,7 +637,7 @@
 
                 $('.yaxis-text').html('Play count');
             } else {
-                yaxis_format = function() { return moment.duration(this.value, 'seconds').format("m [mins]"); };
+                yaxis_format = function() { return moment.duration(this.value, 'seconds').format("H [h] m [m]"); };
                 tooltip_format = function() {
                                     if (moment(this.x, 'X').isValid() && (this.x > 946684800)) {
                                         var s = '<b>'+ moment(this.x).format("ddd MMM D") +'</b>';
diff --git a/plexpy/graphs.py b/plexpy/graphs.py
index d9f9cd55..410fe67b 100644
--- a/plexpy/graphs.py
+++ b/plexpy/graphs.py
@@ -24,22 +24,24 @@ class Graphs(object):
     def __init__(self):
         pass
 
-    def get_total_plays_per_day(self, time_range='30', y_axis='plays'):
+    def get_total_plays_per_day(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
-
-        try:
+        
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
+        try:    
             if y_axis == 'plays':
                 query = 'SELECT date(started, "unixepoch", "localtime") AS date_played, ' \
                         'SUM(CASE WHEN media_type = "episode" THEN 1 ELSE 0 END) AS tv_count, ' \
                         'SUM(CASE WHEN media_type = "movie" THEN 1 ELSE 0 END) AS movie_count, ' \
                         'SUM(CASE WHEN media_type = "track" THEN 1 ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") ' \
+                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") %s' \
                         'GROUP BY date_played ' \
-                        'ORDER BY started ASC' % time_range
+                        'ORDER BY started ASC' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -51,9 +53,9 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "track" AND stopped > 0 THEN (stopped - started) ' \
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") ' \
+                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") %s' \
                         'GROUP BY date_played ' \
-                        'ORDER BY started ASC' % time_range
+                        'ORDER BY started ASC' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -102,12 +104,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_per_dayofweek(self, time_range='30', y_axis='plays'):
+    def get_total_plays_per_dayofweek(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT strftime("%%w", datetime(started, "unixepoch", "localtime")) AS daynumber, ' \
@@ -123,9 +127,9 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "movie" THEN 1 ELSE 0 END) AS movie_count, ' \
                         'SUM(CASE WHEN media_type = "track" THEN 1 ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") ' \
+                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") %s' \
                         'GROUP BY dayofweek ' \
-                        'ORDER BY daynumber' % time_range
+                        'ORDER BY daynumber' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -145,9 +149,9 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "track" AND stopped > 0 THEN (stopped - started) ' \
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") ' \
+                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") %s' \
                         'GROUP BY dayofweek ' \
-                        'ORDER BY daynumber' % time_range
+                        'ORDER BY daynumber' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -193,12 +197,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_per_hourofday(self, time_range='30', y_axis='plays'):
+    def get_total_plays_per_hourofday(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT strftime("%%H", datetime(started, "unixepoch", "localtime")) AS hourofday, ' \
@@ -206,9 +212,9 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "movie" THEN 1 ELSE 0 END) AS movie_count, ' \
                         'SUM(CASE WHEN media_type = "track" THEN 1 ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") ' \
+                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") %s' \
                         'GROUP BY hourofday ' \
-                        'ORDER BY hourofday' % time_range
+                        'ORDER BY hourofday' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -220,9 +226,9 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "track" AND stopped > 0 THEN (stopped - started) ' \
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") ' \
+                        'WHERE datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime") %s' \
                         'GROUP BY hourofday ' \
-                        'ORDER BY hourofday' % time_range
+                        'ORDER BY hourofday' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -270,25 +276,27 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_per_month(self, y_axis='plays'):
+    def get_total_plays_per_month(self, y_axis='plays', user_id=None):
         import time as time
 
         monitor_db = database.MonitorDatabase()
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
-                query = 'SELECT strftime("%Y-%m", datetime(started, "unixepoch", "localtime")) AS datestring, ' \
+                query = 'SELECT strftime("%%Y-%%m", datetime(started, "unixepoch", "localtime")) AS datestring, ' \
                         'SUM(CASE WHEN media_type = "episode" THEN 1 ELSE 0 END) AS tv_count, ' \
                         'SUM(CASE WHEN media_type = "movie" THEN 1 ELSE 0 END) AS movie_count, ' \
                         'SUM(CASE WHEN media_type = "track" THEN 1 ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(started, "unixepoch", "localtime") >= datetime("now", "-12 months", "localtime") ' \
-                        'GROUP BY strftime("%Y-%m", datetime(started, "unixepoch", "localtime")) ' \
-                        'ORDER BY datestring DESC LIMIT 12'
+                        'WHERE datetime(started, "unixepoch", "localtime") >= datetime("now", "-12 months", "localtime") %s' \
+                        'GROUP BY strftime("%%Y-%%m", datetime(started, "unixepoch", "localtime")) ' \
+                        'ORDER BY datestring DESC LIMIT 12' % (user_cond)
 
                 result = monitor_db.select(query)
             else:
-                query = 'SELECT strftime("%Y-%m", datetime(started, "unixepoch", "localtime")) AS datestring, ' \
+                query = 'SELECT strftime("%%Y-%%m", datetime(started, "unixepoch", "localtime")) AS datestring, ' \
                         'SUM(CASE WHEN media_type = "episode" AND stopped > 0 THEN (stopped - started) ' \
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS tv_count, ' \
                         'SUM(CASE WHEN media_type = "movie" AND stopped > 0 THEN (stopped - started) ' \
@@ -296,9 +304,9 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "track" AND stopped > 0 THEN (stopped - started) ' \
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS music_count ' \
                         'FROM session_history ' \
-                        'WHERE datetime(started, "unixepoch", "localtime") >= datetime("now", "-12 months", "localtime") ' \
-                        'GROUP BY strftime("%Y-%m", datetime(started, "unixepoch", "localtime")) ' \
-                        'ORDER BY datestring DESC LIMIT 12'
+                        'WHERE datetime(started, "unixepoch", "localtime") >= datetime("now", "-12 months", "localtime") %s' \
+                        'GROUP BY strftime("%%Y-%%m", datetime(started, "unixepoch", "localtime")) ' \
+                        'ORDER BY datestring DESC LIMIT 12' % (user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -351,12 +359,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_by_top_10_platforms(self, time_range='30', y_axis='plays'):
+    def get_total_plays_by_top_10_platforms(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT platform, ' \
@@ -365,10 +375,10 @@ class Graphs(object):
                         'SUM(CASE WHEN media_type = "track" THEN 1 ELSE 0 END) AS music_count, ' \
                         'COUNT(id) AS total_count ' \
                         'FROM session_history ' \
-                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) ' \
+                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) %s' \
                         'GROUP BY platform ' \
                         'ORDER BY total_count DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -382,10 +392,10 @@ class Graphs(object):
                         'SUM(CASE WHEN stopped > 0 THEN (stopped - started) ' \
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS total_duration ' \
                         'FROM session_history ' \
-                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) ' \
+                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) %s' \
                         'GROUP BY platform ' \
                         'ORDER BY total_duration DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -481,12 +491,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_per_stream_type(self, time_range='30', y_axis='plays'):
+    def get_total_plays_per_stream_type(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT date(session_history.started, "unixepoch", "localtime") AS date_played, ' \
@@ -501,9 +513,9 @@ class Graphs(object):
                         'WHERE (datetime(session_history.stopped, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime")) AND ' \
                         '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR ' \
-                        'session_history.media_type = "track") ' \
+                        'session_history.media_type = "track") %s' \
                         'GROUP BY date_played ' \
-                        'ORDER BY started ASC' % time_range
+                        'ORDER BY started ASC' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -522,9 +534,9 @@ class Graphs(object):
                         'WHERE datetime(session_history.stopped, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime") AND ' \
                         '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR ' \
-                        'session_history.media_type = "track") ' \
+                        'session_history.media_type = "track") %s' \
                         'GROUP BY date_played ' \
-                        'ORDER BY started ASC' % time_range
+                        'ORDER BY started ASC' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -573,12 +585,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_by_source_resolution(self, time_range='30', y_axis='plays'):
+    def get_total_plays_by_source_resolution(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT session_history_media_info.video_resolution AS resolution, ' \
@@ -593,10 +607,10 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE (datetime(session_history.stopped, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime")) AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") %s' \
                         'GROUP BY resolution ' \
                         'ORDER BY total_count DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -616,10 +630,10 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE (datetime(session_history.stopped, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime")) AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") %s' \
                         'GROUP BY resolution ' \
                         'ORDER BY total_duration DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -648,12 +662,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_by_stream_resolution(self, time_range='30', y_axis='plays'):
+    def get_total_plays_by_stream_resolution(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT ' \
@@ -678,10 +694,10 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE (datetime(session_history.stopped, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime")) AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") %s' \
                         'GROUP BY resolution ' \
                         'ORDER BY total_count DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -711,10 +727,10 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE (datetime(session_history.stopped, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime")) AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie") %s' \
                         'GROUP BY resolution ' \
                         'ORDER BY total_duration DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -743,12 +759,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_stream_type_by_top_10_platforms(self, time_range='30', y_axis='plays'):
+    def get_stream_type_by_top_10_platforms(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT session_history.platform AS platform, ' \
@@ -763,9 +781,9 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE datetime(session_history.started, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime") AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") %s' \
                         'GROUP BY platform ' \
-                        'ORDER BY total_count DESC LIMIT 10' % time_range
+                        'ORDER BY total_count DESC LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -786,9 +804,9 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE datetime(session_history.started, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime") AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") %s' \
                         'GROUP BY platform ' \
-                        'ORDER BY total_duration DESC LIMIT 10' % time_range
+                        'ORDER BY total_duration DESC LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
diff --git a/plexpy/users.py b/plexpy/users.py
index 9207ad0d..2e28e6f8 100644
--- a/plexpy/users.py
+++ b/plexpy/users.py
@@ -21,6 +21,23 @@ class Users(object):
     def __init__(self):
         pass
 
+    def get_names(self, kwargs=None):
+        monitor_db = database.MonitorDatabase()
+        
+        try:
+            query = 'SELECT user_id, ' \
+                    '(CASE WHEN users.friendly_name IS NULL OR TRIM(users.friendly_name) = "" \
+                    THEN users.username ELSE users.friendly_name END) AS friendly_name ' \
+                    'FROM users ' \
+                    'WHERE deleted_user = 0'
+
+            result = monitor_db.select(query)
+        except Exception as e:
+            logger.warn(u"PlexPy Graphs :: Unable to execute database query for get_user_names: %s." % e)
+            return None
+        
+        return result
+    
     def get_datatables_list(self, kwargs=None):
         data_tables = datatables.DataTables()
 
diff --git a/plexpy/webserve.py b/plexpy/webserve.py
index 697f85ad..d7c84826 100644
--- a/plexpy/webserve.py
+++ b/plexpy/webserve.py
@@ -861,13 +861,23 @@ class WebInterface(object):
             plexpy.CONFIG.write()
 
         return "Updated graphs config values."
-
+    
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_date(self, time_range='30', y_axis='plays', **kwargs):
+    def get_user_names(self, **kwargs):
+
+        user_data = users.Users()
+        user_names = user_data.get_names(kwargs=kwargs)
+
+        cherrypy.response.headers['Content-type'] = 'application/json'
+        return json.dumps(user_names)
+    
+    @cherrypy.expose
+    @addtoapi()
+    def get_plays_by_date(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_per_day(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_per_day(time_range=time_range, user_id=user_id, y_axis=y_axis)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -877,10 +887,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_dayofweek(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_dayofweek(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_per_dayofweek(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_per_dayofweek(time_range=time_range, user_id=user_id, y_axis=y_axis)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -890,10 +900,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_hourofday(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_hourofday(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_per_hourofday(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_per_hourofday(time_range=time_range, user_id=user_id, y_axis=y_axis)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -903,10 +913,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_per_month(self, y_axis='plays', **kwargs):
+    def get_plays_per_month(self, y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_per_month(y_axis=y_axis)
+        result = graph.get_total_plays_per_month(y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -916,10 +926,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_top_10_platforms(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_top_10_platforms(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_by_top_10_platforms(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_by_top_10_platforms(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -942,10 +952,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_stream_type(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_stream_type(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_per_stream_type(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_per_stream_type(time_range=time_range, user_id=user_id, y_axis=y_axis)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -955,10 +965,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_source_resolution(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_source_resolution(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_by_source_resolution(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_by_source_resolution(time_range=time_range, user_id=user_id, y_axis=y_axis)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -968,10 +978,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_stream_resolution(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_stream_resolution(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_by_stream_resolution(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_by_stream_resolution(time_range=time_range, user_id=user_id, y_axis=y_axis)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -994,10 +1004,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_stream_type_by_top_10_platforms(self, time_range='30', y_axis='plays', **kwargs):
+    def get_stream_type_by_top_10_platforms(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_stream_type_by_top_10_platforms(time_range=time_range, y_axis=y_axis)
+        result = graph.get_stream_type_by_top_10_platforms(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'

From 7b169e94397f40f128c3c20d30ebcaa1dc713924 Mon Sep 17 00:00:00 2001
From: drzoidberg33 <timvdwest@gmail.com>
Date: Tue, 19 Apr 2016 21:17:55 +0200
Subject: [PATCH 02/11] Create ISSUE_TEMPLATE.md

---
 ISSUE_TEMPLATE.md | 42 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 ISSUE_TEMPLATE.md

diff --git a/ISSUE_TEMPLATE.md b/ISSUE_TEMPLATE.md
new file mode 100644
index 00000000..e297ffb1
--- /dev/null
+++ b/ISSUE_TEMPLATE.md
@@ -0,0 +1,42 @@
+### Reporting Issues:
+
+To ensure that a develpoer has enough information to work with please include all of the following information.
+
+**Use proper markdown syntax to structure your post (i.e. code/log in code blocks).**
+
+**Make sure you provide the following information below:**
+- [ ] Version
+
+
+- [ ] Branch
+
+
+- [ ] Commit hash
+
+
+- [ ] Operating system
+
+
+- [ ] Python version
+
+
+- [ ] What you did?
+
+
+- [ ] What happened?
+
+
+- [ ] What you expected?
+
+
+- [ ] How can we reproduce your issue?
+
+
+- [ ] What are your (relevant) settings?
+
+
+- [ ] Include a link to your **FULL** (not just a few lines!) log file that has the error. Please use [Gist](http://gist.github.com) or [Pastebin](http://pastebin.com/).
+
+Close your issue when it's solved! If you found the solution yourself please comment so that others benefit from it.
+
+#### Link to log: 

From ae5889dbac3c5534c7340e8a6f6554efc5c5a44d Mon Sep 17 00:00:00 2001
From: JonnyWong16 <JonnyWong16@users.noreply.github.com>
Date: Thu, 21 Apr 2016 08:38:28 -0700
Subject: [PATCH 03/11] Fix viewing photos crashing PlexPy

---
 plexpy/pmsconnect.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/plexpy/pmsconnect.py b/plexpy/pmsconnect.py
index bf1d72a2..a2c63754 100644
--- a/plexpy/pmsconnect.py
+++ b/plexpy/pmsconnect.py
@@ -1348,6 +1348,7 @@ class PmsConnect(object):
                 transcode_container = helpers.get_xml_attr(transcode_session, 'container')
                 transcode_protocol = helpers.get_xml_attr(transcode_session, 'protocol')
             else:
+                transcode_key = ''
                 throttled = '0'
                 transcode_progress = '0'
                 transcode_speed = ''

From ffa1331802586e687045a7f7fe27a8de368c23d1 Mon Sep 17 00:00:00 2001
From: Otger <otgerp@users.noreply.github.com>
Date: Sun, 24 Apr 2016 03:21:51 +0200
Subject: [PATCH 04/11] Added missing user filtering to a pair of graphs and
 renamed a few things

---
 data/interfaces/default/graphs.html | 26 +++++++++++++-------------
 plexpy/graphs.py                    | 24 ++++++++++++++----------
 plexpy/users.py                     |  2 +-
 plexpy/webserve.py                  | 22 +++++++++++-----------
 4 files changed, 39 insertions(+), 35 deletions(-)

diff --git a/data/interfaces/default/graphs.html b/data/interfaces/default/graphs.html
index 310546ad..ac255643 100644
--- a/data/interfaces/default/graphs.html
+++ b/data/interfaces/default/graphs.html
@@ -319,8 +319,8 @@
         // Initial values for graph from config
         var yaxis = "${config['graph_type']}";
         var current_range = ${config['graph_days']};
-        var current_user = undefined;
         var current_tab = "${'#' + config['graph_tab']}";
+        var selected_user_id = undefined;
         
         $('.days').html(current_range);
         
@@ -352,7 +352,7 @@
             $.ajax({
                 url: "get_plays_by_date",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     var dateArray = [];
@@ -379,7 +379,7 @@
             $.ajax({
                 url: "get_plays_by_dayofweek",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_dayofweek_options.xAxis.categories = data.categories;
@@ -392,7 +392,7 @@
             $.ajax({
                 url: "get_plays_by_hourofday",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_hourofday_options.xAxis.categories = data.categories;
@@ -405,7 +405,7 @@
             $.ajax({
                 url: "get_plays_by_top_10_platforms",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_platform_options.xAxis.categories = data.categories;
@@ -418,7 +418,7 @@
             $.ajax({
                 url: "get_plays_by_top_10_users",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id  },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_user_options.xAxis.categories = data.categories;
@@ -437,7 +437,7 @@
             $.ajax({
                 url: "get_plays_by_stream_type",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     var dateArray = [];
@@ -463,7 +463,7 @@
             $.ajax({
                 url: "get_plays_by_source_resolution",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_source_resolution_options.xAxis.categories = data.categories;
@@ -475,7 +475,7 @@
             $.ajax({
                 url: "get_plays_by_stream_resolution",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_stream_resolution_options.xAxis.categories = data.categories;
@@ -487,7 +487,7 @@
             $.ajax({
                 url: "get_stream_type_by_top_10_platforms",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_platform_by_stream_type_options.xAxis.categories = data.categories;
@@ -499,7 +499,7 @@
             $.ajax({
                 url: "get_stream_type_by_top_10_users",
                 type: 'get',
-                data: { time_range: time_range, y_axis: yaxis, user_id: current_user },
+                data: { time_range: time_range, y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_user_by_stream_type_options.xAxis.categories = data.categories;
@@ -517,7 +517,7 @@
             $.ajax({
                 url: "get_plays_per_month",
                 type: 'get',
-                data: { y_axis: yaxis, user_id: current_user },
+                data: { y_axis: yaxis, user_id: selected_user_id },
                 dataType: "json",
                 success: function(data) {
                     hc_plays_by_month_options.yAxis.min = 0;
@@ -589,7 +589,7 @@
 
         // User changed
         $('#graph-user').on('change', function() {
-            current_user = $(this).val() || undefined;
+            selected_user_id = $(this).val() || undefined;
             if (current_tab == '#tabs-1') { loadGraphsTab1(current_range, yaxis); }
             if (current_tab == '#tabs-2') { loadGraphsTab2(current_range, yaxis); }
             if (current_tab == '#tabs-3') { loadGraphsTab3(yaxis); }
diff --git a/plexpy/graphs.py b/plexpy/graphs.py
index 410fe67b..e64bec51 100644
--- a/plexpy/graphs.py
+++ b/plexpy/graphs.py
@@ -424,12 +424,14 @@ class Graphs(object):
                   'series': [series_1_output, series_2_output, series_3_output]}
         return output
 
-    def get_total_plays_by_top_10_users(self, time_range='30', y_axis='plays'):
+    def get_total_plays_by_top_10_users(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND users.user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT ' \
@@ -440,10 +442,10 @@ class Graphs(object):
                         'COUNT(session_history.id) AS total_count ' \
                         'FROM session_history ' \
                         'JOIN users ON session_history.user_id = users.user_id ' \
-                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) ' \
+                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) %s' \
                         'GROUP BY session_history.user_id ' \
                         'ORDER BY total_count DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -459,10 +461,10 @@ class Graphs(object):
                         ' - (CASE WHEN paused_counter IS NULL THEN 0 ELSE paused_counter END) ELSE 0 END) AS total_duration ' \
                         'FROM session_history ' \
                         'JOIN users ON session_history.user_id = users.user_id ' \
-                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) ' \
+                        'WHERE (datetime(stopped, "unixepoch", "localtime") >= datetime("now", "-%s days", "localtime")) %s' \
                         'GROUP BY session_history.user_id ' \
                         'ORDER BY total_duration DESC ' \
-                        'LIMIT 10' % time_range
+                        'LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
@@ -836,12 +838,14 @@ class Graphs(object):
 
         return output
 
-    def get_stream_type_by_top_10_users(self, time_range='30', y_axis='plays'):
+    def get_stream_type_by_top_10_users(self, time_range='30', y_axis='plays', user_id=None):
         monitor_db = database.MonitorDatabase()
 
         if not time_range.isdigit():
             time_range = '30'
 
+        user_cond = ('AND users.user_id = %s ' % user_id) if user_id and user_id.isdigit() else ''
+        
         try:
             if y_axis == 'plays':
                 query = 'SELECT ' \
@@ -858,9 +862,9 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE datetime(session_history.started, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime") AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") %s' \
                         'GROUP BY username ' \
-                        'ORDER BY total_count DESC LIMIT 10' % time_range
+                        'ORDER BY total_count DESC LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
             else:
@@ -883,9 +887,9 @@ class Graphs(object):
                         'JOIN session_history_media_info ON session_history.id = session_history_media_info.id ' \
                         'WHERE datetime(session_history.started, "unixepoch", "localtime") >= ' \
                         'datetime("now", "-%s days", "localtime") AND ' \
-                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") ' \
+                        '(session_history.media_type = "episode" OR session_history.media_type = "movie" OR session_history.media_type = "track") %s' \
                         'GROUP BY username ' \
-                        'ORDER BY total_duration DESC LIMIT 10' % time_range
+                        'ORDER BY total_duration DESC LIMIT 10' % (time_range, user_cond)
 
                 result = monitor_db.select(query)
         except Exception as e:
diff --git a/plexpy/users.py b/plexpy/users.py
index 2e28e6f8..1fd4d637 100644
--- a/plexpy/users.py
+++ b/plexpy/users.py
@@ -21,7 +21,7 @@ class Users(object):
     def __init__(self):
         pass
 
-    def get_names(self, kwargs=None):
+    def get_user_names(self, kwargs=None):
         monitor_db = database.MonitorDatabase()
         
         try:
diff --git a/plexpy/webserve.py b/plexpy/webserve.py
index d7c84826..e220df08 100644
--- a/plexpy/webserve.py
+++ b/plexpy/webserve.py
@@ -867,7 +867,7 @@ class WebInterface(object):
     def get_user_names(self, **kwargs):
 
         user_data = users.Users()
-        user_names = user_data.get_names(kwargs=kwargs)
+        user_names = user_data.get_user_names(kwargs=kwargs)
 
         cherrypy.response.headers['Content-type'] = 'application/json'
         return json.dumps(user_names)
@@ -939,10 +939,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_top_10_users(self, time_range='30', y_axis='plays', **kwargs):
+    def get_plays_by_top_10_users(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_by_top_10_users(time_range=time_range, y_axis=y_axis)
+        result = graph.get_total_plays_by_top_10_users(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -952,10 +952,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_stream_type(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
+    def get_plays_by_stream_type(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_per_stream_type(time_range=time_range, user_id=user_id, y_axis=y_axis)
+        result = graph.get_total_plays_per_stream_type(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -965,10 +965,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_source_resolution(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
+    def get_plays_by_source_resolution(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_by_source_resolution(time_range=time_range, user_id=user_id, y_axis=y_axis)
+        result = graph.get_total_plays_by_source_resolution(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -978,10 +978,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_plays_by_stream_resolution(self, time_range='30', user_id=None, y_axis='plays', **kwargs):
+    def get_plays_by_stream_resolution(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_total_plays_by_stream_resolution(time_range=time_range, user_id=user_id, y_axis=y_axis)
+        result = graph.get_total_plays_by_stream_resolution(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'
@@ -991,10 +991,10 @@ class WebInterface(object):
 
     @cherrypy.expose
     @addtoapi()
-    def get_stream_type_by_top_10_users(self, time_range='30', y_axis='plays', **kwargs):
+    def get_stream_type_by_top_10_users(self, time_range='30', y_axis='plays', user_id=None, **kwargs):
 
         graph = graphs.Graphs()
-        result = graph.get_stream_type_by_top_10_users(time_range=time_range, y_axis=y_axis)
+        result = graph.get_stream_type_by_top_10_users(time_range=time_range, y_axis=y_axis, user_id=user_id)
 
         if result:
             cherrypy.response.headers['Content-type'] = 'application/json'

From 7ebd74a54aafd939b325916334ee09a103e32a24 Mon Sep 17 00:00:00 2001
From: JonnyWong16 <Jonny.Wong.16@gmail.com>
Date: Wed, 27 Apr 2016 23:10:54 -0700
Subject: [PATCH 05/11] Cache posters with thread id to avoid overwriting
 images

---
 plexpy/notification_handler.py | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/plexpy/notification_handler.py b/plexpy/notification_handler.py
index 2b730ffa..fc07da5a 100644
--- a/plexpy/notification_handler.py
+++ b/plexpy/notification_handler.py
@@ -17,6 +17,7 @@
 import arrow
 import os
 import re
+import threading
 import time
 import urllib
 
@@ -622,11 +623,15 @@ def build_notify_text(session=None, timeline=None, notify_action=None, agent_id=
         # If no previous poster_url
         if not poster_url and plexpy.CONFIG.NOTIFY_UPLOAD_POSTERS:
             try:
+                thread_name = str(threading.current_thread().ident)
                 # Retrieve the poster from Plex and cache to file
                 urllib.urlretrieve(plexpy.CONFIG.PMS_URL + thumb + '?X-Plex-Token=' + plexpy.CONFIG.PMS_TOKEN,
-                                   os.path.join(plexpy.CONFIG.CACHE_DIR, 'cache-poster.jpg'))
+                                   os.path.join(plexpy.CONFIG.CACHE_DIR, 'cache-poster-'+thread_name+'.jpg'))
                 # Upload thumb to Imgur and get link
-                poster_url = helpers.uploadToImgur(os.path.join(plexpy.CONFIG.CACHE_DIR, 'cache-poster.jpg'), poster_title)
+                poster_url = helpers.uploadToImgur(os.path.join(plexpy.CONFIG.CACHE_DIR,
+                                                                'cache-poster-'+thread_name+'.jpg'), poster_title)
+                # Delete the cached poster
+                os.remove(os.path.join(plexpy.CONFIG.CACHE_DIR, 'cache-poster-'+thread_name+'.jpg'))
             except Exception as e:
                 logger.error(u"PlexPy Notifier :: Unable to retrieve poster for rating_key %s: %s." % (str(rating_key), e))
 

From cf70b3e989547ad8d17096f0cad95cc4ba17e7ec Mon Sep 17 00:00:00 2001
From: JonnyWong16 <Jonny.Wong.16@gmail.com>
Date: Wed, 27 Apr 2016 23:11:12 -0700
Subject: [PATCH 06/11] Reconnect websocket on a new thread

---
 plexpy/web_socket.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/plexpy/web_socket.py b/plexpy/web_socket.py
index 76fdfe3d..c027a6e7 100644
--- a/plexpy/web_socket.py
+++ b/plexpy/web_socket.py
@@ -105,8 +105,8 @@ def run():
             logger.info(u"PlexPy WebSocket :: Reconnecting websocket...")
             ws.shutdown()
             ws_connected = False
-            start_thread()
-
+            threading.Thread(target=run).start()
+    
     if not ws_connected and not ws_reconnect:
         logger.error(u"PlexPy WebSocket :: Connection unavailable, falling back to polling.")
         plexpy.POLLING_FAILOVER = True

From 72af2fa2812d36b9783558ceccb3f0f7da9a259c Mon Sep 17 00:00:00 2001
From: JonnyWong16 <Jonny.Wong.16@gmail.com>
Date: Wed, 27 Apr 2016 23:47:24 -0700
Subject: [PATCH 07/11] Fix persist Users > Edit mode on datatable page change

---
 data/interfaces/default/js/tables/users.js | 18 ++++++++++++++++++
 data/interfaces/default/users.html         | 14 ++------------
 2 files changed, 20 insertions(+), 12 deletions(-)

diff --git a/data/interfaces/default/js/tables/users.js b/data/interfaces/default/js/tables/users.js
index 5f6d936d..be8fa661 100644
--- a/data/interfaces/default/js/tables/users.js
+++ b/data/interfaces/default/js/tables/users.js
@@ -1,6 +1,23 @@
 var users_to_delete = [];
 var users_to_purge = [];
 
+function toggleEditNames() {
+    if ($('.edit-control').hasClass('hidden')) {
+        $('.edit-user-control > .edit-user-name').each(function () {
+            a = $(this).children('a');
+            input = $(this).children('input');
+            a.text(input.val());
+            a.removeClass('hidden');
+            input.addClass('hidden');
+        });
+    } else {
+        $('.edit-user-control > .edit-user-name').each(function () {
+            $(this).children('a').addClass('hidden');
+            $(this).children('input').removeClass('hidden');
+        });
+    }
+}
+
 users_list_table_options = {
     "language": {
         "search": "Search: ",
@@ -217,6 +234,7 @@ users_list_table_options = {
             $('.edit-control').each(function () {
                 $(this).removeClass('hidden');
             });
+            toggleEditNames();
         }
     },
     "preDrawCallback": function(settings) {
diff --git a/data/interfaces/default/users.html b/data/interfaces/default/users.html
index 9b1a9dd1..bba7b7dd 100644
--- a/data/interfaces/default/users.html
+++ b/data/interfaces/default/users.html
@@ -156,14 +156,7 @@
                     $(this).addClass('hidden');
                     $('#row-edit-mode-alert').fadeOut(200);
                 });
-                $('.edit-user-control > .edit-user-name').each(function () {
-                    a = $(this).children('a');
-                    input = $(this).children('input');
-                    a.text(input.val());
-                    a.removeClass('hidden');
-                    input.addClass('hidden');
-                });
-
+                toggleEditNames();
             } else {
                 users_to_delete = [];
                 users_to_purge = [];
@@ -171,10 +164,7 @@
                     $(this).find('button.btn-danger').toggleClass('btn-warning').toggleClass('btn-danger');
                     $(this).removeClass('hidden');
                 });
-                $('.edit-user-control > .edit-user-name').each(function () {
-                    $(this).children('a').addClass('hidden');
-                    $(this).children('input').removeClass('hidden');
-                });
+                toggleEditNames();
             }
         });
     });

From 4a5d2f850248fb25891f3d3c9cbbf145a4bfb482 Mon Sep 17 00:00:00 2001
From: JonnyWong16 <JonnyWong16@users.noreply.github.com>
Date: Fri, 29 Apr 2016 07:07:02 -0700
Subject: [PATCH 08/11] Fix regression PMS update notifications broken

---
 plexpy/notification_handler.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plexpy/notification_handler.py b/plexpy/notification_handler.py
index fc07da5a..8ba8e017 100644
--- a/plexpy/notification_handler.py
+++ b/plexpy/notification_handler.py
@@ -934,6 +934,7 @@ def build_server_notify_text(notify_action=None, agent_id=None):
 
     update_status = {}
     if notify_action == 'pmsupdate':
+        pms_connect = pmsconnect.PmsConnect()
         update_status = pms_connect.get_update_staus()
 
     if server_times:
@@ -1108,4 +1109,4 @@ def strip_tag(data, agent_id=None):
     else:
         p = re.compile(r'<.*?>', re.IGNORECASE | re.DOTALL)
 
-    return p.sub('', data)
\ No newline at end of file
+    return p.sub('', data)

From bff4eaba5678990adb1cda6d8c3164554cd7d1a8 Mon Sep 17 00:00:00 2001
From: JonnyWong16 <JonnyWong16@users.noreply.github.com>
Date: Fri, 29 Apr 2016 08:03:14 -0700
Subject: [PATCH 09/11] Websocket check active sessions on reconnect
 cf70b3e989547ad8d17096f0cad95cc4ba17e7ec

---
 plexpy/web_socket.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plexpy/web_socket.py b/plexpy/web_socket.py
index c027a6e7..be0e260a 100644
--- a/plexpy/web_socket.py
+++ b/plexpy/web_socket.py
@@ -105,7 +105,7 @@ def run():
             logger.info(u"PlexPy WebSocket :: Reconnecting websocket...")
             ws.shutdown()
             ws_connected = False
-            threading.Thread(target=run).start()
+            threading.Thread(target=start_thread).start()
     
     if not ws_connected and not ws_reconnect:
         logger.error(u"PlexPy WebSocket :: Connection unavailable, falling back to polling.")

From 14489e1db9d19cd9bb13f1a5e8a03948f0a585ab Mon Sep 17 00:00:00 2001
From: JonnyWong16 <JonnyWong16@users.noreply.github.com>
Date: Sat, 30 Apr 2016 13:03:54 -0700
Subject: [PATCH 10/11] Revert reconnecting
 cf70b3e989547ad8d17096f0cad95cc4ba17e7ec and
 bff4eaba5678990adb1cda6d8c3164554cd7d1a8

---
 plexpy/web_socket.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plexpy/web_socket.py b/plexpy/web_socket.py
index be0e260a..9112a0dc 100644
--- a/plexpy/web_socket.py
+++ b/plexpy/web_socket.py
@@ -105,7 +105,7 @@ def run():
             logger.info(u"PlexPy WebSocket :: Reconnecting websocket...")
             ws.shutdown()
             ws_connected = False
-            threading.Thread(target=start_thread).start()
+            start_thread()
     
     if not ws_connected and not ws_reconnect:
         logger.error(u"PlexPy WebSocket :: Connection unavailable, falling back to polling.")

From 0aa2537d1e37b3487e056909ed84b75208a8015c Mon Sep 17 00:00:00 2001
From: JonnyWong16 <Jonny.Wong.16@gmail.com>
Date: Sun, 1 May 2016 11:01:34 -0700
Subject: [PATCH 11/11] v1.3.16

---
 CHANGELOG.md      | 8 ++++++++
 plexpy/version.py | 2 +-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 00ea57c3..1a0a6609 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,13 @@
 # Changelog
 
+## v1.3.16 (2016-05-01)
+
+* Fix: Viewing photos crashing PlexPy.
+* Fix: Persist Users > Edit mode on datatable page change.
+* Fix: PMS update notifications broken.
+* Change: Cache notifications poster with thread ID to avoid overwritting images.
+
+
 ## v1.3.15 (2016-04-18)
 
 * Fix: Slack notifications failing when using and icon URL.
diff --git a/plexpy/version.py b/plexpy/version.py
index 5761785f..603cb281 100644
--- a/plexpy/version.py
+++ b/plexpy/version.py
@@ -1,2 +1,2 @@
 PLEXPY_VERSION = "master"
-PLEXPY_RELEASE_VERSION = "1.3.15"
+PLEXPY_RELEASE_VERSION = "1.3.16"