# -*- coding: utf-8 -*-

import sys

if sys.version_info[0] < 3:
    basestring = basestring
else:
    basestring = str


import os, time, glob

from platformcode import config, logger, platformtools
from core.item import Item
from core import filetools, jsontools

STATUS_CODES = type("StatusCode", (), {"stopped": 0, "canceled": 1, "completed": 2, "error": 3})

color_alert = config.get_setting('notification_alert_color', default='red')
color_infor = config.get_setting('notification_infor_color', default='pink')
color_adver = config.get_setting('notification_adver_color', default='violet')
color_avis = config.get_setting('notification_avis_color', default='yellow')
color_exec = config.get_setting('notification_exec_color', default='cyan')


# ~ Ruta descargas
download_path = config.get_setting('downloadpath', default='')
if not download_path:
    download_path = filetools.join(config.get_data_path(), 'downloads')

if not filetools.exists(download_path):
    filetools.mkdir(download_path)


def mainlist(item):
    logger.info()
    itemlist = []

    item.category = 'Descargas'

    itemlist.append(item.clone( title = '[B]DESCARGAS:[/B]', action = '', text_color='seagreen' ))

    itemlist.append(item.clone( action='show_infos', title='[COLOR fuchsia][B]Cuestiones Preliminares[/B][/COLOR]', thumbnail=config.get_thumb('news') ))

    elem = 0

    if download_path.startswith('smb://'):
        fichs = sorted(filetools.listdir(download_path))
        ficheros = [filetools.join(download_path, fit) for fit in fichs if fit.endswith('.json')]
    else:
        path = filetools.join(download_path, '*.json')
        ficheros = glob.glob(path)
        ficheros.sort(key=os.path.getmtime, reverse=False)

    for down_path in ficheros:
        # ~ it = Item().fromjson(path=down_path) # falla con smb://
        it = Item().fromjson(filetools.read(down_path))

        it.from_channel = it.channel
        it.from_action = it.action
        it.channel = item.channel
        it.action = 'acciones_enlace'
        it.jsonfile = down_path
        it.folder = False

        if it.downloadStatus == STATUS_CODES.completed:
            it.title = '[COLOR gold][B][Ok][/B] %s [%s][/COLOR]' % (it.downloadFilename, config.format_bytes(it.downloadSize))

        elif it.downloadStatus == STATUS_CODES.canceled:
            it.title = '[COLOR red][B][%s%%][/B] %s [%s de %s][/COLOR]' % (int(it.downloadProgress), it.downloadFilename, config.format_bytes(it.downloadCompleted), config.format_bytes(it.downloadSize))

        elif it.downloadStatus == STATUS_CODES.error:
            it.title = '[COLOR gray][B][I][Error][/B][/I] %s[/COLOR]' % it.downloadFilename

        else:
            it.title = '[COLOR yellow][I][B][???][/B][/I] %s[/COLOR]' % it.downloadFilename

        elem += 1

        itemlist.append(it)

    if elem == 0:
        platformtools.dialog_notification(config.__addon_name, '[COLOR %s][B]Aún no tiene Descargas[/B][/COLOR]' % color_exec)

        try:
           filetools.rmdirtree(download_path)
        except:
           pass

        # ~ por si varió el path y quedaron descargas huerfanas en el path default
        if download_path:
           try:
              path = filetools.join(config.get_data_path(), 'downloads')
              filetools.rmdirtree(path)
           except:
              pass

    if not elem == 0:
        itemlist.append(item.clone( channel='actions', title = '[COLOR red][B]Eliminar[/B][/COLOR] Todas las Descargas', action = 'manto_folder_downloads', thumbnail=config.get_thumb('downloads') ))

    itemlist.append(item.clone( channel='actions', action = 'open_settings', title= '[COLOR chocolate][B]Ajustes[/B][/COLOR] categoría [COLOR seagreen][B]Descargas[/B][/COLOR]', thumbnail=config.get_thumb('settings') ))

    platformtools.itemlist_refresh()

    return itemlist


def show_infos(item):
    logger.info()
    itemlist = []

    itemlist.append(item.clone( action='', title='[COLOR fuchsia][B]DESCARGAS Cuestiones Prelininares:[/B][/COLOR]', thumbnail=config.get_thumb('news') ))

    itemlist.append(item.clone( title = ' - [B]Ubicación actual de las[/B] [COLOR seagreen][B]Descargas[/B][/COLOR]', action = 'show_folder_downloads', thumbnail=config.get_thumb('downloads') ))

    itemlist.append(item.clone( channel='helper', title = ' - [COLOR green][B]Información[/B][/COLOR] ¿ Cómo funcionan ?', action = 'show_help_descargas', thumbnail=config.get_thumb('news') ))

    itemlist.append(item.clone( channel='helper', action = 'show_help_usb', title = ' - ¿ [B]Se puede Descargar directamente en una[/B] [COLOR goldenrod][B]Unidad USB[/B][/COLOR] ?', thumbnail=config.get_thumb('usb') ))

    itemlist.append(item.clone( channel='helper', action='show_not_download', title= ' - ¿ Qué [COLOR goldenrod][B]NO[/B][/COLOR] está contemplado en las [COLOR seagreen][B]Descargas[/B][/COLOR] ?', thumbnail=config.get_thumb('roadblock') ))

    return itemlist


def show_folder_downloads(item):
    logger.info()

    downloadpath = config.get_setting('downloadpath', default='')

    if downloadpath:
        path = downloadpath
    else:
        path = os.path.join(config.get_data_path(), 'downloads')

    txt = 'Carpeta de descargas (por defecto [COLOR chocolate][B].../addon_data.../downloads[/B][/COLOR])[CR][CR]'

    txt += path

    platformtools.dialog_textviewer('Ubicación de las Descargas', txt)


def acciones_enlace(item):
    logger.info()

    item.__dict__['channel'] = item.__dict__.pop('from_channel')
    item.__dict__['action'] = item.__dict__.pop('from_action')

    if item.downloadStatus == STATUS_CODES.completed:
        acciones = ['Reproducir vídeo', 'Eliminar descarga', 'Guardar una copia en ...']

    elif item.downloadStatus == STATUS_CODES.canceled:
        acciones = ['Continuar descarga', 'Eliminar descarga']

    # ~ elif item.downloadStatus == STATUS_CODES.error:
    else:
        acciones = ['Eliminar descarga']

    ret = platformtools.dialog_select('¿Qué hacer con esta descarga?', acciones)
    if ret == -1: 
        return False

    elif acciones[ret] == 'Eliminar descarga':
        if not platformtools.dialog_yesno('Eliminar descarga', '¿ [COLOR red][B]Confirma Eliminar la descarga[/B][/COLOR] %s ?' % item.title, 'Se eliminará el fichero %s y su json con la información.' % item.downloadFilename): 
            return False

        path_video = filetools.join(download_path, item.downloadFilename)
        if item.downloadFilename and filetools.exists(path_video):
            filetools.remove(path_video)

        if item.jsonfile and filetools.exists(item.jsonfile):
            filetools.remove(item.jsonfile)

        platformtools.itemlist_refresh()
        return True

    elif acciones[ret] == 'Continuar descarga':
        item.__dict__.pop('jsonfile')
        server_item = Item().fromjson(item.__dict__.pop('server_item'))
        return download_video(server_item, item)

    elif acciones[ret] == 'Reproducir vídeo':
        import xbmcgui, xbmc
        mediaurl = filetools.join(download_path, item.downloadFilename)

        xlistitem = xbmcgui.ListItem(path=mediaurl)
        platformtools.set_infolabels(xlistitem, item, True)

        # ~ se lanza el reproductor (no funciona si el play es desde el diálogo info !?)
        playlist = xbmc.PlayList(xbmc.PLAYLIST_VIDEO)
        playlist.clear()
        playlist.add(mediaurl, xlistitem)
        xbmc.Player().play(playlist, xlistitem)
        return True

    elif acciones[ret] == 'Guardar una copia en ...':
        import xbmcgui
        destino_path = xbmcgui.Dialog().browseSingle(3, 'Seleccionar la carpeta dónde copiar', 'files', '', False, False, '')
        if not destino_path: return False
        origen = filetools.join(download_path, item.downloadFilename)
        destino = filetools.join(destino_path, item.downloadFilename)
        if not filetools.copy(origen, destino, silent=False):
            platformtools.dialog_ok(config.__addon_name, 'Error, no se ha podido copiar el fichero', origen, destino)
            return False
        platformtools.dialog_notification('Fichero copiado', destino_path)
        return True


# ~ Llamada desde menú contextual para una peli/episodio (parecido a platformtools.play_from_itemlist)
def save_download(item):
    logger.info()

    notification_d_ok = config.get_setting('notification_d_ok', default=True)

    # ~ Si se llega aquí mediante el menú contextual, hay que recuperar los parámetros action y channel
    if item.from_action: item.__dict__["action"] = item.__dict__.pop("from_action")
    if item.from_channel: item.__dict__["channel"] = item.__dict__.pop("from_channel")

    try:
        if item.action == 'findvideos':
            if item.channel == 'tracking': canal = __import__('modules.' + item.channel, fromlist=[''])
            else: canal = __import__('channels.' + item.channel, fromlist=[''])
            itemlist = canal.findvideos(item)

            # ~ Para algunos servers (ej: gamovideo) se necesita la url para usar como referer
            if item.channel == 'tracking' and len(itemlist) > 0: item.url = itemlist[0].parent_item_url

            # ~ Reordenar/Filtrar enlaces
            # ~ aunque por ahora no se usan action != 'play' en los findvideos
            itemlist = filter(lambda it: it.action == 'play', itemlist)

            from core import servertools
            itemlist = servertools.filter_and_sort_by_quality(itemlist)
            itemlist = servertools.filter_and_sort_by_server(itemlist)
            itemlist = servertools.filter_and_sort_by_language(itemlist)

            if len(itemlist) == 0:
                if notification_d_ok:
                    platformtools.dialog_ok(config.__addon_name, 'Sin enlaces disponibles')
                else:
                    platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Sin enlaces disponibles[/COLOR][/B]' % color_exec)

            itemlist = platformtools.formatear_enlaces_servidores(itemlist)

            import xbmc
            erroneos = []

            # ~ Bucle hasta cancelar o descargar
            while not xbmc.Monitor().abortRequested():
                opciones = []
                for i, it in enumerate(itemlist):
                    if i in erroneos:
                        opciones.append('[I][COLOR gray]%s[/COLOR][/I]' % config.quitar_colores(it.title))
                    else:
                        opciones.append(it.title)

                seleccion = platformtools.dialog_select('[COLOR seagreen]Descargas[/COLOR] disponibles en [COLOR yellow]%s[/COLOR]' % itemlist[0].channel.capitalize(), opciones)

                if seleccion == -1:
                    # ~ platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Descarga cancelada[/B]' % color_infor)
                    break
                else:
                    # ~ Si el canal tiene play propio
                    canal_play = __import__('channels.' + itemlist[seleccion].channel, fromlist=[''])

                    if hasattr(canal_play, 'play'):
                        itemlist_play = canal_play.play(itemlist[seleccion])

                        if len(itemlist_play) > 0 and isinstance(itemlist_play[0], Item):
                            ok_play = download_video(itemlist_play[0], item)

                        elif len(itemlist_play) > 0 and isinstance(itemlist_play[0], list):
                            itemlist[seleccion].video_urls = itemlist_play
                            ok_play = download_video(itemlist[seleccion], item)

                        elif isinstance(itemlist_play, basestring):
                            ok_play = False
                            if notification_d_ok:
                                platformtools.dialog_ok(config.__addon_name, itemlist_play)
                            else:
                                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]No se Pudo descargar[/COLOR][/B]' % color_exec)
                        else:
                            ok_play = False
                            if notification_d_ok:
                                platformtools.dialog_ok(config.__addon_name, 'No se puede descargar')
                            else:
                                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]No se Pudo Descargar2[/COLOR][/B]' % color_exec)

                    else:
                        ok_play = download_video(itemlist[seleccion], item)

                    if ok_play: break
                    else: erroneos.append(seleccion)

        else:
            if notification_d_ok:
                platformtools.dialog_ok(config.__addon_name, 'Nada a descargar')
            else:
                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Nada a descargar[/COLOR][/B]' % color_exec)

    except:
        import traceback
        logger.error(traceback.format_exc())

        if notification_d_ok:
            platformtools.dialog_ok(config.__addon_name, 'Error al descargar')
        else:
            platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Error al descargar[/COLOR][/B]' % color_alert)


# ~ (parecido a platformtools.play_video pero para descargar)
def download_video(item, parent_item):
    logger.info(item)
    logger.info(parent_item)

    platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Descarga en preparación[/COLOR][/B]' % color_exec)

    notification_d_ok = config.get_setting('notification_d_ok', default=True)

    if item.video_urls:
        video_urls, puedes, motivo = item.video_urls, True, ""
    else:
        from core import servertools
        url_referer = item.url_referer if item.url_referer else parent_item.url
        video_urls, puedes, motivo = servertools.resolve_video_urls_for_playing(item.server, item.url, url_referer=url_referer)

    if len(video_urls) == 1:
        if '.rar' in video_urls[0][0] or '.zip' in video_urls[0][0]:
            puedes = False
            motivo = '[COLOR crimson][B]Está en formato Comprimido[/B][/COLOR]'

    if not puedes:
        platformtools.dialog_ok("No puedes descargar este vídeo porque ...", motivo, item.url)
        return False

    opciones = []

    for video_url in video_urls:
        if '[/B]' in str(video_url):
           opciones.append('[COLOR seagreen]Descargar[COLOR moccasin] el vídeo en [B]' + video_url[0] + '[/COLOR]')
        else:
           opciones.append('[COLOR seagreen]Descargar[COLOR moccasin] el vídeo en [B]' + video_url[0] + '[/B][/COLOR]')

    # ~ Si hay varias opciones dar a elegir, si sólo hay una reproducir directamente
    if len(opciones) > 1:
        seleccion = platformtools.dialog_select("Seleccione una opción para [B][COLOR seagreen]" + item.server.capitalize() + '[/B][/COLOR]', opciones)
    else:
        seleccion = 0

    if seleccion == -1:
        return True
    else:
        mediaurl, view, mpd = platformtools.get_video_seleccionado(item, seleccion, video_urls)
        if mediaurl == '':
            platformtools.dialog_ok(config.__addon_name, 'No se encuentra el vídeo')
            return False

        if mediaurl.endswith('.m3u8') or '.m3u8?' in mediaurl or 'm3u8' in video_urls[seleccion][0].lower():
            if notification_d_ok:
                platformtools.dialog_ok(config.__addon_name, 'Los archivos M3u8 no están permitidos, no se descargan')
            else:
                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Archivo M3u8 no permitido[/COLOR][/B]' % color_alert)
            return False

        if mpd:
            if notification_d_ok:
                platformtools.dialog_ok(config.__addon_name, 'Los archivos Mpd no están permitidos, no se descargan')
            else:
                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Archivo Mpd no permitido[/COLOR][/B]' % color_alert)
            return False

        if mediaurl.startswith('rtmp'):
            if notification_d_ok:
                platformtools.dialog_ok(config.__addon_name, 'Los archivos Rtmp no está permitidos, no se descargan')
            else:
                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Archivo Rtmp no permitido[/COLOR][/B]' % color_alert)
            return False

        if item.server == 'torrent':
            if notification_d_ok:
                platformtools.dialog_ok(config.__addon_name, 'Los archivos Torrent no están permitidos, no se descargan')
            else:
                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Archivo Torrent no permitido[/COLOR][/B]' % color_alert)
            return False

        if item.server == 'youtube':
            if notification_d_ok:
                platformtools.dialog_ok(config.__addon_name, 'Los Vídeos de Youtube no están permitidos, no se descargan')
            else:
                platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]Vídeo Youtube no permitido[/COLOR][/B]' % color_alert)
            return False

        if parent_item.contentType == 'movie':
            # ~ config.text_clean(...)
            file_name = '%s' % parent_item.contentTitle
        else:
            try:
               nro_season = int(parent_item.contentSeason)
            except:
               logger.error("Verificar Número Temporada: %s" % str(parent_item.contentSeason))
               nro_season = ''

            if not nro_season: nro_season = '00'
            else:
               num_season = str(nro_season)
               if len(num_season) == 1: nro_season = '0' + num_season

            nro_epis = str(parent_item.contentEpisodeNumber)

            if 'Capitulo' in nro_epis: nro_epis = nro_epis.replace('Capitulo', '').strip()
            elif 'Capítulo' in nro_epis: nro_epis = nro_epis.replace('Capítulo', '').strip()

            elif 'capitulo' in nro_epis: nro_epis = nro_epis.replace('capitulo', '').strip()
            elif 'capítulo' in nro_epis: nro_epis = nro_epis.replace('capítulo', '').strip()

            elif 'Episodio' in nro_epis: nro_epis = nro_epis.replace('Episodio', '').strip()
            elif 'episodio' in nro_epis: nro_epis = nro_epis.replace('episodio', '').strip()

            elif 'Episode' in nro_epis: nro_epis = nro_epis.replace('Episode', '').strip()
            elif 'episode' in nro_epis: nro_epis = nro_epis.replace('episode', '').strip()

            if '-' in nro_epis: nro_epis = nro_epis.replace('-', '').strip()

            try:
               nro_epis = int(nro_epis)
            except:
               logger.error("Verificar Número Episodio: %s" % str(parent_item.contentEpisodeNumber))
               nro_epis = ''

            if not nro_epis: nro_epis = '00'
            else:
               num_epis = str(nro_epis)
               if len(num_epis) == 1: nro_epis = '0' + num_epis

            # ~ 6/1/25
            # ~ file_name = '%s - S%02dE%02d' % (parent_item.contentSerieName, int(parent_item.contentSeason), int(num_epis))
            file_name = '%s - S%02dE%02d' % (parent_item.contentSerieName, int(nro_season), int(nro_epis))

        ch_name = parent_item.channel if parent_item.channel != 'tracking' else item.channel
        file_name += ' [%s][%s]' % (ch_name, item.server)

        return do_download(mediaurl, file_name, parent_item, item)


def do_download(mediaurl, file_name, parent_item, server_item):
    from core import downloadtools

    download_path = config.get_setting('downloadpath', default='')

    if not download_path:
        download_path = filetools.join(config.get_data_path(), 'downloads')

    if not filetools.exists(download_path):
        filetools.mkdir(download_path)

    if config.get_setting('conf_ubicacion', default=True):
        if not download_path:
            download_path = filetools.join(config.get_data_path(), 'downloads')

        la_ubicacion = ('[B][COLOR %s]' + download_path) % color_infor

        show_folder_downloads(parent_item)

        if not platformtools.dialog_yesno(config.__addon_name, '¿ Confirma la ubicación de la [COLOR seagreen]Descarga[/COLOR] ?', la_ubicacion + '[/COLOR][/B]'): 
            from modules import actions

            actions.open_settings(parent_item)

            download_path = config.get_setting('downloadpath', default='')
            if not download_path:
                download_path = filetools.join(config.get_data_path(), 'downloads')

            if not filetools.exists(download_path):
                filetools.mkdir(download_path)

        if not platformtools.dialog_yesno(config.__addon_name, '[B][COLOR %s]¿ Desea que se le siga formulando la pregunta respecto a confirmar la ubicación?[/COLOR][/B]' % color_exec): 
            config.set_setting('conf_ubicacion', False)

    # ~ Limpiar caracteres para nombre de fichero válido
    file_name = config.text_clean(file_name)

    # ~ Guardar info del vídeo en json
    path_down_json = filetools.join(download_path, file_name + '.json')

    # ~ Guardar info del server por si hay que continuar la descarga
    parent_item.server_item = server_item.tojson()
    write_download_json(path_down_json, parent_item)

    # ~ Lanzamos la descarga
    down_stats = downloadtools.do_download(mediaurl, download_path, file_name)

    # ~ Actualizar info de la descarga en json
    update_download_json(path_down_json, down_stats)

    if down_stats['downloadStatus'] == STATUS_CODES.error:
        platformtools.dialog_notification(config.__addon_name, '[B][COLOR %s]No se pudo descargar[/COLOR][/B]' % color_alert)
        return False
    else:
        if down_stats['downloadStatus'] == STATUS_CODES.completed:
            platformtools.dialog_ok(config.__addon_name + ' Descargas', '[COLOR cyan][B]Descarga Finalizada[/B][/COLOR]', '[COLOR yellow][B]' + file_name + '[/B][/COLOR]', config.format_bytes(down_stats['downloadSize']))

        platformtools.itemlist_refresh()
        return True


def write_download_json(path, item):
    if item.__dict__.__contains__('context'): item.__dict__.pop('context')
    item.downloadStatus = STATUS_CODES.stopped
    item.downloadProgress = 0
    item.downloadSize = 0
    item.downloadCompleted = 0

    filetools.write(path, item.tojson())
    time.sleep(0.1)

def update_download_json(path, params):
    item = Item().fromjson(filetools.read(path))
    item.__dict__.update(params)
    filetools.write(path, item.tojson())

