469 lines
16 KiB
Python
469 lines
16 KiB
Python
# -*- coding: utf-8 -*-
|
|
# ------------------------------------------------------------
|
|
# Configuration parameters (kodi)
|
|
# ------------------------------------------------------------
|
|
|
|
# from builtins import str
|
|
import sys, os, re, xbmc, xbmcaddon
|
|
PY3 = False
|
|
if sys.version_info[0] >= 3: PY3 = True; unicode = str; unichr = chr; long = int
|
|
|
|
PLUGIN_NAME = "kod"
|
|
|
|
__settings__ = xbmcaddon.Addon(id="plugin.video." + PLUGIN_NAME)
|
|
__language__ = __settings__.getLocalizedString
|
|
__version_fix = None
|
|
__dev_mode = None
|
|
|
|
channels_data = list()
|
|
|
|
def get_addon_core():
|
|
return __settings__
|
|
|
|
|
|
def get_addon_version(with_fix=True):
|
|
'''
|
|
Returns the version number of the addon, and optionally fix number if there is one
|
|
'''
|
|
if with_fix:
|
|
return __settings__.getAddonInfo('version') + " " + get_addon_version_fix()
|
|
else:
|
|
return __settings__.getAddonInfo('version')
|
|
|
|
|
|
def get_addon_version_fix():
|
|
global __version_fix
|
|
ret = __version_fix
|
|
if not ret:
|
|
if not dev_mode():
|
|
try:
|
|
sha = open(os.path.join(get_runtime_path(), 'last_commit.txt')).readline()
|
|
ret = sha[:7]
|
|
except:
|
|
ret = '??'
|
|
else:
|
|
ret = 'DEV'
|
|
return ret
|
|
|
|
|
|
def dev_mode():
|
|
global __dev_mode
|
|
if not __dev_mode:
|
|
__dev_mode = os.path.isdir(get_runtime_path() + '/.git')
|
|
return __dev_mode
|
|
|
|
|
|
def get_platform(full_version=False):
|
|
"""
|
|
Returns the information the version of xbmc or kodi on which the plugin is run
|
|
|
|
@param full_version: indicates if we want all the information or not
|
|
@type full_version: bool
|
|
@rtype: str o dict
|
|
@return: If the full_version parameter is True, a dictionary with the following keys is returned:
|
|
'num_version': (float) version number in XX.X format
|
|
'name_version': (str) key name of each version
|
|
'video_db': (str) name of the file that contains the video database
|
|
'plaform': (str) is made up of "kodi-" or "xbmc-" plus the version name as appropriate.
|
|
If the full_version parameter is False (default) the value of the 'plaform' key from the previous dictionary is returned.
|
|
"""
|
|
|
|
ret = {}
|
|
codename = {"10": "dharma", "11": "eden", "12": "frodo",
|
|
"13": "gotham", "14": "helix", "15": "isengard",
|
|
"16": "jarvis", "17": "krypton", "18": "leia",
|
|
"19": "matrix"}
|
|
code_db = {'10': 'MyVideos37.db', '11': 'MyVideos60.db', '12': 'MyVideos75.db',
|
|
'13': 'MyVideos78.db', '14': 'MyVideos90.db', '15': 'MyVideos93.db',
|
|
'16': 'MyVideos99.db', '17': 'MyVideos107.db', '18': 'MyVideos116.db',
|
|
'19': 'MyVideos116.db'}
|
|
|
|
num_version = xbmc.getInfoLabel('System.BuildVersion')
|
|
num_version = re.match("\d+\.\d+", num_version).group(0)
|
|
ret['name_version'] = codename.get(num_version.split('.')[0], num_version)
|
|
ret['video_db'] = code_db.get(num_version.split('.')[0], "")
|
|
ret['num_version'] = float(num_version)
|
|
if ret['num_version'] < 14:
|
|
ret['platform'] = "xbmc-" + ret['name_version']
|
|
else:
|
|
ret['platform'] = "kodi-" + ret['name_version']
|
|
|
|
if full_version:
|
|
return ret
|
|
else:
|
|
return ret['platform']
|
|
|
|
|
|
def is_xbmc():
|
|
return True
|
|
|
|
|
|
def get_videolibrary_support():
|
|
return True
|
|
|
|
def get_channel_url(findhostMethod=None, name=None):
|
|
from core import jsontools
|
|
import inspect
|
|
|
|
frame = inspect.stack()[1]
|
|
if not name:
|
|
name = os.path.basename(frame[0].f_code.co_filename).replace('.py', '')
|
|
if findhostMethod:
|
|
url = jsontools.get_node_from_file(name, 'url')
|
|
if not url or 'web.archive.org' in url: # per eliminare tutti i webarchive salvati causa bug httptools CF, eliminare in futuro
|
|
url = findhostMethod()
|
|
jsontools.update_node(url, name, 'url')
|
|
return url
|
|
else:
|
|
ROOT_DIR = xbmc.translatePath(__settings__.getAddonInfo('Path'))
|
|
LOCAL_FILE = os.path.join(ROOT_DIR, "channels.json")
|
|
global channels_data
|
|
if not channels_data:
|
|
with open(LOCAL_FILE) as f:
|
|
channels_data = jsontools.load(f.read())
|
|
return channels_data[name]
|
|
|
|
def get_system_platform():
|
|
""" function: to recover the platform that xbmc is running """
|
|
platform = "unknown"
|
|
if xbmc.getCondVisibility("system.platform.linux"):
|
|
platform = "linux"
|
|
elif xbmc.getCondVisibility("system.platform.windows"):
|
|
platform = "windows"
|
|
elif xbmc.getCondVisibility("system.platform.osx"):
|
|
platform = "osx"
|
|
return platform
|
|
|
|
|
|
def is_autorun_enabled():
|
|
try:
|
|
if "xbmc.executebuiltin('RunAddon(plugin.video.kod)')" in open(os.path.join(xbmc.translatePath('special://userdata'),'autoexec.py')).read():
|
|
return True
|
|
else:
|
|
return False
|
|
except:
|
|
# if error in reading from file autoexec doesnt exists
|
|
return False
|
|
|
|
|
|
def enable_disable_autorun(is_enabled):
|
|
# using autoexec.py and not service.py to force autorun
|
|
|
|
path = os.path.join(xbmc.translatePath('special://userdata'),'autoexec.py')
|
|
append_write = 'a' if os.path.exists(path) else 'w'
|
|
|
|
if is_enabled is False:
|
|
with open(path, append_write) as file:
|
|
file.write("import xbmc\nxbmc.executebuiltin('RunAddon(plugin.video.kod)')")
|
|
set_setting('autostart', 'On')
|
|
else:
|
|
file = open(path, "r")
|
|
old_content = file.read()
|
|
new_content = old_content.replace("xbmc.executebuiltin('RunAddon(plugin.video.kod)')", "")
|
|
file.close()
|
|
with open(path, "w") as file:
|
|
file.write(new_content)
|
|
set_setting('autostart', 'Off')
|
|
return True
|
|
|
|
def get_all_settings_addon():
|
|
# Read the settings.xml file and return a dictionary with {id: value}
|
|
from core import scrapertools
|
|
|
|
infile = open(os.path.join(get_data_path(), "settings.xml"), "r")
|
|
data = infile.read()
|
|
infile.close()
|
|
|
|
ret = {}
|
|
matches = scrapertools.find_multiple_matches(data, '<setting id=\"([^\"]+)\"[^>]*>([^<]*)</setting>')
|
|
|
|
for _id, value in matches:
|
|
ret[_id] = get_setting(_id)
|
|
|
|
return ret
|
|
|
|
|
|
def open_settings():
|
|
__settings__.openSettings()
|
|
|
|
|
|
def get_setting(name, channel="", server="", default=None):
|
|
"""
|
|
Returns the configuration value of the requested parameter.
|
|
|
|
Returns the value of the parameter 'name' in the global configuration, in the own configuration of the channel 'channel' or in that of the server 'server'.
|
|
|
|
The channel and server parameters should not be used simultaneously. If the channel name is specified it will be returned
|
|
the result of calling channeltools.get_channel_setting (name, channel, default). If the name of the
|
|
server will return the result of calling servertools.get_channel_setting (name, server, default). If I dont know
|
|
Specify none of the above will return the value of the parameter in the global configuration if it exists or
|
|
the default value otherwise.
|
|
|
|
@param name: parameter name
|
|
@type name: str
|
|
@param channel: channel name
|
|
@type channel: str
|
|
@param server: server name
|
|
@type server: str
|
|
@param default: return value in case the name parameter does not exist
|
|
@type default: any
|
|
|
|
@return: The value of the parameter 'name'
|
|
@rtype: any
|
|
|
|
"""
|
|
|
|
# Specific channel setting
|
|
if channel:
|
|
# logger.log("get_setting reading channel setting '"+name+"' from channel json")
|
|
from core import channeltools
|
|
value = channeltools.get_channel_setting(name, channel, default)
|
|
# logger.log("get_setting -> '"+repr(value)+"'")
|
|
return value
|
|
|
|
# Specific server setting
|
|
elif server:
|
|
# logger.log("get_setting reading server setting '"+name+"' from server json")
|
|
from core import servertools
|
|
value = servertools.get_server_setting(name, server, default)
|
|
# logger.log("get_setting -> '"+repr(value)+"'")
|
|
return value
|
|
|
|
# Global setting
|
|
else:
|
|
# logger.log("get_setting reading main setting '"+name+"'")
|
|
value = __settings__.getSetting(name)
|
|
if not value:
|
|
return default
|
|
# Translate Path if start with "special://"
|
|
if value.startswith("special://") and "videolibrarypath" not in name:
|
|
value = xbmc.translatePath(value)
|
|
|
|
# hack para devolver el tipo correspondiente
|
|
if value == "true":
|
|
return True
|
|
elif value == "false":
|
|
return False
|
|
else:
|
|
# special case return as str
|
|
try:
|
|
value = int(value)
|
|
except ValueError:
|
|
pass
|
|
return value
|
|
|
|
|
|
def set_setting(name, value, channel="", server=""):
|
|
"""
|
|
Sets the configuration value of the indicated parameter.
|
|
|
|
Set 'value' as the value of the parameter 'name' in the global configuration or in the own configuration of the channel 'channel'.
|
|
Returns the changed value or None if the assignment could not be completed.
|
|
|
|
If the name of the channel is specified, search in the path \ addon_data \ plugin.video.kod \ settings_channels the
|
|
channel_data.json file and set the parameter 'name' to the value indicated by 'value'. If the file
|
|
channel_data.json does not exist look in the channels folder for the channel.json file and create a channel_data.json file before modifying the 'name' parameter.
|
|
If the parameter 'name' does not exist, it adds it, with its value, to the corresponding file.
|
|
|
|
|
|
Parameters:
|
|
name - name of the parameter
|
|
value - value of the parameter
|
|
channel [optional] - channel name
|
|
|
|
Returns:
|
|
'value' if the value could be set and None otherwise
|
|
|
|
"""
|
|
if channel:
|
|
from core import channeltools
|
|
return channeltools.set_channel_setting(name, value, channel)
|
|
elif server:
|
|
from core import servertools
|
|
return servertools.set_server_setting(name, value, server)
|
|
else:
|
|
try:
|
|
if isinstance(value, bool):
|
|
if value:
|
|
value = "true"
|
|
else:
|
|
value = "false"
|
|
|
|
elif isinstance(value, (int, long)):
|
|
value = str(value)
|
|
|
|
__settings__.setSetting(name, value)
|
|
|
|
except Exception as ex:
|
|
from platformcode import logger
|
|
logger.error("Error converting '%s' value is not saved \n%s" % (name, ex))
|
|
return None
|
|
|
|
return value
|
|
|
|
|
|
def get_localized_string(code):
|
|
dev = __language__(code)
|
|
|
|
try:
|
|
# Unicode to utf8
|
|
if isinstance(dev, unicode):
|
|
dev = dev.encode("utf8")
|
|
if PY3: dev = dev.decode("utf8")
|
|
|
|
# All encodings to utf8
|
|
elif not PY3 and isinstance(dev, str):
|
|
dev = unicode(dev, "utf8", errors="replace").encode("utf8")
|
|
|
|
# Bytes encodings to utf8
|
|
elif PY3 and isinstance(dev, bytes):
|
|
dev = dev.decode("utf8")
|
|
except:
|
|
pass
|
|
|
|
return dev
|
|
|
|
def get_localized_category(categ):
|
|
categories = {'movie': get_localized_string(30122), 'tvshow': get_localized_string(30123),
|
|
'anime': get_localized_string(30124), 'documentary': get_localized_string(30125),
|
|
'vos': get_localized_string(30136), 'sub-ita': get_localized_string(70566),
|
|
'direct': get_localized_string(30137), 'torrent': get_localized_string(70015),
|
|
'live': get_localized_string(30138), 'music': get_localized_string(30139)
|
|
}
|
|
return categories[categ] if categ in categories else categ
|
|
|
|
|
|
|
|
def get_videolibrary_config_path():
|
|
value = get_setting("videolibrarypath")
|
|
if value == "":
|
|
verify_directories_created()
|
|
value = get_setting("videolibrarypath")
|
|
return value
|
|
|
|
|
|
def get_videolibrary_path():
|
|
return xbmc.translatePath(get_videolibrary_config_path())
|
|
|
|
|
|
def get_temp_file(filename):
|
|
return xbmc.translatePath(os.path.join("special://temp/", filename))
|
|
|
|
|
|
def get_runtime_path():
|
|
return xbmc.translatePath(__settings__.getAddonInfo('Path'))
|
|
|
|
|
|
def get_data_path():
|
|
dev = xbmc.translatePath(__settings__.getAddonInfo('Profile'))
|
|
|
|
# Create the directory if it doesn't exist
|
|
if not os.path.exists(dev):
|
|
os.makedirs(dev)
|
|
|
|
return dev
|
|
|
|
|
|
def get_icon():
|
|
return xbmc.translatePath(__settings__.getAddonInfo('icon'))
|
|
|
|
|
|
def get_fanart():
|
|
return xbmc.translatePath(__settings__.getAddonInfo('fanart'))
|
|
|
|
|
|
def get_cookie_data():
|
|
import os
|
|
ficherocookies = os.path.join(get_data_path(), 'cookies.dat')
|
|
|
|
cookiedatafile = open(ficherocookies, 'r')
|
|
cookiedata = cookiedatafile.read()
|
|
cookiedatafile.close()
|
|
|
|
return cookiedata
|
|
|
|
|
|
# Test if all the required directories are created
|
|
def verify_directories_created():
|
|
from platformcode import logger
|
|
from core import filetools
|
|
from platformcode import xbmc_videolibrary
|
|
|
|
config_paths = [["videolibrarypath", "videolibrary"],
|
|
["downloadpath", "downloads"],
|
|
["downloadlistpath", "downloads/list"],
|
|
["settings_path", "settings_channels"]]
|
|
|
|
for path, default in config_paths:
|
|
saved_path = get_setting(path)
|
|
|
|
# video store
|
|
if path == "videolibrarypath":
|
|
if not saved_path:
|
|
saved_path = xbmc_videolibrary.search_library_path()
|
|
if saved_path:
|
|
set_setting(path, saved_path)
|
|
|
|
if not saved_path:
|
|
saved_path = "special://profile/addon_data/plugin.video." + PLUGIN_NAME + "/" + default
|
|
set_setting(path, saved_path)
|
|
|
|
saved_path = xbmc.translatePath(saved_path)
|
|
if not filetools.exists(saved_path):
|
|
logger.debug("Creating %s: %s" % (path, saved_path))
|
|
filetools.mkdir(saved_path)
|
|
|
|
config_paths = [["folder_movies", "Film"],
|
|
["folder_tvshows", "Serie TV"]]
|
|
|
|
for path, default in config_paths:
|
|
saved_path = get_setting(path)
|
|
|
|
if not saved_path:
|
|
saved_path = default
|
|
set_setting(path, saved_path)
|
|
|
|
content_path = filetools.join(get_videolibrary_path(), saved_path)
|
|
if not filetools.exists(content_path):
|
|
logger.debug("Creating %s: %s" % (path, content_path))
|
|
|
|
# if the directory is created
|
|
filetools.mkdir(content_path)
|
|
|
|
from platformcode import xbmc_videolibrary
|
|
xbmc_videolibrary.update_sources(get_setting("videolibrarypath"))
|
|
xbmc_videolibrary.update_sources(get_setting("downloadpath"))
|
|
|
|
try:
|
|
from core import scrapertools
|
|
# We look for the addon.xml file of the active skin
|
|
skindir = filetools.join(xbmc.translatePath("special://home"), 'addons', xbmc.getSkinDir(), 'addon.xml')
|
|
if not os.path.isdir(skindir): return # No need to show error in log if folder doesn't exist
|
|
# We extract the name of the default resolution folder
|
|
folder = ""
|
|
data = filetools.read(skindir)
|
|
res = scrapertools.find_multiple_matches(data, '(<res .*?>)')
|
|
for r in res:
|
|
if 'default="true"' in r:
|
|
folder = scrapertools.find_single_match(r, 'folder="([^"]+)"')
|
|
break
|
|
|
|
# We check if it exists in the addon and if not, we create it
|
|
default = filetools.join(get_runtime_path(), 'resources', 'skins', 'Default')
|
|
if folder and not filetools.exists(filetools.join(default, folder)):
|
|
filetools.mkdir(filetools.join(default, folder))
|
|
|
|
# We copy the file to said folder from the 720p folder if it does not exist or if the size is different
|
|
if folder and folder != '720p':
|
|
for root, folders, files in filetools.walk(filetools.join(default, '720p')):
|
|
for f in files:
|
|
if not filetools.exists(filetools.join(default, folder, f)) or (filetools.getsize(filetools.join(default, folder, f)) != filetools.getsize(filetools.join(default, '720p', f))):
|
|
filetools.copy(filetools.join(default, '720p', f), filetools.join(default, folder, f), True)
|
|
except:
|
|
import traceback
|
|
logger.error("When checking or creating the resolution folder")
|
|
logger.error(traceback.format_exc())
|
|
|
|
|
|
def get_online_server_thumb(server):
|
|
return "https://raw.github.com/kodiondemand/media/master/resources/servers/" + server.lower() + '.png' |