PlexKodiConnect/default.py

193 lines
6.5 KiB
Python
Raw Normal View History

# -*- coding: utf-8 -*-
###############################################################################
2018-06-22 03:24:37 +10:00
from __future__ import absolute_import, division, unicode_literals
import logging
2018-06-22 03:24:37 +10:00
from sys import argv
2017-01-03 00:07:24 +11:00
from urlparse import parse_qsl
2018-06-22 03:24:37 +10:00
from xbmc import sleep, executebuiltin
from xbmcgui import ListItem
2017-01-03 00:07:24 +11:00
from xbmcplugin import setResolvedUrl
2018-06-22 03:24:37 +10:00
from resources.lib import entrypoint, utils, pickler, pkc_listitem, \
variables as v, loghandler
2018-06-24 03:15:24 +10:00
from resources.lib.watchdog.utils import unicode_paths
###############################################################################
loghandler.config()
2017-03-08 21:02:25 +11:00
log = logging.getLogger('PLEX.default')
2016-08-30 03:12:46 +10:00
###############################################################################
2017-01-03 00:07:24 +11:00
HANDLE = int(argv[1])
2016-06-20 07:24:34 +10:00
class Main():
# MAIN ENTRY POINT
2017-01-03 00:07:24 +11:00
# @utils.profiling()
def __init__(self):
2018-06-24 03:15:24 +10:00
log.debug('Full sys.argv received: %s', argv)
# Parse parameters
2018-06-24 03:15:24 +10:00
path = unicode_paths.decode(argv[0])
arguments = unicode_paths.decode(argv[2])
params = dict(parse_qsl(arguments[1:]))
2017-03-08 20:58:08 +11:00
mode = params.get('mode', '')
itemid = params.get('id', '')
2017-01-03 00:07:24 +11:00
if mode == 'play':
2017-03-08 20:39:05 +11:00
self.play()
elif mode == 'plex_node':
self.play()
2017-03-08 20:39:05 +11:00
elif mode == 'ondeck':
2018-06-15 22:11:17 +10:00
entrypoint.on_deck_episodes(itemid,
params.get('tagname'),
int(params.get('limit')))
2017-03-08 20:39:05 +11:00
elif mode == 'recentepisodes':
2018-06-15 22:01:09 +10:00
entrypoint.recent_episodes(params.get('type'),
2018-06-15 22:00:12 +10:00
params.get('tagname'),
int(params.get('limit')))
2017-03-08 20:39:05 +11:00
elif mode == 'nextup':
2018-06-15 21:57:33 +10:00
entrypoint.next_up_episodes(params['tagname'],
int(params['limit']))
2017-03-08 20:39:05 +11:00
2017-03-08 21:02:25 +11:00
elif mode == 'inprogressepisodes':
2018-06-15 21:58:39 +10:00
entrypoint.in_progress_episodes(params['tagname'],
int(params['limit']))
2017-03-08 20:39:05 +11:00
elif mode == 'browseplex':
2017-03-09 02:21:00 +11:00
entrypoint.browse_plex(key=params.get('key'),
plex_section_id=params.get('id'))
2017-03-08 20:39:05 +11:00
elif mode == 'watchlater':
entrypoint.watchlater()
elif mode == 'channels':
entrypoint.channels()
2018-05-05 03:03:27 +10:00
elif mode == 'extras':
entrypoint.extras(plex_id=params.get('plex_id'))
2017-03-08 21:02:25 +11:00
elif mode == 'settings':
2017-03-08 20:39:05 +11:00
executebuiltin('Addon.OpenSettings(%s)' % v.ADDON_ID)
2017-03-08 21:02:25 +11:00
elif mode == 'enterPMS':
2018-06-15 22:13:46 +10:00
entrypoint.create_new_pms()
2017-03-08 20:39:05 +11:00
elif mode == 'reset':
2018-06-22 03:24:37 +10:00
utils.reset()
2017-03-08 20:39:05 +11:00
elif mode == 'togglePlexTV':
2018-06-15 21:44:46 +10:00
entrypoint.toggle_plex_tv_sign_in()
2017-03-08 20:39:05 +11:00
elif mode == 'resetauth':
2018-06-15 21:44:46 +10:00
entrypoint.reset_authorization()
2017-03-08 20:39:05 +11:00
elif mode == 'passwords':
2018-06-22 03:24:37 +10:00
utils.passwords_xml()
2017-03-08 20:39:05 +11:00
elif mode == 'switchuser':
2018-06-15 21:50:04 +10:00
entrypoint.switch_plex_user()
2017-03-08 20:39:05 +11:00
2017-03-08 21:02:25 +11:00
elif mode in ('manualsync', 'repair'):
2018-06-22 03:24:37 +10:00
if pickler.pickl_window('plex_online') != 'true':
2017-03-08 20:39:05 +11:00
# Server is not online, do not run the sync
2018-06-22 03:24:37 +10:00
utils.dialog('ok', utils.lang(29999), utils.lang(39205))
2017-03-08 21:02:25 +11:00
log.error('Not connected to a PMS.')
2017-03-08 20:39:05 +11:00
else:
if mode == 'repair':
2017-03-08 21:02:25 +11:00
log.info('Requesting repair lib sync')
2018-06-22 03:24:37 +10:00
utils.plex_command('RUN_LIB_SCAN', 'repair')
2017-03-08 20:39:05 +11:00
elif mode == 'manualsync':
2017-03-08 21:02:25 +11:00
log.info('Requesting full library scan')
2018-06-22 03:24:37 +10:00
utils.plex_command('RUN_LIB_SCAN', 'full')
2017-03-08 20:39:05 +11:00
2017-03-08 21:02:25 +11:00
elif mode == 'texturecache':
2017-08-22 02:53:38 +10:00
log.info('Requesting texture caching of all textures')
2018-06-22 03:24:37 +10:00
utils.plex_command('RUN_LIB_SCAN', 'textures')
2017-03-08 20:39:05 +11:00
2017-03-08 21:02:25 +11:00
elif mode == 'chooseServer':
2018-06-15 21:44:46 +10:00
entrypoint.choose_pms_server()
2017-03-08 20:39:05 +11:00
2017-03-08 21:02:25 +11:00
elif mode == 'refreshplaylist':
2017-03-08 20:39:05 +11:00
log.info('Requesting playlist/nodes refresh')
2018-06-22 03:24:37 +10:00
utils.plex_command('RUN_LIB_SCAN', 'views')
2017-03-08 20:39:05 +11:00
2017-03-08 21:02:25 +11:00
elif mode == 'deviceid':
2017-03-08 20:39:05 +11:00
self.deviceid()
elif mode == 'fanart':
log.info('User requested fanarttv refresh')
2018-06-22 03:24:37 +10:00
utils.plex_command('RUN_LIB_SCAN', 'fanart')
2017-03-08 20:39:05 +11:00
2018-06-24 03:15:24 +10:00
elif '/extrafanart' in path:
plexpath = arguments[1:]
2017-03-08 20:58:08 +11:00
plexid = itemid
2018-06-15 22:05:48 +10:00
entrypoint.extra_fanart(plexid, plexpath)
entrypoint.get_video_files(plexid, plexpath)
# Called by e.g. 3rd party plugin video extras
2018-06-24 03:15:24 +10:00
elif ('/Extras' in path or '/VideoFiles' in path or
'/Extras' in arguments):
2017-03-08 20:58:08 +11:00
plexId = itemid or None
2018-06-15 22:05:48 +10:00
entrypoint.get_video_files(plexId, params)
elif mode == 'playlists':
entrypoint.playlists(params.get('type'))
else:
2018-06-15 21:49:18 +10:00
entrypoint.show_main_menu(content_type=params.get('content_type'))
2017-03-08 20:39:05 +11:00
2017-08-22 02:53:38 +10:00
@staticmethod
def play():
"""
Start up playback_starter in main Python thread
"""
2018-04-16 02:13:48 +10:00
request = '%s&handle=%s' % (argv[2], HANDLE)
2017-03-08 21:02:25 +11:00
# Put the request into the 'queue'
2018-06-22 03:24:37 +10:00
utils.plex_command('PLAY', request)
2018-04-16 02:13:48 +10:00
if HANDLE == -1:
# Handle -1 received, not waiting for main thread
return
2017-03-08 20:39:05 +11:00
# Wait for the result
2018-06-22 03:24:37 +10:00
while not pickler.pickl_window('plex_result'):
2017-03-08 20:39:05 +11:00
sleep(50)
2018-06-22 03:24:37 +10:00
result = pickler.unpickle_me()
2017-03-08 20:39:05 +11:00
if result is None:
log.error('Error encountered, aborting')
2018-06-22 03:24:37 +10:00
utils.dialog('notification',
heading='{plex}',
message=utils.lang(30128),
icon='{error}',
time=3000)
2017-03-08 20:39:05 +11:00
setResolvedUrl(HANDLE, False, ListItem())
elif result.listitem:
2018-06-22 03:24:37 +10:00
listitem = pkc_listitem.convert_pkc_to_listitem(result.listitem)
2017-03-08 20:39:05 +11:00
setResolvedUrl(HANDLE, True, listitem)
2017-08-22 02:53:38 +10:00
@staticmethod
def deviceid():
2018-06-22 03:24:37 +10:00
deviceId_old = pickler.pickl_window('plex_client_Id')
2018-07-04 16:05:24 +10:00
from resources.lib import clientinfo
2017-03-08 20:39:05 +11:00
try:
2018-07-04 16:05:24 +10:00
deviceId = clientinfo.getDeviceId(reset=True)
2017-03-08 20:39:05 +11:00
except Exception as e:
2017-03-08 21:02:25 +11:00
log.error('Failed to generate a new device Id: %s' % e)
2018-06-22 03:24:37 +10:00
utils.dialog('ok', utils.lang(29999), utils.lang(33032))
2017-03-08 20:39:05 +11:00
else:
2017-03-08 21:02:25 +11:00
log.info('Successfully removed old device ID: %s New deviceId:'
'%s' % (deviceId_old, deviceId))
# 'Kodi will now restart to apply the changes'
2018-06-22 03:24:37 +10:00
utils.dialog('ok', utils.lang(29999), utils.lang(33033))
2017-03-08 20:39:05 +11:00
executebuiltin('RestartApp')
2017-08-22 02:53:38 +10:00
2017-03-08 21:02:25 +11:00
if __name__ == '__main__':
2017-03-08 20:39:05 +11:00
log.info('%s started' % v.ADDON_ID)
2016-06-20 07:24:34 +10:00
Main()
2017-03-08 20:39:05 +11:00
log.info('%s stopped' % v.ADDON_ID)