Alhaziel01
279 lines
9.5 KiB
Python
279 lines
9.5 KiB
Python
# -*- coding: utf-8 -*-
|
|
# ------------------------------------------------------------
|
|
# Channel for recent videos on several channels
|
|
# ------------------------------------------------------------
|
|
import sys, channelselector
|
|
from platformcode import config, logger, platformtools
|
|
from channelselector import auto_filter
|
|
from core.item import Item
|
|
from core import support, filetools, channeltools, tmdb
|
|
|
|
if sys.version_info[0] >= 3:
|
|
from concurrent import futures
|
|
else:
|
|
from concurrent_py2 import futures
|
|
|
|
mode = config.getSetting('result_mode', 'news')
|
|
cacheTime = 10
|
|
|
|
def mainlist(item):
|
|
logger.debug()
|
|
|
|
itemlist = []
|
|
# list_canales, any_active = get_channels_list()
|
|
channel_language = config.getSetting("channel_language", default="auto")
|
|
if channel_language == 'auto':
|
|
channel_language = auto_filter()
|
|
|
|
itemlist = [item.clone(action="news", extra="movie", title=config.getLocalizedString(30122) + ' {news}'),
|
|
item.clone(action="news", extra="tvshow", title=config.getLocalizedString(60511) + ' {news}'),
|
|
item.clone(action="news", extra="anime", title=config.getLocalizedString(60512) + ' {news}')]
|
|
|
|
set_category_context(itemlist)
|
|
|
|
itemlist.append(Item(channel='shortcuts', action="SettingOnPosition", category=7, setting=1,
|
|
title=support.typo(config.getLocalizedString(70285), 'bold color kod')))
|
|
|
|
support.thumb(itemlist)
|
|
set_category_context(itemlist)
|
|
|
|
return itemlist
|
|
|
|
|
|
def set_category_context(itemlist):
|
|
for item in itemlist:
|
|
if item.extra:
|
|
item.context = [{"title": config.getLocalizedString(60514) % item.title,
|
|
"extra": item.extra,
|
|
"action": "setting_channel",
|
|
"channel": item.channel}]
|
|
item.category = config.getLocalizedString(60679) % item.title
|
|
|
|
|
|
def get_channels(category='all'):
|
|
logger.debug()
|
|
# logger.dbg()
|
|
channels = []
|
|
|
|
all_channels = channelselector.filterchannels(category)
|
|
|
|
for ch in all_channels:
|
|
channel = ch.channel
|
|
ch_param = channeltools.get_channel_parameters(channel)
|
|
if not ch_param.get("active", False):
|
|
continue
|
|
|
|
if not config.getSetting("include_in_newest_" + category, channel):
|
|
continue
|
|
|
|
channels.append([ch_param.get('title'), channel])
|
|
return channels
|
|
|
|
|
|
def news(item):
|
|
|
|
if item.itemlist:
|
|
itemlist = support.itemlistdb()
|
|
|
|
else:
|
|
itemlist = []
|
|
itlist = []
|
|
results = cache(item.extra)
|
|
if not results:
|
|
progress = platformtools.dialogProgress(item.category, config.getLocalizedString(60519))
|
|
channels = get_channels(item.extra)
|
|
|
|
channelNames = [c[0] for c in channels]
|
|
count = 0
|
|
# progress.update(int(count / len(channels)), ', '.join(c for c in channelNames))
|
|
|
|
# logger.dbg()
|
|
with futures.ThreadPoolExecutor() as executor:
|
|
for channel in channels:
|
|
if progress.iscanceled(): return
|
|
itlist.append(executor.submit(get_newest, channel, item.extra, channels))
|
|
for res in futures.as_completed(itlist):
|
|
if res.result():
|
|
name = res.result()[0]
|
|
channelNames.remove(name)
|
|
count += 1
|
|
percent = int((float(count) / len(channels)) * 100)
|
|
progress.update(percent, ', '.join(c for c in channelNames))
|
|
results.append(res.result())
|
|
|
|
if progress:
|
|
# progress.update(100, '')
|
|
progress.close()
|
|
|
|
cache(item.extra, results)
|
|
|
|
if mode in [2]:
|
|
for res in results:
|
|
_name, _id, _list = res
|
|
for it in _list:
|
|
it.title += ' [{}]'.format(_name)
|
|
itemlist.extend(_list)
|
|
|
|
elif mode in [1]:
|
|
for res in results:
|
|
plot = ''
|
|
items = []
|
|
for it in res[2]:
|
|
plot += '\n{}'.format(platformtools.setTitle(it))
|
|
items.append(it.tourl())
|
|
if items:
|
|
itemlist.append(Item(title='{} [{}]'.format(res[0], len(items)),
|
|
plot=plot,
|
|
channel='news',
|
|
action='movies',
|
|
thumbnail=channeltools.get_channel_parameters(res[1])["thumbnail"],
|
|
items=items))
|
|
itemlist.sort(key=lambda it: it.title)
|
|
|
|
elif mode in [0]:
|
|
items = {}
|
|
for res in results:
|
|
_name, _id, _list = res
|
|
for it in _list:
|
|
if it.fulltitle not in items:
|
|
items[it.fulltitle] = []
|
|
|
|
it.channelName = _name
|
|
items[it.fulltitle].append(it.tourl())
|
|
|
|
itemlist = [Item(title='{} [{}]'.format(v, len(v) if len(v) > 1 else Item().fromurl(v[0]).channelName), infoLabels=Item().fromurl(v[0]).infoLabels, channel='news', action='movies', items = v) for v in items.values()]
|
|
|
|
if mode in [0, 2]:
|
|
itemlist = support.pagination(itemlist, item, 'news')
|
|
tmdb.set_infoLabels_itemlist(itemlist, seekTmdb=True)
|
|
|
|
return itemlist
|
|
|
|
|
|
def get_newest(channel, category, channels):
|
|
global progress
|
|
name = channel[0]
|
|
_id = channel[1]
|
|
list_newest = []
|
|
try:
|
|
module = platformtools.channelImport(_id)
|
|
logger.debug('channel_id=', _id, 'category=', category)
|
|
|
|
if not module:
|
|
return []
|
|
|
|
list_newest = module.newest(category)
|
|
for item in list_newest:
|
|
item.channel = _id
|
|
|
|
|
|
|
|
except:
|
|
logger.error("No se pueden recuperar novedades de: " + name)
|
|
import traceback
|
|
logger.error(traceback.format_exc())
|
|
|
|
return name, _id, list_newest
|
|
|
|
|
|
def movies(item):
|
|
if item.itemlist:
|
|
itemlist = support.itemlistdb()
|
|
else:
|
|
itemlist = [Item().fromurl(url=it) for it in item.items]
|
|
if len(itemlist) == 1:
|
|
from platformcode.launcher import run
|
|
run(itemlist[0])
|
|
if mode == 0:
|
|
for it in itemlist:
|
|
it.title = '{} [{}]'.format(it.title, it.channelName)
|
|
itemlist = support.pagination(itemlist, item, 'movies')
|
|
tmdb.set_infoLabels_itemlist(itemlist, seekTmdb=True)
|
|
return itemlist
|
|
|
|
|
|
def cache(_type, results=None):
|
|
from core import db
|
|
from time import time
|
|
# logger.dbg()
|
|
news = dict(db['news'][_type])
|
|
|
|
|
|
if results != None:
|
|
news = {}
|
|
news['time'] = time()
|
|
news['results'] = results
|
|
db['news'][_type] = news
|
|
|
|
elif news.get('time', 0) + 60 * cacheTime < time() :
|
|
results = []
|
|
else:
|
|
results = news.get('results', [])
|
|
db.close()
|
|
return results
|
|
|
|
def settings(item):
|
|
return platformtools.showChannelSettings(caption=config.getLocalizedString(60532))
|
|
|
|
|
|
def setting_channel(item):
|
|
import os, glob
|
|
channels_path = os.path.join(config.getRuntimePath(), "channels", '*.json')
|
|
channel_language = config.getSetting("channel_language", default="auto")
|
|
if channel_language == 'auto':
|
|
channel_language = auto_filter()
|
|
|
|
|
|
list_controls = []
|
|
for infile in sorted(glob.glob(channels_path)):
|
|
channel_id = filetools.basename(infile)[:-5]
|
|
channel_parameters = channeltools.get_channel_parameters(channel_id)
|
|
|
|
# Do not include if it is an inactive channel
|
|
if not channel_parameters["active"]:
|
|
continue
|
|
|
|
# Do not include if the channel is in a filtered language
|
|
if channel_language != "all" and channel_language not in str(channel_parameters["language"]) and "*" not in channel_parameters["language"]:
|
|
continue
|
|
|
|
# Do not include if the channel does not exist 'include_in_newest' in your configuration
|
|
include_in_newest = config.getSetting("include_in_newest_" + item.extra, channel_id)
|
|
if include_in_newest is None or item.extra not in channel_parameters['categories']:
|
|
continue
|
|
|
|
control = {'id': channel_id,
|
|
'type': "bool",
|
|
'label': channel_parameters["title"],
|
|
'default': include_in_newest,
|
|
'enabled': True,
|
|
'visible': True}
|
|
|
|
list_controls.append(control)
|
|
|
|
caption = config.getLocalizedString(60533) + item.title.replace(config.getLocalizedString(60525), "- ").strip()
|
|
if config.getSetting("custom_button_value_news", item.channel):
|
|
custom_button_icon = 'subtract'
|
|
else:
|
|
custom_button_icon = 'add'
|
|
|
|
return platformtools.showChannelSettings(list_controls=list_controls,
|
|
caption=caption,
|
|
callback="save_settings", item=item,
|
|
custom_buttons=[{'visible': True, 'function': "cb_custom_button", 'all':True, 'close': False, 'icon': 'add'},
|
|
{'visible': True, 'function': "cb_custom_button", 'all':False, 'close': False, 'icon': 'subtract'}])
|
|
|
|
|
|
def save_settings(item, dict_values):
|
|
cache(item.extra, [])
|
|
for v in dict_values:
|
|
config.setSetting("include_in_newest_" + item.extra, dict_values[v], v)
|
|
|
|
|
|
def cb_custom_button(item, dict_values, button):
|
|
for v in list(dict_values.keys()):
|
|
dict_values[v] = button['all']
|
|
|
|
return {'result':dict_values}
|
|
|