mirror of
https://github.com/Tautulli/Tautulli.git
synced 2025-07-11 07:46:07 -07:00
637339ea62
Add remote server switch in config. Add compulsory server verification in settings. Store the machine_id in settings for quick retrieval. Add setup complete screen on setup wizard and increase delay. Refresh server URL params on startup and set up 12 hourly refresh schedule. Use outer join on history tables. Add extra exception in http_handler to catch http requests trying to communicate with https-only server.
939 lines
48 KiB
Python
939 lines
48 KiB
Python
# This file is part of PlexPy.
|
|
#
|
|
# PlexPy is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# PlexPy is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with PlexPy. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
from plexpy import logger, helpers, datafactory, http_handler
|
|
from urlparse import urlparse
|
|
|
|
import plexpy
|
|
|
|
|
|
class PmsConnect(object):
|
|
"""
|
|
Retrieve data from Plex Server
|
|
"""
|
|
|
|
def __init__(self):
|
|
if plexpy.CONFIG.PMS_URL:
|
|
url_parsed = urlparse(plexpy.CONFIG.PMS_URL)
|
|
hostname = url_parsed.hostname
|
|
port = url_parsed.port
|
|
self.protocol = url_parsed.scheme
|
|
else:
|
|
hostname = plexpy.CONFIG.PMS_IP
|
|
port = plexpy.CONFIG.PMS_PORT
|
|
self.protocol = 'http'
|
|
|
|
self.request_handler = http_handler.HTTPHandler(host=hostname,
|
|
port=port,
|
|
token=plexpy.CONFIG.PMS_TOKEN)
|
|
|
|
"""
|
|
Return current sessions.
|
|
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_sessions(self, output_format=''):
|
|
uri = '/status/sessions'
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return metadata for request item.
|
|
|
|
Parameters required: rating_key { Plex ratingKey }
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_metadata(self, rating_key='', output_format=''):
|
|
uri = '/library/metadata/' + rating_key
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return list of recently added items.
|
|
|
|
Parameters required: count { number of results to return }
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_recently_added(self, count='0', output_format=''):
|
|
uri = '/library/recentlyAdded?X-Plex-Container-Start=0&X-Plex-Container-Size=' + count
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return list of episodes in requested season.
|
|
|
|
Parameters required: rating_key { ratingKey of parent }
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_episode_list(self, rating_key='', output_format=''):
|
|
uri = '/library/metadata/' + rating_key + '/children'
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return list of local servers.
|
|
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_server_list(self, output_format=''):
|
|
uri = '/servers'
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return the local servers preferences.
|
|
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_server_prefs(self, output_format=''):
|
|
uri = '/:/prefs'
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return the local server identity.
|
|
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_local_server_identity(self, output_format=''):
|
|
uri = '/identity'
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return sync item details.
|
|
|
|
Parameters required: sync_id { unique sync id for item }
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_sync_item(self, sync_id=None, output_format=''):
|
|
uri = '/sync/items/' + sync_id
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return sync transcode queue.
|
|
|
|
Optional parameters: output_format { dict, json }
|
|
|
|
Output: array
|
|
"""
|
|
def get_sync_transcode_queue(self, output_format=''):
|
|
uri = '/sync/transcodeQueue'
|
|
request = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
output_format=output_format)
|
|
|
|
return request
|
|
|
|
"""
|
|
Return processed and validated list of recently added items.
|
|
|
|
Parameters required: count { number of results to return }
|
|
|
|
Output: array
|
|
"""
|
|
def get_recently_added_details(self, count='0'):
|
|
recent = self.get_recently_added(count, output_format='xml')
|
|
|
|
try:
|
|
xml_head = recent.getElementsByTagName('MediaContainer')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_recently_added.")
|
|
return []
|
|
|
|
recents_list = []
|
|
|
|
for a in xml_head:
|
|
if a.getAttribute('size'):
|
|
if a.getAttribute('size') == '0':
|
|
output = {'recently_added': []}
|
|
return output
|
|
|
|
if a.getElementsByTagName('Directory'):
|
|
recents_main = a.getElementsByTagName('Directory')
|
|
for item in recents_main:
|
|
recent_type = helpers.get_xml_attr(item, 'type')
|
|
recent_items = {'type': recent_type,
|
|
'rating_key': helpers.get_xml_attr(item, 'ratingKey'),
|
|
'title': helpers.get_xml_attr(item, 'title'),
|
|
'thumb': helpers.get_xml_attr(item, 'thumb'),
|
|
'added_at': helpers.get_xml_attr(item, 'addedAt')
|
|
}
|
|
recents_list.append(recent_items)
|
|
|
|
if a.getElementsByTagName('Video'):
|
|
recents_main = a.getElementsByTagName('Video')
|
|
for item in recents_main:
|
|
recent_type = helpers.get_xml_attr(item, 'type')
|
|
|
|
if recent_type == 'movie':
|
|
recent_items = {'type': recent_type,
|
|
'rating_key': helpers.get_xml_attr(item, 'ratingKey'),
|
|
'title': helpers.get_xml_attr(item, 'title'),
|
|
'year': helpers.get_xml_attr(item, 'year'),
|
|
'thumb': helpers.get_xml_attr(item, 'thumb'),
|
|
'added_at': helpers.get_xml_attr(item, 'addedAt')
|
|
}
|
|
recents_list.append(recent_items)
|
|
else:
|
|
pass
|
|
|
|
output = {'recently_added': sorted(recents_list, key=lambda k: k['added_at'], reverse=True)}
|
|
return output
|
|
|
|
"""
|
|
Return processed and validated metadata list for requested item.
|
|
|
|
Parameters required: rating_key { Plex ratingKey }
|
|
|
|
Output: array
|
|
"""
|
|
def get_metadata_details(self, rating_key=''):
|
|
metadata = self.get_metadata(rating_key, output_format='xml')
|
|
|
|
try:
|
|
xml_head = metadata.getElementsByTagName('MediaContainer')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_metadata.")
|
|
return []
|
|
|
|
metadata_list = []
|
|
|
|
for a in xml_head:
|
|
if a.getAttribute('size'):
|
|
if a.getAttribute('size') != '1':
|
|
metadata_list = {'metadata': None}
|
|
return metadata_list
|
|
|
|
if a.getElementsByTagName('Directory'):
|
|
metadata_main = a.getElementsByTagName('Directory')[0]
|
|
metadata_type = helpers.get_xml_attr(metadata_main, 'type')
|
|
elif a.getElementsByTagName('Video'):
|
|
metadata_main = a.getElementsByTagName('Video')[0]
|
|
metadata_type = helpers.get_xml_attr(metadata_main, 'type')
|
|
elif a.getElementsByTagName('Track'):
|
|
metadata_main = a.getElementsByTagName('Track')[0]
|
|
metadata_type = helpers.get_xml_attr(metadata_main, 'type')
|
|
else:
|
|
logger.debug(u"Metadata failed")
|
|
|
|
genres = []
|
|
actors = []
|
|
writers = []
|
|
directors = []
|
|
|
|
if metadata_main.getElementsByTagName('Genre'):
|
|
for genre in metadata_main.getElementsByTagName('Genre'):
|
|
genres.append(helpers.get_xml_attr(genre, 'tag'))
|
|
|
|
if metadata_main.getElementsByTagName('Role'):
|
|
for actor in metadata_main.getElementsByTagName('Role'):
|
|
actors.append(helpers.get_xml_attr(actor, 'tag'))
|
|
|
|
if metadata_main.getElementsByTagName('Writer'):
|
|
for writer in metadata_main.getElementsByTagName('Writer'):
|
|
writers.append(helpers.get_xml_attr(writer, 'tag'))
|
|
|
|
if metadata_main.getElementsByTagName('Director'):
|
|
for director in metadata_main.getElementsByTagName('Director'):
|
|
directors.append(helpers.get_xml_attr(director, 'tag'))
|
|
|
|
if metadata_type == 'show':
|
|
metadata = {'type': metadata_type,
|
|
'rating_key': helpers.get_xml_attr(metadata_main, 'ratingKey'),
|
|
'grandparent_title': helpers.get_xml_attr(metadata_main, 'grandparentTitle'),
|
|
'parent_index': helpers.get_xml_attr(metadata_main, 'parentIndex'),
|
|
'parent_title': helpers.get_xml_attr(metadata_main, 'parentTitle'),
|
|
'index': helpers.get_xml_attr(metadata_main, 'index'),
|
|
'studio': helpers.get_xml_attr(metadata_main, 'studio'),
|
|
'title': helpers.get_xml_attr(metadata_main, 'title'),
|
|
'content_rating': helpers.get_xml_attr(metadata_main, 'contentRating'),
|
|
'summary': helpers.get_xml_attr(metadata_main, 'summary'),
|
|
'rating': helpers.get_xml_attr(metadata_main, 'rating'),
|
|
'duration': helpers.get_xml_attr(metadata_main, 'duration'),
|
|
'year': helpers.get_xml_attr(metadata_main, 'year'),
|
|
'thumb': helpers.get_xml_attr(metadata_main, 'thumb'),
|
|
'parent_thumb': helpers.get_xml_attr(metadata_main, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(metadata_main, 'grandparentThumb'),
|
|
'art': helpers.get_xml_attr(metadata_main, 'art'),
|
|
'originally_available_at': helpers.get_xml_attr(metadata_main, 'originallyAvailableAt'),
|
|
'added_at': helpers.get_xml_attr(metadata_main, 'addedAt'),
|
|
'updated_at': helpers.get_xml_attr(metadata_main, 'updatedAt'),
|
|
'last_viewed_at': helpers.get_xml_attr(metadata_main, 'lastViewedAt'),
|
|
'guid': helpers.get_xml_attr(metadata_main, 'guid'),
|
|
'writers': writers,
|
|
'directors': directors,
|
|
'genres': genres,
|
|
'actors': actors
|
|
}
|
|
metadata_list = {'metadata': metadata}
|
|
elif metadata_type == 'episode':
|
|
metadata = {'type': metadata_type,
|
|
'rating_key': helpers.get_xml_attr(metadata_main, 'ratingKey'),
|
|
'grandparent_title': helpers.get_xml_attr(metadata_main, 'grandparentTitle'),
|
|
'parent_index': helpers.get_xml_attr(metadata_main, 'parentIndex'),
|
|
'parent_title': helpers.get_xml_attr(metadata_main, 'parentTitle'),
|
|
'index': helpers.get_xml_attr(metadata_main, 'index'),
|
|
'studio': helpers.get_xml_attr(metadata_main, 'studio'),
|
|
'title': helpers.get_xml_attr(metadata_main, 'title'),
|
|
'content_rating': helpers.get_xml_attr(metadata_main, 'contentRating'),
|
|
'summary': helpers.get_xml_attr(metadata_main, 'summary'),
|
|
'rating': helpers.get_xml_attr(metadata_main, 'rating'),
|
|
'duration': helpers.get_xml_attr(metadata_main, 'duration'),
|
|
'year': helpers.get_xml_attr(metadata_main, 'year'),
|
|
'thumb': helpers.get_xml_attr(metadata_main, 'thumb'),
|
|
'parent_thumb': helpers.get_xml_attr(metadata_main, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(metadata_main, 'grandparentThumb'),
|
|
'art': helpers.get_xml_attr(metadata_main, 'art'),
|
|
'originally_available_at': helpers.get_xml_attr(metadata_main, 'originallyAvailableAt'),
|
|
'added_at': helpers.get_xml_attr(metadata_main, 'addedAt'),
|
|
'updated_at': helpers.get_xml_attr(metadata_main, 'updatedAt'),
|
|
'last_viewed_at': helpers.get_xml_attr(metadata_main, 'lastViewedAt'),
|
|
'guid': helpers.get_xml_attr(metadata_main, 'guid'),
|
|
'writers': writers,
|
|
'directors': directors,
|
|
'genres': genres,
|
|
'actors': actors
|
|
}
|
|
metadata_list = {'metadata': metadata}
|
|
elif metadata_type == 'movie':
|
|
metadata = {'type': metadata_type,
|
|
'rating_key': helpers.get_xml_attr(metadata_main, 'ratingKey'),
|
|
'grandparent_title': helpers.get_xml_attr(metadata_main, 'grandparentTitle'),
|
|
'parent_index': helpers.get_xml_attr(metadata_main, 'parentIndex'),
|
|
'parent_title': helpers.get_xml_attr(metadata_main, 'parentTitle'),
|
|
'index': helpers.get_xml_attr(metadata_main, 'index'),
|
|
'studio': helpers.get_xml_attr(metadata_main, 'studio'),
|
|
'title': helpers.get_xml_attr(metadata_main, 'title'),
|
|
'content_rating': helpers.get_xml_attr(metadata_main, 'contentRating'),
|
|
'summary': helpers.get_xml_attr(metadata_main, 'summary'),
|
|
'rating': helpers.get_xml_attr(metadata_main, 'rating'),
|
|
'duration': helpers.get_xml_attr(metadata_main, 'duration'),
|
|
'year': helpers.get_xml_attr(metadata_main, 'year'),
|
|
'thumb': helpers.get_xml_attr(metadata_main, 'thumb'),
|
|
'parent_thumb': helpers.get_xml_attr(metadata_main, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(metadata_main, 'grandparentThumb'),
|
|
'art': helpers.get_xml_attr(metadata_main, 'art'),
|
|
'originally_available_at': helpers.get_xml_attr(metadata_main, 'originallyAvailableAt'),
|
|
'added_at': helpers.get_xml_attr(metadata_main, 'addedAt'),
|
|
'updated_at': helpers.get_xml_attr(metadata_main, 'updatedAt'),
|
|
'last_viewed_at': helpers.get_xml_attr(metadata_main, 'lastViewedAt'),
|
|
'guid': helpers.get_xml_attr(metadata_main, 'guid'),
|
|
'genres': genres,
|
|
'actors': actors,
|
|
'writers': writers,
|
|
'directors': directors
|
|
}
|
|
metadata_list = {'metadata': metadata}
|
|
elif metadata_type == 'season':
|
|
parent_rating_key = helpers.get_xml_attr(metadata_main, 'parentRatingKey')
|
|
show_details = self.get_metadata_details(parent_rating_key)
|
|
metadata = {'type': metadata_type,
|
|
'rating_key': helpers.get_xml_attr(metadata_main, 'ratingKey'),
|
|
'grandparent_title': helpers.get_xml_attr(metadata_main, 'grandparentTitle'),
|
|
'parent_index': helpers.get_xml_attr(metadata_main, 'parentIndex'),
|
|
'parent_title': helpers.get_xml_attr(metadata_main, 'parentTitle'),
|
|
'index': helpers.get_xml_attr(metadata_main, 'index'),
|
|
'studio': helpers.get_xml_attr(metadata_main, 'studio'),
|
|
'title': helpers.get_xml_attr(metadata_main, 'title'),
|
|
'content_rating': helpers.get_xml_attr(metadata_main, 'contentRating'),
|
|
'summary': show_details['metadata']['summary'],
|
|
'rating': helpers.get_xml_attr(metadata_main, 'rating'),
|
|
'duration': show_details['metadata']['duration'],
|
|
'year': helpers.get_xml_attr(metadata_main, 'year'),
|
|
'thumb': helpers.get_xml_attr(metadata_main, 'thumb'),
|
|
'parent_thumb': helpers.get_xml_attr(metadata_main, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(metadata_main, 'grandparentThumb'),
|
|
'art': helpers.get_xml_attr(metadata_main, 'art'),
|
|
'originally_available_at': helpers.get_xml_attr(metadata_main, 'originallyAvailableAt'),
|
|
'added_at': helpers.get_xml_attr(metadata_main, 'addedAt'),
|
|
'updated_at': helpers.get_xml_attr(metadata_main, 'updatedAt'),
|
|
'last_viewed_at': helpers.get_xml_attr(metadata_main, 'lastViewedAt'),
|
|
'guid': helpers.get_xml_attr(metadata_main, 'guid'),
|
|
'genres': genres,
|
|
'actors': actors,
|
|
'writers': writers,
|
|
'directors': directors
|
|
}
|
|
metadata_list = {'metadata': metadata}
|
|
elif metadata_type == 'track':
|
|
metadata = {'type': metadata_type,
|
|
'rating_key': helpers.get_xml_attr(metadata_main, 'ratingKey'),
|
|
'grandparent_title': helpers.get_xml_attr(metadata_main, 'grandparentTitle'),
|
|
'parent_index': helpers.get_xml_attr(metadata_main, 'parentIndex'),
|
|
'parent_title': helpers.get_xml_attr(metadata_main, 'parentTitle'),
|
|
'index': helpers.get_xml_attr(metadata_main, 'index'),
|
|
'studio': helpers.get_xml_attr(metadata_main, 'studio'),
|
|
'title': helpers.get_xml_attr(metadata_main, 'title'),
|
|
'content_rating': helpers.get_xml_attr(metadata_main, 'contentRating'),
|
|
'summary': helpers.get_xml_attr(metadata_main, 'summary'),
|
|
'rating': helpers.get_xml_attr(metadata_main, 'rating'),
|
|
'duration': helpers.get_xml_attr(metadata_main, 'duration'),
|
|
'year': helpers.get_xml_attr(metadata_main, 'year'),
|
|
'thumb': helpers.get_xml_attr(metadata_main, 'thumb'),
|
|
'parent_thumb': helpers.get_xml_attr(metadata_main, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(metadata_main, 'grandparentThumb'),
|
|
'art': helpers.get_xml_attr(metadata_main, 'art'),
|
|
'originally_available_at': helpers.get_xml_attr(metadata_main, 'originallyAvailableAt'),
|
|
'added_at': helpers.get_xml_attr(metadata_main, 'addedAt'),
|
|
'updated_at': helpers.get_xml_attr(metadata_main, 'updatedAt'),
|
|
'last_viewed_at': helpers.get_xml_attr(metadata_main, 'lastViewedAt'),
|
|
'guid': helpers.get_xml_attr(metadata_main, 'guid'),
|
|
'genres': genres,
|
|
'actors': actors,
|
|
'writers': writers,
|
|
'directors': directors
|
|
}
|
|
metadata_list = {'metadata': metadata}
|
|
else:
|
|
return None
|
|
|
|
return metadata_list
|
|
|
|
"""
|
|
Return processed and validated session list.
|
|
|
|
Output: array
|
|
"""
|
|
def get_current_activity(self):
|
|
session_data = self.get_sessions(output_format='xml')
|
|
|
|
try:
|
|
xml_head = session_data.getElementsByTagName('MediaContainer')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_sessions.")
|
|
return []
|
|
|
|
session_list = []
|
|
|
|
for a in xml_head:
|
|
if a.getAttribute('size'):
|
|
if a.getAttribute('size') == '0':
|
|
session_list = {'stream_count': '0',
|
|
'sessions': []
|
|
}
|
|
return session_list
|
|
|
|
if a.getElementsByTagName('Track'):
|
|
session_data = a.getElementsByTagName('Track')
|
|
session_type = 'track'
|
|
for session in session_data:
|
|
session_output = self.get_session_each(session_type, session)
|
|
session_list.append(session_output)
|
|
if a.getElementsByTagName('Video'):
|
|
session_data = a.getElementsByTagName('Video')
|
|
session_type = 'video'
|
|
for session in session_data:
|
|
session_output = self.get_session_each(session_type, session)
|
|
session_list.append(session_output)
|
|
|
|
output = {'stream_count': helpers.get_xml_attr(xml_head[0], 'size'),
|
|
'sessions': session_list
|
|
}
|
|
|
|
return output
|
|
|
|
"""
|
|
Return selected data from current sessions.
|
|
This function processes and validates session data
|
|
|
|
Parameters required: stream_type { track or video }
|
|
session { the session dictionary }
|
|
Output: dict
|
|
"""
|
|
def get_session_each(self, stream_type='', session=None):
|
|
session_output = None
|
|
data_factory = datafactory.DataFactory()
|
|
if stream_type == 'track':
|
|
|
|
media_info = session.getElementsByTagName('Media')[0]
|
|
audio_decision = 'direct play'
|
|
audio_channels = helpers.get_xml_attr(media_info, 'audioChannels')
|
|
audio_codec = helpers.get_xml_attr(media_info, 'audioCodec')
|
|
container = helpers.get_xml_attr(media_info, 'container')
|
|
bitrate = helpers.get_xml_attr(media_info, 'bitrate')
|
|
duration = helpers.get_xml_attr(media_info, 'duration')
|
|
progress = helpers.get_xml_attr(session, 'viewOffset')
|
|
|
|
if session.getElementsByTagName('TranscodeSession'):
|
|
transcode_session = session.getElementsByTagName('TranscodeSession')[0]
|
|
audio_decision = helpers.get_xml_attr(transcode_session, 'audioDecision')
|
|
transcode_audio_channels = helpers.get_xml_attr(transcode_session, 'audioChannels')
|
|
transcode_audio_codec = helpers.get_xml_attr(transcode_session, 'audioCodec')
|
|
transcode_container = helpers.get_xml_attr(transcode_session, 'container')
|
|
transcode_protocol = helpers.get_xml_attr(transcode_session, 'protocol')
|
|
duration = helpers.get_xml_attr(transcode_session, 'duration')
|
|
else:
|
|
transcode_audio_channels = ''
|
|
transcode_audio_codec = ''
|
|
transcode_container = ''
|
|
transcode_protocol = ''
|
|
|
|
user_details = data_factory.get_user_details(
|
|
user=helpers.get_xml_attr(session.getElementsByTagName('User')[0], 'title'))
|
|
|
|
if helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'machineIdentifier').endswith('_Track'):
|
|
machine_id = helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'machineIdentifier')[:-6]
|
|
else:
|
|
machine_id = helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'machineIdentifier')
|
|
|
|
session_output = {'session_key': helpers.get_xml_attr(session, 'sessionKey'),
|
|
'media_index': helpers.get_xml_attr(session, 'index'),
|
|
'parent_media_index': helpers.get_xml_attr(session, 'parentIndex'),
|
|
'art': helpers.get_xml_attr(session, 'art'),
|
|
'parent_thumb': helpers.get_xml_attr(session, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(session, 'grandparentThumb'),
|
|
'thumb': helpers.get_xml_attr(session, 'thumb'),
|
|
'bif_thumb': '',
|
|
'user': helpers.get_xml_attr(session.getElementsByTagName('User')[0], 'title'),
|
|
'user_id': user_details['user_id'],
|
|
'friendly_name': user_details['friendly_name'],
|
|
'player': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'title'),
|
|
'platform': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'platform'),
|
|
'machine_id': machine_id,
|
|
'state': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'state'),
|
|
'grandparent_title': helpers.get_xml_attr(session, 'grandparentTitle'),
|
|
'parent_title': helpers.get_xml_attr(session, 'parentTitle'),
|
|
'title': helpers.get_xml_attr(session, 'title'),
|
|
'rating_key': helpers.get_xml_attr(session, 'ratingKey'),
|
|
'parent_rating_key': helpers.get_xml_attr(session, 'parentRatingKey'),
|
|
'grandparent_rating_key': helpers.get_xml_attr(session, 'grandparentRatingKey'),
|
|
'audio_decision': audio_decision,
|
|
'audio_channels': audio_channels,
|
|
'audio_codec': audio_codec,
|
|
'video_decision': '',
|
|
'video_codec': '',
|
|
'height': '',
|
|
'width': '',
|
|
'container': container,
|
|
'bitrate': bitrate,
|
|
'video_resolution': '',
|
|
'video_framerate': '',
|
|
'aspect_ratio': '',
|
|
'transcode_audio_channels': transcode_audio_channels,
|
|
'transcode_audio_codec': transcode_audio_codec,
|
|
'transcode_video_codec': '',
|
|
'transcode_width': '',
|
|
'transcode_height': '',
|
|
'transcode_container': transcode_container,
|
|
'transcode_protocol': transcode_protocol,
|
|
'duration': duration,
|
|
'progress': progress,
|
|
'progress_percent': str(helpers.get_percent(progress, duration)),
|
|
'type': 'track',
|
|
'indexes': 0
|
|
}
|
|
elif stream_type == 'video':
|
|
media_info = session.getElementsByTagName('Media')[0]
|
|
audio_decision = 'direct play'
|
|
audio_channels = helpers.get_xml_attr(media_info, 'audioChannels')
|
|
audio_codec = helpers.get_xml_attr(media_info, 'audioCodec')
|
|
video_decision = 'direct play'
|
|
video_codec = helpers.get_xml_attr(media_info, 'videoCodec')
|
|
container = helpers.get_xml_attr(media_info, 'container')
|
|
bitrate = helpers.get_xml_attr(media_info, 'bitrate')
|
|
video_resolution = helpers.get_xml_attr(media_info, 'videoResolution')
|
|
video_framerate = helpers.get_xml_attr(media_info, 'videoFrameRate')
|
|
aspect_ratio = helpers.get_xml_attr(media_info, 'aspectRatio')
|
|
width = helpers.get_xml_attr(media_info, 'width')
|
|
height = helpers.get_xml_attr(media_info, 'height')
|
|
duration = helpers.get_xml_attr(media_info, 'duration')
|
|
progress = helpers.get_xml_attr(session, 'viewOffset')
|
|
|
|
if session.getElementsByTagName('TranscodeSession'):
|
|
transcode_session = session.getElementsByTagName('TranscodeSession')[0]
|
|
audio_decision = helpers.get_xml_attr(transcode_session, 'audioDecision')
|
|
transcode_audio_channels = helpers.get_xml_attr(transcode_session, 'audioChannels')
|
|
transcode_audio_codec = helpers.get_xml_attr(transcode_session, 'audioCodec')
|
|
video_decision = helpers.get_xml_attr(transcode_session, 'videoDecision')
|
|
transcode_video_codec = helpers.get_xml_attr(transcode_session, 'videoCodec')
|
|
transcode_width = helpers.get_xml_attr(transcode_session, 'width')
|
|
transcode_height = helpers.get_xml_attr(transcode_session, 'height')
|
|
transcode_container = helpers.get_xml_attr(transcode_session, 'container')
|
|
transcode_protocol = helpers.get_xml_attr(transcode_session, 'protocol')
|
|
else:
|
|
transcode_audio_channels = ''
|
|
transcode_audio_codec = ''
|
|
transcode_video_codec = ''
|
|
transcode_width = ''
|
|
transcode_height = ''
|
|
transcode_container = ''
|
|
transcode_protocol = ''
|
|
|
|
media_info = session.getElementsByTagName('Media')[0]
|
|
if media_info.getElementsByTagName('Part'):
|
|
indexes = helpers.get_xml_attr(media_info.getElementsByTagName('Part')[0], 'indexes')
|
|
part_id = helpers.get_xml_attr(media_info.getElementsByTagName('Part')[0], 'id')
|
|
if indexes == 'sd':
|
|
bif_thumb = '/library/parts/' + part_id + '/indexes/sd/' + progress
|
|
else:
|
|
bif_thumb = ''
|
|
else:
|
|
indexes = ''
|
|
bif_thumb = ''
|
|
|
|
if plexpy.CONFIG.PMS_USE_BIF and indexes == 'sd':
|
|
use_indexes = 1
|
|
else:
|
|
use_indexes = 0
|
|
|
|
user_details = data_factory.get_user_details(
|
|
user=helpers.get_xml_attr(session.getElementsByTagName('User')[0], 'title'))
|
|
|
|
if helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'machineIdentifier').endswith('_Video'):
|
|
machine_id = helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'machineIdentifier')[:-6]
|
|
else:
|
|
machine_id = helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'machineIdentifier')
|
|
|
|
if helpers.get_xml_attr(session, 'type') == 'episode':
|
|
session_output = {'session_key': helpers.get_xml_attr(session, 'sessionKey'),
|
|
'media_index': helpers.get_xml_attr(session, 'index'),
|
|
'parent_media_index': helpers.get_xml_attr(session, 'parentIndex'),
|
|
'art': helpers.get_xml_attr(session, 'art'),
|
|
'parent_thumb': helpers.get_xml_attr(session, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(session, 'grandparentThumb'),
|
|
'thumb': helpers.get_xml_attr(session, 'thumb'),
|
|
'bif_thumb': bif_thumb,
|
|
'user': helpers.get_xml_attr(session.getElementsByTagName('User')[0], 'title'),
|
|
'user_id': user_details['user_id'],
|
|
'friendly_name': user_details['friendly_name'],
|
|
'player': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'title'),
|
|
'platform': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'platform'),
|
|
'machine_id': machine_id,
|
|
'state': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'state'),
|
|
'grandparent_title': helpers.get_xml_attr(session, 'grandparentTitle'),
|
|
'parent_title': helpers.get_xml_attr(session, 'parentTitle'),
|
|
'title': helpers.get_xml_attr(session, 'title'),
|
|
'rating_key': helpers.get_xml_attr(session, 'ratingKey'),
|
|
'parent_rating_key': helpers.get_xml_attr(session, 'parentRatingKey'),
|
|
'grandparent_rating_key': helpers.get_xml_attr(session, 'grandparentRatingKey'),
|
|
'audio_decision': audio_decision,
|
|
'audio_channels': audio_channels,
|
|
'audio_codec': audio_codec,
|
|
'video_decision': video_decision,
|
|
'video_codec': video_codec,
|
|
'height': height,
|
|
'width': width,
|
|
'container': container,
|
|
'bitrate': bitrate,
|
|
'video_resolution': video_resolution,
|
|
'video_framerate': video_framerate,
|
|
'aspect_ratio': aspect_ratio,
|
|
'transcode_audio_channels': transcode_audio_channels,
|
|
'transcode_audio_codec': transcode_audio_codec,
|
|
'transcode_video_codec': transcode_video_codec,
|
|
'transcode_width': transcode_width,
|
|
'transcode_height': transcode_height,
|
|
'transcode_container': transcode_container,
|
|
'transcode_protocol': transcode_protocol,
|
|
'duration': duration,
|
|
'progress': progress,
|
|
'progress_percent': str(helpers.get_percent(progress, duration)),
|
|
'type': helpers.get_xml_attr(session, 'type'),
|
|
'indexes': use_indexes
|
|
}
|
|
elif helpers.get_xml_attr(session, 'type') == 'movie':
|
|
session_output = {'session_key': helpers.get_xml_attr(session, 'sessionKey'),
|
|
'media_index': helpers.get_xml_attr(session, 'index'),
|
|
'parent_media_index': helpers.get_xml_attr(session, 'parentIndex'),
|
|
'art': helpers.get_xml_attr(session, 'art'),
|
|
'thumb': helpers.get_xml_attr(session, 'thumb'),
|
|
'bif_thumb': bif_thumb,
|
|
'parent_thumb': helpers.get_xml_attr(session, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(session, 'grandparentThumb'),
|
|
'user': helpers.get_xml_attr(session.getElementsByTagName('User')[0], 'title'),
|
|
'user_id': user_details['user_id'],
|
|
'friendly_name': user_details['friendly_name'],
|
|
'player': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'title'),
|
|
'platform': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'platform'),
|
|
'machine_id': machine_id,
|
|
'state': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'state'),
|
|
'grandparent_title': helpers.get_xml_attr(session, 'grandparentTitle'),
|
|
'parent_title': helpers.get_xml_attr(session, 'parentTitle'),
|
|
'title': helpers.get_xml_attr(session, 'title'),
|
|
'rating_key': helpers.get_xml_attr(session, 'ratingKey'),
|
|
'parent_rating_key': helpers.get_xml_attr(session, 'parentRatingKey'),
|
|
'grandparent_rating_key': helpers.get_xml_attr(session, 'grandparentRatingKey'),
|
|
'audio_decision': audio_decision,
|
|
'audio_channels': audio_channels,
|
|
'audio_codec': audio_codec,
|
|
'video_decision': video_decision,
|
|
'video_codec': video_codec,
|
|
'height': height,
|
|
'width': width,
|
|
'container': container,
|
|
'bitrate': bitrate,
|
|
'video_resolution': video_resolution,
|
|
'video_framerate': video_framerate,
|
|
'aspect_ratio': aspect_ratio,
|
|
'transcode_audio_channels': transcode_audio_channels,
|
|
'transcode_audio_codec': transcode_audio_codec,
|
|
'transcode_video_codec': transcode_video_codec,
|
|
'transcode_width': transcode_width,
|
|
'transcode_height': transcode_height,
|
|
'transcode_container': transcode_container,
|
|
'transcode_protocol': transcode_protocol,
|
|
'duration': duration,
|
|
'progress': progress,
|
|
'progress_percent': str(helpers.get_percent(progress, duration)),
|
|
'type': helpers.get_xml_attr(session, 'type'),
|
|
'indexes': use_indexes
|
|
}
|
|
elif helpers.get_xml_attr(session, 'type') == 'clip':
|
|
session_output = {'session_key': helpers.get_xml_attr(session, 'sessionKey'),
|
|
'media_index': helpers.get_xml_attr(session, 'index'),
|
|
'parent_media_index': helpers.get_xml_attr(session, 'parentIndex'),
|
|
'art': helpers.get_xml_attr(session, 'art'),
|
|
'thumb': helpers.get_xml_attr(session, 'thumb'),
|
|
'bif_thumb': bif_thumb,
|
|
'parent_thumb': helpers.get_xml_attr(session, 'parentThumb'),
|
|
'grandparent_thumb': helpers.get_xml_attr(session, 'grandparentThumb'),
|
|
'user': helpers.get_xml_attr(session.getElementsByTagName('User')[0], 'title'),
|
|
'user_id': user_details['user_id'],
|
|
'friendly_name': user_details['friendly_name'],
|
|
'player': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'title'),
|
|
'platform': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'platform'),
|
|
'machine_id': machine_id,
|
|
'state': helpers.get_xml_attr(session.getElementsByTagName('Player')[0], 'state'),
|
|
'grandparent_title': helpers.get_xml_attr(session, 'grandparentTitle'),
|
|
'parent_title': helpers.get_xml_attr(session, 'parentTitle'),
|
|
'title': helpers.get_xml_attr(session, 'title'),
|
|
'rating_key': helpers.get_xml_attr(session, 'ratingKey'),
|
|
'parent_rating_key': helpers.get_xml_attr(session, 'parentRatingKey'),
|
|
'grandparent_rating_key': helpers.get_xml_attr(session, 'grandparentRatingKey'),
|
|
'audio_decision': audio_decision,
|
|
'audio_channels': audio_channels,
|
|
'audio_codec': audio_codec,
|
|
'video_decision': video_decision,
|
|
'video_codec': video_codec,
|
|
'height': height,
|
|
'width': width,
|
|
'container': container,
|
|
'bitrate': bitrate,
|
|
'video_resolution': video_resolution,
|
|
'video_framerate': video_framerate,
|
|
'aspect_ratio': aspect_ratio,
|
|
'transcode_audio_channels': transcode_audio_channels,
|
|
'transcode_audio_codec': transcode_audio_codec,
|
|
'transcode_video_codec': transcode_video_codec,
|
|
'transcode_width': transcode_width,
|
|
'transcode_height': transcode_height,
|
|
'transcode_container': transcode_container,
|
|
'transcode_protocol': transcode_protocol,
|
|
'duration': duration,
|
|
'progress': progress,
|
|
'progress_percent': str(helpers.get_percent(progress, duration)),
|
|
'type': helpers.get_xml_attr(session, 'type'),
|
|
'indexes': 0
|
|
}
|
|
else:
|
|
logger.warn(u"No known stream types found in session list.")
|
|
|
|
return session_output
|
|
|
|
"""
|
|
Return processed and validated episode list.
|
|
|
|
Output: array
|
|
"""
|
|
def get_season_children(self, rating_key=''):
|
|
episode_data = self.get_episode_list(rating_key, output_format='xml')
|
|
|
|
try:
|
|
xml_head = episode_data.getElementsByTagName('MediaContainer')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_episode_list.")
|
|
return []
|
|
|
|
episode_list = []
|
|
|
|
for a in xml_head:
|
|
if a.getAttribute('size'):
|
|
if a.getAttribute('size') == '0':
|
|
logger.debug(u"No episode data.")
|
|
episode_list = {'episode_count': '0',
|
|
'episode_list': []
|
|
}
|
|
return episode_list
|
|
|
|
if a.getElementsByTagName('Video'):
|
|
result_data = a.getElementsByTagName('Video')
|
|
for result in result_data:
|
|
episode_output = {'rating_key': helpers.get_xml_attr(result, 'ratingKey'),
|
|
'index': helpers.get_xml_attr(result, 'index'),
|
|
'title': helpers.get_xml_attr(result, 'title'),
|
|
'thumb': helpers.get_xml_attr(result, 'thumb')
|
|
}
|
|
episode_list.append(episode_output)
|
|
|
|
output = {'episode_count': helpers.get_xml_attr(xml_head[0], 'size'),
|
|
'title': helpers.get_xml_attr(xml_head[0], 'title2'),
|
|
'episode_list': episode_list
|
|
}
|
|
|
|
return output
|
|
|
|
"""
|
|
Return the list of local servers.
|
|
|
|
Output: array
|
|
"""
|
|
def get_servers_info(self):
|
|
recent = self.get_server_list(output_format='xml')
|
|
|
|
try:
|
|
xml_head = recent.getElementsByTagName('Server')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_server_list.")
|
|
return []
|
|
|
|
server_info = []
|
|
for a in xml_head:
|
|
output = {"name": helpers.get_xml_attr(a, 'name'),
|
|
"machine_identifier": helpers.get_xml_attr(a, 'machineIdentifier'),
|
|
"host": helpers.get_xml_attr(a, 'host'),
|
|
"port": helpers.get_xml_attr(a, 'port'),
|
|
"version": helpers.get_xml_attr(a, 'version')
|
|
}
|
|
|
|
server_info.append(output)
|
|
|
|
return server_info
|
|
|
|
"""
|
|
Return the local machine identity.
|
|
|
|
Output: dict
|
|
"""
|
|
def get_server_identity(self):
|
|
identity = self.get_local_server_identity(output_format='xml')
|
|
|
|
try:
|
|
xml_head = identity.getElementsByTagName('MediaContainer')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_local_server_identity.")
|
|
return []
|
|
|
|
server_identity = {}
|
|
for a in xml_head:
|
|
server_identity = {"machine_identifier": helpers.get_xml_attr(a, 'machineIdentifier'),
|
|
"version": helpers.get_xml_attr(a, 'version')
|
|
}
|
|
|
|
return server_identity
|
|
|
|
"""
|
|
Return a specified server preference.
|
|
|
|
Parameters required: pref { name of preference }
|
|
|
|
Output: string
|
|
"""
|
|
def get_server_pref(self, pref=None):
|
|
if pref:
|
|
prefs = self.get_server_prefs(output_format='xml')
|
|
|
|
try:
|
|
xml_head = prefs.getElementsByTagName('Setting')
|
|
except:
|
|
logger.warn("Unable to parse XML for get_local_server_name.")
|
|
return ''
|
|
|
|
pref_value = 'None'
|
|
for a in xml_head:
|
|
if helpers.get_xml_attr(a, 'id') == pref:
|
|
pref_value = helpers.get_xml_attr(a, 'value')
|
|
break
|
|
|
|
return pref_value
|
|
else:
|
|
logger.debug(u"Server preferences queried but no parameter received.")
|
|
return None
|
|
|
|
"""
|
|
Return image data as array.
|
|
Array contains the image content type and image binary
|
|
|
|
Parameters required: img { Plex image location }
|
|
Optional parameters: width { the image width }
|
|
height { the image height }
|
|
Output: array
|
|
"""
|
|
def get_image(self, img=None, width=None, height=None):
|
|
if img:
|
|
if width.isdigit() and height.isdigit():
|
|
uri = '/photo/:/transcode?url=http://127.0.0.1:32400' + img + '&width=' + width + '&height=' + height
|
|
else:
|
|
uri = '/photo/:/transcode?url=http://127.0.0.1:32400' + img
|
|
|
|
request, content_type = self.request_handler.make_request(uri=uri,
|
|
proto=self.protocol,
|
|
request_type='GET',
|
|
return_type=True)
|
|
|
|
return [request, content_type]
|
|
else:
|
|
logger.error("Image proxy queries but no input received.")
|
|
return None
|