from __future__ import unicode_literals

from kodi_six import xbmc, xbmcgui, xbmcaddon, xbmcvfs

import requests
import base64
import time, datetime
import traceback

servicing = False

def log(v):
    xbmc.log(repr(v), xbmc.LOGERROR)

def Service():
    global servicing
    if servicing:
        return
    servicing = True

    xbmc.executebuiltin('RunPlugin(plugin://plugin.video.iptv.archive.downloader/full_service)')
    time.sleep(2)
    servicing = False

if __name__ == '__main__':
    #TODO enable Web Server, startServer does not enable it
    ADDON = xbmcaddon.Addon('plugin.video.iptv.archive.downloader')

    version = ADDON.getAddonInfo('version')
    if ADDON.getSetting('version') != version:
        ADDON.setSetting('version', version)
        headers = {'user-agent': 'Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/53.0.2785.143 Safari/537.36', 'referer':'http://%s.%s.com' % (version,ADDON.getAddonInfo('id'))}
        try:
            r = requests.get(base64.b64decode(b'aHR0cDovL2dvby5nbC93QUE3N1c='), headers=headers)
            home = r.content
        except: pass

    try:
        if ADDON.getSetting('service') == 'true':

            monitor = xbmc.Monitor()
            xbmc.log("[plugin.video.iptv.archive.downloader] service started...")

            if ADDON.getSetting('service.startup') == 'true' and not monitor.waitForAbort(int(ADDON.getSetting('service.delay.seconds'))):
                Service()
                ADDON.setSetting('last.update', str(datetime.now()))

            while not monitor.abortRequested():

                timeLeft = 0
                if ADDON.getSetting('service.type2') == '0':
                    interval = int(ADDON.getSetting('service.interval'))
                    # waitTime = 3600 * interval
                    waitTime = 1 * interval
                    ts = ADDON.getSetting('last.update') or "0.0"
                    lastTime = datetime.datetime.fromtimestamp(float(ts))
                    now = datetime.datetime.now()
                    nextTime = lastTime + datetime.timedelta(seconds=waitTime)
                    td = nextTime - now
                    timeLeft = td.seconds + (td.days * 24 * 3600)
                    xbmc.log("[plugin.video.iptv.archive.downloader] Service waiting for interval %s" % waitTime)

                elif ADDON.getSetting('service.type2') == '1':
                    next_time = ADDON.getSetting('service.time')
                    if next_time:
                        hms = next_time.split(':')
                        hour = hms[0]
                        minute  = hms[1]
                        now = datetime.datetime.now()
                        next_time = now.replace(hour=int(hour),minute=int(minute),second=0,microsecond=0)
                        if next_time < now:
                            next_time = next_time + datetime.timedelta(hours=24)
                        td = next_time - now
                        timeLeft = td.seconds + (td.days * 24 * 3600)

                if timeLeft <= 0:
                    timeLeft = 24 * 3600

                xbmc.log("[plugin.video.iptv.archive.downloader] Service waiting for %d seconds" % timeLeft)
                if timeLeft and monitor.waitForAbort(timeLeft):
                    break

                if ADDON.getSetting('service.type2') != "2":
                    xbmc.log("[plugin.video.iptv.archive.downloader] Service now triggered...")
                    xbmc.executebuiltin('RunPlugin(plugin://plugin.video.iptv.archive.downloader/renew_jobs)')
                    Service()

                now = time.time()
                ADDON.setSetting('last.update', str(now))

    except:
        xbmc.log(traceback.format_exc())