56 lines
2.2 KiB
Python
56 lines
2.2 KiB
Python
#!/usr/bin/env python
|
|
# -*- coding: utf-8 -*-
|
|
from __future__ import absolute_import, division, unicode_literals
|
|
from logging import getLogger
|
|
|
|
from . import utils, playback, context_entry, transfer, backgroundthread
|
|
|
|
###############################################################################
|
|
|
|
LOG = getLogger('PLEX.playback_starter')
|
|
|
|
###############################################################################
|
|
|
|
|
|
class PlaybackTask(backgroundthread.Task):
|
|
"""
|
|
Processes new plays
|
|
"""
|
|
def __init__(self, command):
|
|
self.command = command
|
|
super(PlaybackTask, self).__init__()
|
|
|
|
def run(self):
|
|
LOG.debug('Starting PlaybackTask with %s', self.command)
|
|
item = self.command
|
|
try:
|
|
_, params = item.split('?', 1)
|
|
except ValueError:
|
|
# E.g. other add-ons scanning for Extras folder
|
|
LOG.debug('Detected 3rd party add-on call - ignoring')
|
|
transfer.send(True)
|
|
# Wait for default.py to have completed xbmcplugin.setResolvedUrl()
|
|
transfer.wait_for_transfer(source='default')
|
|
return
|
|
params = dict(utils.parse_qsl(params))
|
|
mode = params.get('mode')
|
|
resolve = False if params.get('handle') == '-1' else True
|
|
LOG.debug('Received mode: %s, params: %s', mode, params)
|
|
if mode == 'play':
|
|
if params.get('resume'):
|
|
resume = params.get('resume') == '1'
|
|
else:
|
|
resume = None
|
|
playback.playback_triage(plex_id=params.get('plex_id'),
|
|
plex_type=params.get('plex_type'),
|
|
path=params.get('path'),
|
|
resolve=resolve,
|
|
resume=resume)
|
|
elif mode == 'plex_node':
|
|
playback.process_indirect(params['key'],
|
|
params['offset'],
|
|
resolve=resolve)
|
|
elif mode == 'context_menu':
|
|
context_entry.ContextMenu(kodi_id=params.get('kodi_id'),
|
|
kodi_type=params.get('kodi_type'))
|
|
LOG.debug('Finished PlaybackTask')
|