Merge branch 'dev'

* Really this time...

CHANGELOG.md

@@ -1,5 +1,22 @@
 # Changelog
 
+## v1.2.7 (2015-11-27)
+* Fix IP address option in notifications
+
+
+## v1.2.6 (2015-11-27)
+
+* Fixes for IP logging in PMS < 0.9.14.x.
+* Fix issue in plexWatch importer when trying to import item with no ratingKey.
+
+
+## v1.2.5 (2015-11-25)
+
+* Add video_decision and audio_decision to notification options
+* Fix IP address logging
+* Fix log spam if notifications disabled 
+
+
 ## v1.2.4 (2015-11-24)
 
 * Add filtering by media type in the history table

data/interfaces/default/settings.html

@@ -1001,9 +1001,17 @@ available_notification_agents = sorted(notifiers.available_notification_agents()
                                     <td width="150"><strong>{episode_num00}</strong></td>
                                     <td>The two digit episode number.</td>
                                 </tr>
+                                <tr>
+                                    <td width="150"><strong>{video_decision}</strong></td>
+                                    <td>The video transcode decisions for the media item.</td>
+                                </tr>
+                                <tr>
+                                    <td width="150"><strong>{audio_decision}</strong></td>
+                                    <td>The audio transcode decisions for the media item.</td>
+                                </tr>
                                 <tr>
                                     <td width="150"><strong>{transcode_decision}</strong></td>
-                                    <td>The transcode decisions for the media item.</td>
+                                    <td>The stream transcode decisions for the media item.</td>
                                 </tr>
                                 <tr>
                                     <td width="150"><strong>{year}</strong></td>

plexpy/activity_processor.py

@@ -39,7 +39,7 @@ class ActivityProcessor(object):
                       'parent_title': session['parent_title'],
                       'grandparent_title': session['grandparent_title'],
                       'friendly_name': session['friendly_name'],
-                      'ip_address': session['ip_address'],
+                      #'ip_address': session['ip_address'],
                       'player': session['player'],
                       'platform': session['platform'],
                       'parent_rating_key': session['parent_rating_key'],
@@ -67,6 +67,10 @@ class ActivityProcessor(object):
                       'transcode_height': session['transcode_height']
                       }
 
+            # Add ip_address back into values
+            if session['ip_address']:
+                values.update({'ip_address': session['ip_address']})
+
             keys = {'session_key': session['session_key'],
                     'rating_key': session['rating_key']}
 
@@ -75,23 +79,22 @@ class ActivityProcessor(object):
             if result == 'insert':
                 # Push any notifications - Push it on it's own thread so we don't hold up our db actions
                 if notify:
+                    values.update({'ip_address': session['ip_address']})
                     threading.Thread(target=notification_handler.notify,
                                      kwargs=dict(stream_data=values, notify_action='play')).start()
 
+                # If it's our first write then time stamp it.
                 started = int(time.time())
                 timestamp = {'started': started}
+                self.db.upsert('sessions', timestamp, keys)
 
                 # Try and grab IP address from logs (fallback if not on PMS 0.9.14 and above)
                 if not session['ip_address']:
                     if plexpy.CONFIG.IP_LOGGING_ENABLE and plexpy.CONFIG.PMS_LOGS_FOLDER:
                         ip_address = self.find_session_ip(rating_key=session['rating_key'],
                                                           machine_id=session['machine_id'])
-                        timestamp.update({'ip_address': ip_address})
+                        ip_address = {'ip_address': ip_address}
-                    else:
+                        self.db.upsert('sessions', ip_address, keys)
-                        timestamp.update({'ip_address': None})
-
-                # If it's our first write then time stamp it.
-                self.db.upsert('sessions', timestamp, keys)
 
     def write_session_history(self, session=None, import_metadata=None, is_import=False, import_ignore_interval=0):
         from plexpy import users

plexpy/helpers.py

@@ -92,13 +92,15 @@ def latinToAscii(unicrap):
     }
 
     r = ''
-    for i in unicrap:
+    if unicrap:
-        if ord(i) in xlate:
+        for i in unicrap:
-            r += xlate[ord(i)]
+            if ord(i) in xlate:
-        elif ord(i) >= 0x80:
+                r += xlate[ord(i)]
-            pass
+            elif ord(i) >= 0x80:
-        else:
+                pass
-            r += str(i)
+            else:
+                r += str(i)
+
     return r
 
 

plexpy/notification_handler.py

@@ -161,7 +161,7 @@ def notify(stream_data=None, notify_action=None):
         elif stream_data['media_type'] == 'clip':
             pass
         else:
-            logger.debug(u"PlexPy Notifier :: Notify called with unsupported media type.")
+            #logger.debug(u"PlexPy Notifier :: Notify called with unsupported media type.")
             pass
     else:
         logger.debug(u"PlexPy Notifier :: Notify called but incomplete data received.")
@@ -370,6 +370,8 @@ def build_notify_text(session=None, timeline=None, state=None):
     duration = helpers.convert_milliseconds_to_minutes(metadata['duration'])
 
     # Default values
+    video_decision = ''
+    audio_decision = ''
     transcode_decision = ''
     stream_duration = 0
     view_offset = 0
@@ -381,18 +383,15 @@ def build_notify_text(session=None, timeline=None, state=None):
     # Session values
     if session:
         # Generate a combined transcode decision value
-        if session['video_decision']:
+        video_decision = session['video_decision'].title()
-            if session['video_decision'] == 'transcode':
+        audio_decision = session['audio_decision'].title()
-                transcode_decision = 'Transcode'
+
-            elif session['video_decision'] == 'copy' or session['audio_decision'] == 'copy':
+        if session['video_decision'] == 'transcode' or session['audio_decision'] == 'transcode':
-                transcode_decision = 'Direct Stream'
+            transcode_decision = 'Transcode'
-            else:
+        elif session['video_decision'] == 'copy' or session['audio_decision'] == 'copy':
-                transcode_decision = 'Direct Play'
+            transcode_decision = 'Direct Stream'
-        elif session['audio_decision']:
+        else:
-            if session['audio_decision'] == 'transcode':
+            transcode_decision = 'Direct Play'
-                transcode_decision = 'Transcode'
-            else:
-                transcode_decision = 'Direct Play'
 
         if state != 'play':
             if session['paused_counter']:
@@ -405,7 +404,7 @@ def build_notify_text(session=None, timeline=None, state=None):
         user = session['friendly_name']
         platform = session['platform']
         player = session['player']
-        ip_address = session['ip_address'] if session['ip_address'] != '' else 'N/A'
+        ip_address = session['ip_address'] if session['ip_address'] else 'N/A'
 
     progress_percent = helpers.get_percent(view_offset, duration)
 
@@ -422,10 +421,12 @@ def build_notify_text(session=None, timeline=None, state=None):
                         'artist_name': metadata['grandparent_title'],
                         'album_name': metadata['parent_title'],
                         'track_name': metadata['title'],
-                        'season_num': metadata['parent_index'],
+                        'season_num': metadata['parent_index'].zfill(1),
                         'season_num00': metadata['parent_index'].zfill(2),
-                        'episode_num': metadata['index'],
+                        'episode_num': metadata['index'].zfill(1),
                         'episode_num00': metadata['index'].zfill(2),
+                        'video_decision': video_decision,
+                        'audio_decision': audio_decision,
                         'transcode_decision': transcode_decision,
                         'year': metadata['year'],
                         'studio': metadata['studio'],

plexpy/plexwatch_import.py

@@ -292,10 +292,15 @@ def import_from_plexwatch(database=None, table_name=None, import_ignore_interval
 
         # If we get back None from our xml extractor skip over the record and log error.
         if not extracted_xml:
-            logger.error(u"PlexPy Importer :: Skipping line with ratingKey %s due to malformed xml."
+            logger.error(u"PlexPy Importer :: Skipping record with ratingKey %s due to malformed xml."
                          % str(row['rating_key']))
             continue
 
+        # Skip line if we don't have a ratingKey to work with
+        if not row['rating_key']:
+            logger.error(u"PlexPy Importer :: Skipping record due to null ratingRey.")
+            continue
+
         # If the user_id no longer exists in the friends list, pull it from the xml.
         if user_data.get_user_id(user=row['user']):
             user_id = user_data.get_user_id(user=row['user'])

plexpy/version.py

@@ -1,2 +1,2 @@
 PLEXPY_VERSION = "master"
-PLEXPY_RELEASE_VERSION = "1.2.4"
+PLEXPY_RELEASE_VERSION = "1.2.7"