pielikti add

addon.py

@@ -0,0 +1,340 @@
+# -*- coding: utf-8 -*-
+try:
+    import wingdbstub
+except:
+    pass
+#try:
+#    import ptvsd
+#    ptvsd.enable_attach("debug")
+#    ptvsd.wait_for_attach()
+#except:
+#    pass
+import os,os.path,sys, glob, shutil, re
+import urllib, traceback
+try:
+    import cPickle as pickle
+except:
+    import pickle
+import pickle,  threading
+from kodiswift import Plugin, ListItem, storage
+from kodiswift import xbmc, xbmcgui, xbmcplugin, xbmcvfs, xbmcaddon, CLI_MODE
+from resources.lib.content import ContentSources, util
+#from downloadqueue import DownloadQueue
+
+cur_directory = os.path.dirname(__file__)
+icon_folder = os.path.join(cur_directory, "resources", "picons")
+icong_url =  xbmcaddon.Addon().getAddonInfo("path") + "/resources/picons/"
+sys.path.insert(0, os.path.join(os.path.dirname(os.path.abspath(__file__)),"resources","lib", "content", "sources"))
+
+plugin = Plugin()
+prefix = "plugin://%s/" % plugin.id
+#plugin.load_addon_settings()
+use_storage = plugin.get_setting("general_use_storage",bool) # TODO vajag nočekot vai nav labāk lietot pickle
+storage_ttl = plugin.get_setting("general_ttl",int)
+use_proxy = plugin.get_setting("general_proxy_use",bool)
+proxy_url = plugin.get_setting("general_proxy_url",str)
+playlist = plugin.get_setting("general_playlist",str)
+download_dir = plugin.get_setting("general_download_dir",str)
+view_mode = plugin.get_setting("general_view_mode",str)
+streams_file = plugin.get_setting("general_streams_file",str)
+streams_file_remote = plugin.get_setting("general_streams_file_remote",str)
+use_streams_file_remote = plugin.get_setting("general_use_streams_file_remote",bool)
+download_overwrite = plugin.get_setting("general_download_overwrite",bool)
+
+
+#storage_path = os.path.join(plugin.storage_path,"sources.p")
+if use_storage:
+    try:
+        storage = plugin.get_storage("playstream","pickle",ttl=30)
+    except Exception as e:
+        os.remove(os.path.join(plugin.storage_path, "playstream"))
+        try:
+            storage = plugin.get_storage("playstream", "pickle", ttl=30)
+        except Exception as e:
+            print "[playstream] error opening storage", plugin.storage_path
+            print "Got Exception: ", str(e)
+            import traceback
+            traceback.print_exc()
+            plugin.notify("Error opening permament storage", "Info", 10000, xbmcgui.NOTIFICATION_INFO)
+            storage = None
+            os.remove(os.path.join(plugin.storage_path, "playstream"))
+cur_directory = os.path.dirname(__file__)
+sources_directory = os.path.join(cur_directory,"resources","lib", "content", "sources")
+cfg_list = glob.glob(os.path.join(sources_directory,"*.cfg"))
+for cf in cfg_list:
+    cf2 = os.path.join(plugin.storage_path,os.path.split(cf)[1])
+    if not os.path.exists(cf2):
+        shutil.copyfile(cf,cf2)
+
+if use_storage and storage is not None and "sources" in storage:
+    print "[playstream] Restore sources from storage"
+    sources = storage["sources"]
+# if use_storage and os.path.exists(storage_path): #"sources" in storage:
+    #sources = pickle.load(open(storage_path,"rb"))
+else:
+    print "[playstream] Create sources objects"
+    if use_streams_file_remote:
+        try:
+            sources = ContentSources.ContentSources(sources_directory, streams_file_remote)
+        except Exception as e:
+            try:
+                sources = ContentSources.ContentSources(sources_directory, streams_file)
+                plugin.notify("Remote streams file is not available, fallback to local")
+            except Exception as e:
+                plugin.notify(e.message)
+    else:
+        try:
+            sources = ContentSources.ContentSources(sources_directory, streams_file)
+        except Exception as e:
+            plugin.notify(e.message)
+
+for source in sources.plugins:
+    if not ("options" in dir(sources.plugins[source]) and sources.plugins[source].options): continue
+    options = sources.plugins[source].options
+    if not options: continue
+    for option in options:
+        key="%s_%s"%(source,option)
+        if key in ("viaplay_device"): continue # exception list,
+        value = plugin.get_setting(key)
+        options[option] = value
+    sources.plugins[source].options_write(options)
+
+
+
+@plugin.route(".+" )
+def main():
+    global prefix
+    plugin.set_content("movies")
+    data = plugin.request.url.replace(prefix,"")
+    data = urllib.unquote(data)
+    sources.plugins["config"].read_streams()
+    if not data:
+        data = u"config::home"
+    print "[playstream] processing data=%s"%data
+
+
+    if sources.is_video(data):
+        try:
+            streams = sources.get_streams(data)
+        except Exception,e:
+            #xbmcgui.Dialog().ok("Error",unicode(e))
+            plugin.notify(unicode(e),"Error",10000, xbmcgui.NOTIFICATION_ERROR)
+            traceback.print_exc()
+            return plugin.set_resolved_url(None)
+        if streams:
+            return play_video(streams)
+        else:
+            plugin.notify("No streams found!","Error",10000,xbmcgui.NOTIFICATION_ERROR)
+            return plugin.set_resolved_url(None)
+    else:
+        if "{0}" in data:
+            q = plugin.keyboard(default=None, heading="Search for", hidden=False)
+            if isinstance(q,str):
+                q = q.decode("utf8")
+            if isinstance(data,str):
+                data = data.decode("utf8")
+            data = data.format(q)
+        try:
+            items = get_list(data)
+        except Exception,e:
+            plugin.notify(unicode(e),"Error",10000,xbmcgui.NOTIFICATION_ERROR)
+            traceback.print_exc()
+            return []
+        if use_storage and storage is not None:
+            print "[playstream] Save sources to storage"
+            storage["sources"] = sources
+            storage.sync()
+        return plugin.finish(items, view_mode=get_view_mode(view_mode), update_listing=False, cache_to_disc=False)
+
+def get_list(data):
+    if isinstance(data,unicode):
+        data = data.encode("utf8")
+    content = sources.get_content(data)
+    print "[playstream] %s items returned"%len(content)
+    items = []
+    i = 1
+    for item in content:
+        if item[1] == "back": continue
+        title = item[0].decode("utf8") if isinstance(item[0],str) else item[0]
+        data2 = item[1].decode("utf8") if isinstance(item[1],str) else item[1]
+        data2 = urllib.quote(data2, ":/")
+        is_playable = True if  sources.is_video(item[1]) else False
+        img = item[2].decode("utf8") if isinstance(item[2],str) else item[2]
+        desc = item[3].decode("utf8") if isinstance(item[3],str) else item[3]
+        #print title.encode("utf8"),data2,img
+        context_menu = [
+            #("Add to PlayStream playlist",
+            # u'RunScript(special://home/addons/%s/context_menu.py,"playlist","%s","%s","%s","%s")' % (
+            #     plugin.id, title, data2, playlist, proxy_url)),
+            ("Add to PlayStream favorites",
+                u'RunScript(special://home/addons/%s/context_menu.py,"add","%s","%s","%s","%s")'%(
+                plugin.id, title,  data2 ,img, desc)),
+            ]
+        if data.startswith("config::"):
+            lst = data.split("::")[1]
+            context_menu.extend([
+            ("Delete from PlayStream favorites",
+                u'RunScript(special://home/addons/%s/context_menu.py,"delete","%s","%s")' % (
+                plugin.id, lst, i)),
+            ("Move in PlayStream favorites",
+                u'RunScript(special://home/addons/%s/context_menu.py,"move","%s","%s")' % (
+                plugin.id, lst, i)),
+            ])
+        context_menu.extend([
+            # "ActivateWindow(<window-id>,'plugin://<plugin-id>/<parameter-optional>',return)"
+            ("* Download jobs list *",
+                 u'RunScript(special://home/addons/%s/queue_management.py,"%s","list")' % (plugin.id, plugin.handle)),
+            #("* Download jobs list *", u'ActivateWindow(10025,"plugin://plugin.video.playstream/downloads::list")'),  #plugin.id
+            #("Active download jobs", u'RunPlugin(plugin://plugin.video.playstream/downloads::list)'),  #plugin.id
+        ])
+        if is_playable:
+            context_menu.extend([
+                ("Download video to default folder",
+                 u'RunScript(special://home/addons/%s/context_download.py,"download","%s","%s","%s")' % (
+                 plugin.id, title, data2, download_dir)),
+                ("Download video, ask folder",
+                 u'RunScript(special://home/addons/%s/context_download.py,"download2","%s","%s","%s")' % (
+                 plugin.id, title, data2, download_dir)),
+                ("Download video to subfolder, ask parent folder",
+                 u'RunScript(special://home/addons/%s/context_download.py,"download3","%s","%s","%s")' % (
+                 plugin.id, title, data2, download_dir)),
+            ])
+        else:
+            context_menu.extend([
+                ("Download list to default folder",
+                 u'RunScript(special://home/addons/%s/context_download.py,"download","%s","%s","%s")' % (
+                 plugin.id, title, data2, download_dir)),
+                ("Download list, ask folder",
+                 u'RunScript(special://home/addons/%s/context_download.py,"download2","%s","%s","%s")' % (
+                 plugin.id, title, data2, download_dir)),
+            ])
+
+        item     = {
+            "label": title,
+            "path": prefix+data2,
+            "thumbnail":thumb_data(img, is_playable),
+            #"poster":thumb_data(img, is_playable) ,
+            "icon":thumb_data(img, is_playable) ,
+            "info":{"plot":desc},
+            "is_playable":is_playable,
+            "context_menu": context_menu,
+        }
+        if view_mode == "Poster":
+            item["poster"] = thumb_data(img, is_playable)
+        items.append(item)
+        i += 1
+    return items
+
+def play_video(streams):
+    if len(streams)>1:
+        slist = []
+        for s in streams:
+            slist.append("%s [%s,%s]"%(s["name"],s["quality"],s["lang"]))
+        res = xbmcgui.Dialog().select("Select stream",slist, useDetails=True) if not CLI_MODE else 0
+        #res = xbmcgui.Dialog().contextmenu(slist) if not CLI_MODE else 0
+        stream = streams[res]
+    else:
+        stream = streams[0]
+    subfiles = []
+    #stream = util.stream_chamge(stream)
+    if use_proxy:
+        if "resolver" in stream and stream["resolver"] in ("hqq","filmas") or \
+            "surl" in stream and re.search(r"http*://(hqq|goo\.gl)",stream["surl"]) or \
+            "lattelecom.tv/mobile-vod/" in stream["url"]: # TODO
+            #re.search(r"http*://.+?lattelecom\.tv/.+?auth_token=[^=]+=", stream["url"]):
+            stream["url"] = util.streamproxy_encode(stream["url"],stream["headers"],proxy_url)
+            stream["headers"] = {}
+    if stream["headers"]:
+        hh = []
+        for k in stream["headers"]:
+            h = "%s=%s"%(k,urllib.quote(stream["headers"][k]))
+            hh.append(h)
+        hh = "&".join(hh)
+        stream["url"] = stream["url"] +"|"+hh
+    print "[playstream] play_video ", stream["url"]
+    if "subs" in stream and stream["subs"]:
+        for sub in stream["subs"]:
+            suburl = sub["url"]
+            subs = util.Captions(suburl)
+            srt = subs.get_srt()
+            #subfile = plugin.temp_fn("subtitles.srt")
+            subfile = os.path.join(os.path.dirname(__file__),sub["lang"]+".srt")
+            f = open(subfile, "w")
+            f.write(srt)
+            f.close()
+            subfiles.append(subfile)
+    item = ListItem(label=stream["name"], thumbnail=thumb_data(stream["img"], True), path=stream["url"])
+    item.set_info("video",{"plot":stream["desc"]})
+    item.set_is_playable(True)
+    return plugin.set_resolved_url(item,subfiles)
+    #return plugin.play_video(item)
+
+def thumb_data(img, video=False):
+    default = "video.png" if video else "folder.png"
+    if img in ("default", ""):
+        img = default
+    if not img.startswith("http"):
+        img = icong_url + img
+    return img
+
+def get_view_mode(vm):
+    modes = {
+        "skin.estuary": {
+            "None": None,
+            "List": 50,
+            "Poster": 51,
+            "IconWall":52 ,
+            "Shift": 53,
+            "InfoWall": 54,
+            "WideList": 55,
+            "Wall": 500,
+            "Banner": 501,
+            "FanArt": 502
+        },
+        "skin.estuary.is": {
+            "None": None,
+            "List": 50,
+            "Poster": 51,
+            "IconWall":52 ,
+            "Shift": 53,
+            "InfoWall": 54,
+            "WideList": 55,
+            "Wall": 500,
+            "Banner": 501,
+            "FanArt": 502
+        },
+            "skin.estuary.isl": {
+            "None": None,
+            "List": 50,
+            "Poster": 51,
+            "IconWall":52 ,
+            "Shift": 53,
+            "InfoWall": 54,
+            "WideList": 55,
+            "Wall": 500,
+            "Banner": 501,
+            "FanArt": 502
+        },
+
+    }
+    skin = xbmc.getSkinDir()
+    if skin in modes and vm in modes[skin]:
+        view_mode = modes[skin][vm]
+    else:
+        view_mode = 50
+    return view_mode
+
+
+
+if __name__ == '__main__':
+    if CLI_MODE:
+        from kodiswift.cli.cli import main as start
+        start()
+    else:
+        plugin.run()
+        if use_storage and storage is not None:
+            print "[playstream] Save sources to storage"
+            storage["sources"] = sources
+            storage.sync()
+            print "Save sources to storage"
+            #pickle.dump(sources,open(storage_path,"wb"),pickle.HIGHEST_PROTOCOL)

addon.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<addon version="0.1.83" id="plugin.video.playstream" name="PlayStream" provider-name="ivars777"  >
+  <requires>
+    <import addon="xbmc.python" version="2.1.0"/>
+    <import addon="script.module.requests" />
+    <import addon="script.module.simplejson" />
+    <import addon="script.module.pycryptodome" optional="true"/>
+  </requires>
+  <extension point="xbmc.python.pluginsource" library="addon.py">
+    <provides>video</provides>
+  </extension>
+  <extension point="xbmc.service" library="service.py" />
+  <extension point="xbmc.addon.metadata">
+    <platform>all</platform>
+    <language></language>
+    <summary>Play online streams from various sites (mostly Latvian)</summary>
+    <description>Play online streams from various sites:
+    - replay.lv
+    - skaties.lv
+    - shortcut.lv
+    </description>
+  </extension>
+</addon>

changelog.md

@@ -0,0 +1,104 @@
+**0.1.77** (28.06.2018):
+- [change] salabots, lai strādā ar Kodi 18 (alpha2)
+
+**0.1.76** (28.06.2018):
+- [feature] ltv.lsm.lv tiešraides strīmi pievienoti replay (futbols)
+- [change] uzlabots title ltc, filmix
+
+**0.1.74** (15.06.2018):
+- vēlreiz salabots replay un filmas.lv
+
+**0.1.72** (15.06.2018):
+- salabots replay (stradā futbola čempionāta širfrētie strimi)
+- reanimētas filmas.lv (downloads nestrādās)
+
+**0.1.70** (15.06.2018):
+- salabots replay
+- uzlabota lejuplāde (ne lidz galam)
+
+**0.1.63** (18.05.2018):
+- salabots filmix domeins (tagad filmix.co)
+
+**0.1.62** (27.04.2018)
+- [change] Salabotas shortcut.lv tiešraides un arhīvs
+
+**0.1.61** (10.04.2018)
+- [change] Salaboti shortcut.lv videonomas saraksti
+
+**0.1.60** (15.03.2018)
+- [bugfix] Slabota shortcut tiešairaide
+
+**0.1.59** (11.03.2018)
+- [bugfix] Slabots filmix
+
+**0.1.58** (11.03.2018)
+- [feature] PlayStream favoritiem sataisits Delete un Move
+- [change] uzlabota ltc informācija
+- [feature] iespēja opcijās norādīt streams.cfg faila atrašanos/nosaukumu gan lokālā failu sistēmā gan remote (ftp://user:password@host/path/too/streams.cfg), gan http (rakstīšana netiek atbalstīta)
+- [change] filmix rādā visus tulkojumus/strīmus (agrak tikai pirmo)
+
+**0.1.55** (18.02.2018)
+- [bugfix] salabots ltc (arhīvs, epg u.c.)
+- [bugfix] salabots filmix search
+- [change] replay, ltc tiešraidēs nosaukumā rāda epg
+
+**0.1.54** (17.01.2018)
+- [bugfix] salabots submodule
+
+**0.1.52** (17.01.2018)
+- [feature] PlayStream autostart opcija
+- [feature] View Mode opcija
+
+**0.1.50** (12.12.2017)
+- [change] Labojumi atbilstoši PlayStream 0.7o
+- [feature] Testa variants video lejupielādei
+
+**0.1.46** (14.10.2017)
+- [change] Labojumi atbilstoši PlayStream 0.7k
+
+**0.1.45** (05.10.2017)
+- [change] Salabots ltc, replay, cnemalive u.c.
+
+**0.1.44** (03.09.2017)
+- [change] Sakārtotas pikonas, u.c.
+
+**0.1.43** (03.09.2017)
+- [bugfix] Salaboti video avoti atbilstoši PlayStream 0.7e (lattelekom u.c.)
+- [change] pārstrukturets kods (video satura avoti atseviškā git modulī)
+- [change] opcija nelietot proxy problemātiskajiem strimiem (lattlecom.tv, viaplay u.c.), izskatās, ka Web serveris stradā par lēnu
+
+**0.1.41** (03.09.2017)
+- [bugfix] Salabots filmix (pamainīts direct url avots uz html5 + dekodēšana kods)
+
+**0.1.40** (27.08.2017
+- [change] Salabots TVDom atbilstoši jaunajam API (papildus parametri - reģions, valoda)
+- [bugfix] Salabots Euronews
+- [change] Nestrādājošie avoti noslēpti menu, kad tiks salaboti parādīsies atkal
+- [change] Sataisīts izmainītais Filmix.me
+
+**0.1.38** (11.04.2016):
+- [feature] options to set local proxy port (by default 8880), proxy url in order to use remote proxy
+
+**0.1.35** (10.04.2016):
+- [feature] option to save plugin status state between calls (necessary to lattelecom.tv archive)
+
+**0.1.34** (09.04.2016):
+- [feature] proxy hack to play full lattelecom.tv videos (more than 5-6 minutes), turn on proxy in settings and restart kodi
+
+**0.1.33** (01.04.2016):
+- [feature] LMT straume (without TV streams)
+
+**0.1.32** (28.03.2016):
+- [feature] sources configod files stored in user_data area (remains after update)
+- [feature] option to use persistent storage to store sources objects (including login status) between calls (exprerimental, not very useful currently)
+- [feature] proxy server to play encoded hls streams as well as hqq and some other resolved streams (exprerimental, not working correctly)
+- [bugfix] viaplay login
+
+**0.1.24** (23.03.2016):
+- [feature] subtitles, context menu etc added
+
+**0.1.5** (14.02.2016):
+- [feature] addon settings added
+
+**0.1.2** (12.02.2016):
+- initial exprerimental version

context_download.py

@@ -0,0 +1,489 @@
+# -*- coding: utf-8 -*-
+try:
+    import wingdbstub
+except:
+    pass
+
+import sys, os, urllib2, urllib, re, requests, datetime, time, json
+#CLI_MODE = True
+from kodiswift import xbmc, xbmcgui, CLI_MODE
+from kodiswift import Plugin, storage
+from resources.lib.content import util, ContentSources, file
+from downloadqueue import DownloadQueue
+import traceback
+
+
+#from resources.lib.content import Downloader
+#from twisted.web import client
+#from twisted.internet import reactor, defer
+
+plugin = Plugin(addon_id="plugin.video.playstream")
+#plugin.load_addon_settings()
+use_storage = plugin.get_setting("general_use_storage",bool) # TODO vajag nočekot vai nav labāk lietot pickle
+overwrite = plugin.get_setting("general_download_overwrite",bool)
+sleep_time = 5  # TODO jāliek iekš parametriem
+
+cunicode = lambda s: s.decode("utf8") if isinstance(s, str) else s
+cstr = lambda s: s.encode("utf8") if isinstance(s, unicode) else s
+
+#print "argv=",sys.argv
+cmd = sys.argv[1]
+title = sys.argv[2]
+data = sys.argv[3]
+download_dir = sys.argv[4]
+#overwrite = sys.argv[5] if len(sys.argv)>5 else False
+
+queue_dir = os.path.join(xbmc.translatePath("special://temp"), "download_queue") if not CLI_MODE else "download_queue"
+download_queue = DownloadQueue(queue_dir)
+
+job_id = datetime.datetime.now().strftime("%Y%m%d%H%M")
+
+if not os.path.exists(queue_dir):
+    os.mkdir(queue_dir)
+
+
+if cmd in ["download2", "download3"] and not CLI_MODE:
+    download_dir2 = xbmcgui.Dialog().browse(0, "Select download folder", "files")
+    if download_dir2:
+        download_dir = download_dir2
+    else:
+        sys.exit()
+
+#remote_dir = True if re.search("^\w+:", download_dir) else False
+#print "encoding=",fs_encoding
+
+cur_directory = os.path.dirname(__file__)
+sources_directory = os.path.join(cur_directory,"resources","lib", "content", "sources")
+sources = ContentSources.ContentSources(sources_directory)
+
+
+def main():
+    if not sources.is_video(data):  # Folderis
+        n = 0
+        dname = file.make_fname(title)
+        download_dir2 = file.join(download_dir, dname)
+        for current2 in sources.get_content(data):
+            if sources.is_video(current2[1]):
+                n += 1
+                download_video(current2[0], current2[1], download_dir2, overwrite, num=n)
+        #if n>0:
+        #    notify("%s videos download started to %s"%(n,download_dir2))
+        #else:
+        #    notify("No videos to download")
+    else:
+        if cmd == "download3":
+            dname = file.make_fname(title)
+            download_dir2 = file.join(download_dir, dname)
+        else:
+            download_dir2 = download_dir
+        download_video(title, data,download_dir2, overwrite)
+        #self.msg("Video download started to %s"%download_dir)
+
+def download_video(title, data, download_dir, overwrite, cb_notify=None, num=None):
+
+    streams = sources.get_streams(data)
+    if not streams:
+        notify("No streams to download")
+        return
+
+    if len(streams)>1 and not num:
+        slist = []
+        for s in streams:
+            slist.append("%s [%s,%s]"%(s["name"],s["quality"],s["lang"]))
+        res = xbmcgui.Dialog().select("Select stream",slist) if not CLI_MODE else 0
+        #res = xbmcgui.Dialog().contextmenu(slist) if not CLI_MODE else 0
+        stream = streams[res]
+    else:
+        stream = streams[0]
+
+    download_stream(stream, download_dir, overwrite, notify, num=num)
+
+    #d = Downloader.download_video(stream["url"], os.path.join(download_dir, output), stream["headers"])
+    #reactor.run()
+
+
+    #xbmcgui.Dialog().ok("Info","Start download")
+
+    #mode = "a" if os.path.exists("context_menu.log") else "w"
+    #with open("context_menu.log", mode) as f:
+    #    f.write("%s %s %s %s", sys.argv[1], sys.argv[2], sys.argv[3], sys.argv[4])
+
+def notify(text, title="Info", time=10000):
+    if isinstance(text, unicode):
+        text = text.encode("utf8")
+    #xbmc.executebuiltin('Notification(Hello World,This is a simple example of notifications,5000,/script.hellow.world.png)')
+    if CLI_MODE:
+        print "Info: ", text
+    else:
+        xbmc.executebuiltin('Notification(%s, %s, %d, %s)'%("Info", text, time, xbmcgui.NOTIFICATION_INFO))
+
+####################################################################################################
+# Platform independent part, should be put in separate module
+####################################################################################################
+
+def download_stream(stream, download_dir, overwrite=True, cb_notify=None, num=False):
+    #output =  stream["name"].replace("\\"," ").replace(":"," ").replace("|"," ")
+    url = stream["url"]
+    title = stream["name"].strip()
+    output = file.make_fname(title)
+
+    headers = stream["headers"] if "headers" in stream and stream["headers"] else {"user-agent":"Enigma2"}
+    try:
+        h = get_header(url,headers=headers)
+        mtype = h.get("content-type")
+        ext,stream_type = get_ext(mtype)
+    except Exception as e:
+        ext,stream_type = (".ts","hls")
+    #stream_type = ContentSources.stream_type(url) #self.sources.stream_type(stream["url"])
+    if not stream_type: #
+        print "Not supported stream type found to download - %s"%(url)
+        raise Exception("Not supported stream type found to download - %s"%(url))
+
+    fname = output+ext
+    outputfile = file.join(download_dir, fname)
+    exists = file.exists(outputfile)
+    if exists and num and num > 1:
+        output = output + "_%02i" % num
+        fname = output+ext
+        outputfile = file.join(download_dir, fname)
+        exists = file.exists(outputfile)
+
+    if exists and not overwrite:
+        if cb_notify: cb_notify("Download skipped - %s" % output)
+        print "Download skipped - %s" % output
+        return
+
+    print "download_dir=", download_dir
+    if not file.isdir(download_dir):
+        try:
+            file.mkdir(file.encode(download_dir))
+        except Exception as e:
+            traceback.print_exc()
+            print 'Error creating download directory "%s"!\nPlease specify in the settings existing directory\n%s'%(download_dir,str(e))
+            raise Exception('Error creating download directory "%s"!\nPlease specify in the settings existing directory\n%s'%(download_dir,str(e)))
+
+    output_path = file.join(download_dir, output)
+
+    if "nfo" in stream and stream["nfo"]:
+        nfofile = file.join(download_dir, output+".nfo")
+        #print "nfofile=", nfofile.encode("utf8")
+        nfo_txt = util.nfo2xml(stream["nfo"])
+        f = file.open(file.encode(nfofile),"w")
+        f.write(nfo_txt)
+        f.close()
+
+    subfiles = []
+    if "subs" in stream and stream["subs"]:
+        for sub in stream["subs"]:
+            suburl = sub["url"]
+            slang = "." + sub["lang"] if sub["lang"] else ""
+            download_sub(suburl, output+slang, download_dir)
+
+    if "img" in stream and stream["img"]:
+        download_image(stream["img"], output, download_dir)
+
+    ### Start video file download ####
+    job = {
+        "job_id": job_id,
+        "status": "downloading",
+        "url":url,
+        "output": output,
+        "file": outputfile,
+        "download_dir": download_dir,
+        "headers": headers,
+        "totalbytes": -1,
+        "currentbytes": 0,
+        "overwrite": overwrite,
+    }
+    download_queue.job_put(job_id, job)
+
+    if cb_notify: cb_notify("%s put in download queue" % output)
+    print "%s put in download queue" % output
+
+
+    if stream_type == "hls":
+        download_hls(url, outputfile, headers=headers, cb_notify=cb_notify)
+    else:
+        download_file(url, outputfile, headers=headers, cb_notify=cb_notify)
+
+
+def download_hls(url, outputfile, headers=None, overwrite=True, limit=None, cb_notify=None):
+    UA = "Mozilla/5.0 (Windows NT 10.0; WOW64; rv:51.0) Gecko/20100101 Firefox/51.0"
+    if not headers:
+        headers = {"User-Agent" : UA}
+    key = headers["key"] if "key" in headers else ""
+#    if not "User-Agent" in headers:
+#        headers["User-Agent"] = UA
+    #outputfile = file.join(download_dir,output)
+
+    if cb_notify: cb_notify("Download started - %s" % outputfile)
+    print "Download started - %s" % outputfile, url
+    #print url
+
+
+    try:
+        r = requests.get(url,headers=headers)
+    except Exception as e:
+        raise Exception("Cannot open manifsest file - %s"%url)
+    if not r.content.startswith("#EXTM3U"):
+        raise Exception("Not valid manifest file - %s" % url)
+    streams = re.findall(r"#EXT-X-STREAM-INF:.*?BANDWIDTH=(\d+).*?\n(.+?)$", r.content, re.IGNORECASE | re.MULTILINE)
+    i = 0
+    while streams:
+        if i > 4: break
+        sorted(streams, key=lambda item: int(item[0]), reverse=True)
+        base_url = "/".join(url.split("?")[0].split("/")[:-1])+"/"
+        url = streams[0][1]
+        if not url.startswith("http"):
+            url = base_url + url
+        #print url
+        try:
+            r = requests.get(url, headers=headers)
+        except Exception as e:
+            raise Exception("Cannot open manifsest file - %s"%url)
+        i += 1
+        streams = re.findall(r"#EXT-X-STREAM-INF:.*?BANDWIDTH=(\d+).*?\n(.+?)$", r.content, re.IGNORECASE | re.MULTILINE)
+    m = re.search('#EXT-X-KEY:METHOD=(.+?),URI="([^"]+)"', r.content, re.IGNORECASE)
+
+    if m:
+        url_key = m.group(2)
+        r2 = requests.get(url_key, headers=headers)
+        key = r2.content
+    else:
+        key = None
+
+    ts_list = re.findall(r"#EXTINF:([\d\.]+),.*?\n(.+?)$", r.content, re.IGNORECASE | re.MULTILINE)
+    base_url = "/".join(url.split("/")[:-1])+"/"
+
+    if not len(ts_list):
+        raise Exception("Cannot read fragment list in  manifsest file - %s"%url)
+
+    ts_num = 0
+    type = "vod" if "#EXT-X-ENDLIST" in r.content else "live"
+    currentbytes = 0.0
+    totalbytes = -1
+    currenttime = 0.0
+    totaltime = sum(map(float,zip(*ts_list)[0]))
+    #ts_file = open(outputfile, "wb")
+
+    tsfile = file.open(file.encode(outputfile),"wb")
+    for ts in ts_list:
+        url2 = ts[1]
+        #print "Downloading ", url2
+        #fname = os.path.join(download_dir,url2.split("/")[-1])
+        if not url2.startswith("http"):
+            url2 = base_url + url2
+
+        r = requests.get(url2, headers=headers, verify=False)
+        content = r.content
+        if key:
+            #from Crypto.Cipher import AES
+            import pyaes
+            iv = content[:16]
+            #key2 = binascii.a2b_hex(key)
+            #d = AES.new(key, AES.MODE_CBC, iv)
+            d = pyaes.AESModeOfOperationCBC(key, iv = iv)
+            content2 = ""
+            for i in range(16, len(content), 16):
+                content2 += d.decrypt(content[i:i+16])
+            content = content2
+            #content = d.decrypt(content[16:])
+            #d = pyaes.Decrypter(pyaes.AESModeOfOperationCBC(key, iv))
+            #content = d.feed(content[16:])
+        tsfile.write(content)
+
+        content_length = len(content)
+        currentbytes += content_length
+        currenttime += float(ts_list[ts_num][0])
+        totalbytes = currentbytes * totaltime / currenttime
+
+        # Checking queue
+        while True:
+            job = download_queue.job_get(job_id)
+            if not job:
+                print "Download canceled"
+                notify("Download canceled - %s" % output)
+                tsfile.close()
+                os.remove(outputfile)
+                return
+            if job["status"] in ("waiting", "paused"):
+                time.sleep(sleep_time)
+                continue
+            break
+        job["currentbytes"] = currentbytes
+        job["totalbytes"] = totalbytes
+        download_queue.job_put(job_id, job)
+
+        ts_num += 1
+        #print "Fragment %s downloaded (%s)"%(self.ts_num,len(content))
+        progress = float(currentbytes)/float(totalbytes)*100
+        msg = "%.1f%% (%iMB/%iMB)"%(progress,currentbytes / 1024 / 1024,totalbytes / 1024 / 1024)
+        #print msg
+        #notify(msg)
+
+        if type == "vod":
+            if ts_num >= len(ts_list) or (limit and currenttime>limit):
+                break
+        else:  # live stream # TODO
+            if limit and currenttime>limit: # TODO
+                break
+
+    download_queue.job_remove(job_id)
+    print "Finished"
+    notify("Download finished - %s" % outputfile)
+    tsfile.close()
+
+
+def download_file(url, outputfile, headers=None, overwrite=True, limit=None, cb_notify=None):
+    global job
+    UA = "Mozilla/5.0 (Windows NT 10.0; WOW64; rv:51.0) Gecko/20100101 Firefox/51.0"
+    if not headers:
+        headers = {"User-Agent" : UA}
+    key = headers["key"] if "key" in headers else ""
+#    if not "User-Agent" in headers:
+#        headers["User-Agent"] = UA
+    #fname = file.join(download_dir,output)
+
+    if cb_notify: cb_notify("Download started - %s" % outputfile)
+    print "Download started - %s" % outputfile
+    #print url
+    try:
+        r = requests.get(url,headers=headers, stream=True)
+    except Exception as e:
+        raise Exception("Cannot open url - %s"%url)
+    currentbytes = 0.0
+    totalbytes = int(r.headers["content-length"])
+
+
+    fd = file.open(file.encode(outputfile), 'wb')
+    for chunk in r.iter_content(chunk_size=1024*1024):
+        fd.write(chunk)
+        currentbytes += len(chunk)
+        progress = float(currentbytes)/float(totalbytes)*100
+        msg = "%.1f%% (%iMB/%iMB)"%(progress,currentbytes / 1024 / 1024,totalbytes / 1024 / 1024)
+        #print msg
+
+        # Checking queue
+        while True:
+            job = download_queue.job_get(job_id)
+            if not job:
+                print "Download canceled"
+                notify("Download canceled - %s" % outputfile)
+                fd.close()
+                os.remove(fname)
+                return
+            if job["status"] in ("waiting", "paused"):
+                time.sleep(sleep_time)
+                continue
+            break
+        job["currentbytes"] = currentbytes
+        job["totalbytes"] = totalbytes
+        download_queue.job_put(job_id, job)
+
+        #notify(msg)
+
+    fd.close()
+    job.remove()
+    print "Finished"
+    notify("Download finished - %s" % outputfile)
+
+def download_sub(suburl, output, download_dir):
+    try:
+        subs = urllib2.urlopen(suburl).read()
+    except:
+        subs = None
+    if subs:
+        if ".xml" in suburl:
+            subs = util.ttaf2srt(subs)
+            subext = ".srt"
+        elif ".vtt" in suburl:
+            subs = util.vtt2srt(subs)
+            subext = ".srt"
+        elif ".srt" in suburl:
+            subext = ".srt"
+        else:
+            subext = ".srt"
+        if subext:
+            subfile = file.join(download_dir, output+subext)
+            f = file.open(file.encode(subfile),"w")
+            f.write(subs)
+            f.close()
+    else:
+        print "\n Error downloading subtitle %s"%suburl
+        raise Exception("Error downloading subtitle %s"%suburl)
+
+
+def download_image(imgurl, output, download_dir):
+    ext = imgurl.split("?")[0].split(".")[-1]
+    ext = "." + ext
+    ext = ".jpg"
+    imgfile =  file.join(download_dir, output+ext)
+    try:
+        img = urllib2.urlopen(imgurl).read()
+    except Exception(e):
+        img = None
+    if img:
+        f = file.open(file.encode(imgfile),"wb")
+        f.write(img)
+        f.close()
+    else:
+        print "\n Error downloading image %s"%imgurl
+        raise Exception("Error downloading image %s"%imgurl)
+
+
+
+def get_header(url,headers=None):
+    r = requests.head(url,headers=headers)
+    return r.headers
+
+def get_ext(mtype):
+    stype = "http"
+    if mtype in ("vnd.apple.mpegURL","application/x-mpegURL",'application/x-mpegurl',"application/vnd.apple.mpegurl"):
+        return ".ts","hls"
+    elif mtype in ("application/dash+xml"):
+        return ".ts","dash" # TODO dash stream type  could be different !
+    elif mtype in ("video/mp4"):
+        return ".mp4","http"
+    elif mtype in ("video/MP2T","video/mp2t"):
+        return ".ts","http"
+    elif mtype in ("video/x-flv"):
+        return ".flv","http"
+    elif mtype in ("video/quicktime"):
+        return ".mov","http"
+    elif mtype in ("video/x-msvideo"):
+        return ".avi","http"
+    elif mtype in ("video/x-ms-wmv"):
+        return ".wmv","http"
+    elif mtype in ("video/x-matroska"):
+        return ".mkv","http"
+    else:
+        return ".mp4","http"
+
+
+class Job(object):
+    def __init__(self, job_id, queue_dir, job={}):
+        self.job_id = job_id
+        self.queue_dir = queue_dir
+        self.job_file = os.path.join(queue_dir, job_id)
+        self.job = job
+
+    def read(self):
+        try:
+            with open(self.job_file, "r") as f:
+                s = f.read()
+            self.job = json.loads(s)
+        except:
+            self.job = {}
+        return self.job
+
+    def write(self):
+        s = json.dumps(self.job)
+        with open(self.job_file, "w") as f:
+            f.write(s)
+    def remove(self):
+        if os.path.exists(self.job_file):
+            os.remove(self.job_file)
+
+
+if __name__ == '__main__':
+    main()

context_menu.py

@@ -0,0 +1,95 @@
+import sys, os, os.path
+from kodiswift import xbmc, xbmcgui, CLI_MODE
+from kodiswift import Plugin, storage
+from resources.lib.content import util
+try:
+    import wingdbstub
+except:
+    pass
+
+
+plugin = Plugin(addon_id="plugin.video.playstream")
+#plugin.load_addon_settings()
+#playlist = plugin.get_setting("general_playlist",str)
+#proxy_url = plugin.get_setting("general_proxy_url",str)
+streams_file = plugin.get_setting("general_streams_file",str)
+streams_file_remote = plugin.get_setting("general_streams_file_remote",str)
+use_streams_file_remote = plugin.get_setting("general_use_streams_file_remote",bool)
+download_overwrite = plugin.get_setting("general_download_overwrite",bool)
+
+cmd = sys.argv[1]
+#title = sys.argv[2]
+#data = sys.argv[3]
+#img = sys.argv[4]
+#desc = sys.argv[5]
+
+if cmd in ("add", "delete", "move"):
+    from resources.lib.content.sources.config import Source
+    fname = streams_file_remote if use_streams_file_remote else streams_file
+    try:
+        cfg = Source(cfg_file=fname)
+    except Exception as e:
+        plugin.notify("Cannot open content config file %s" % fname)
+    lists = cfg.get_lists()
+    titles = [cfg.get_title(name) for name in lists]
+
+if cmd == "add":
+    if not CLI_MODE:
+        ret = xbmcgui.Dialog().select("Select menu",titles)
+    else:
+        ret = 3
+    if ret > 0:
+        cfg.add_item(lists[ret],sys.argv[2:])
+        cfg.write_streams()
+
+elif cmd == "delete":
+    cfg.del_item(sys.argv[2], int(sys.argv[3]))
+    cfg.write_streams()
+    xbmc.executebuiltin("Container.Refresh")
+
+elif cmd == "move":
+    name = sys.argv[2]
+    pos = int(sys.argv[3])
+    item = cfg.get_list_items(name)[pos]
+    cfg.del_item(name, pos)
+    ret = xbmcgui.Dialog().select("Select menu",titles)
+    if ret > 0:
+        name2 = lists[ret]
+        items2 = cfg.get_list_items(name)
+        items2 = [it[0] for it in items2]
+        ret = xbmcgui.Dialog().select("Select position before item will be insert",items2)
+        if ret > 0:
+            cfg.add_item(name2, item, ret)
+            cfg.write_streams()
+            xbmc.executebuiltin("Container.Refresh")
+
+elif cmd == "playlist":
+    title = sys.argv[2]
+    data = sys.argv[3]
+    playlist = sys.argv[4]
+    proxy_url = sys.argv[5]
+    if not os.path.exists(playlist):
+        pl = open(playlist,"wb")
+        pl.write('#EXTM3U\n')
+    else:
+        pl = open(playlist,"a")
+    urlp = util.streamproxy_encode2(data,{},proxy_url)
+    if isinstance(urlp,unicode):
+        urlp = urlp.encode("utf8")
+    if isinstance(title,unicode):
+        title = title.encode("utf8")
+    pl.write("#EXTINF:0,%s\n%s\n"%(title,urlp))
+    pl.close()
+    #plugin.notify("Item '%s' added to %s"%(title,playlist), "Info", 10000, xbmcgui.NOTIFICATION_INFO)
+
+elif cmd == "download":
+    xbmcgui.Dialog().ok("Info","Not yet implemented!")
+
+else:
+    xbmcgui.Dialog().ok("Error","Wrong command")
+
+
+
+#mode = "a" if os.path.exists("context_menu.log") else "w"
+#with open("context_menu.log", mode) as f:
+#    f.write("%s %s %s %s", sys.argv[1], sys.argv[2], sys.argv[3], sys.argv[4])

deploy.bat

@@ -0,0 +1,71 @@
+@echo off
+if (abox)==(%1%) (
+	set TARGET=a:\0\Android\data\org.xbmc.kodi\files\.kodi\addons\plugin.video.playstream\
+) else (
+    set TARGET=C:\Users\User\AppData\Roaming\Kodi\addons\plugin.video.playstream\
+)
+
+for %%f in (
+readme.md
+changelog.md
+addon.xml
+addon.py
+context_menu.py
+context_download.py
+downloadqueue.py
+service.py
+icon.png
+kodiswift\*.py
+resources\__init__.py
+resources\settings.xml
+resources\icon.png
+resources\language\English\*
+resources\lib\__init__.py
+resources\lib\content\__init__.py
+resources\lib\content\ContentSources.py
+resources\lib\content\playstreamproxy.py
+resources\lib\content\util.py
+resources\lib\content\file.py
+resources\lib\content\run.py
+resources\lib\content\resolver.py
+resources\lib\content\demjson.py
+resources\lib\content\ordereddict.py
+resources\lib\content\sources\__init__.py
+resources\lib\content\sources\SourceBase.py
+resources\lib\content\sources\cinemalive.py
+resources\lib\content\sources\config.py
+resources\lib\content\sources\euronews.py
+resources\lib\content\sources\filmix.py
+resources\lib\content\sources\filmon.py
+resources\lib\content\sources\iplayer.py
+resources\lib\content\sources\movieplace.py
+resources\lib\content\sources\ltc.py
+resources\lib\content\sources\mtgplay.py
+resources\lib\content\sources\play24.py
+resources\lib\content\sources\replay.py
+resources\lib\content\sources\serialguru.py
+resources\lib\content\sources\tvdom.py
+resources\lib\content\sources\ustvnow.py
+resources\lib\content\sources\viaplay.py
+resources\lib\content\sources\lmt.py
+resources\lib\content\sources\filmas.py
+resources\lib\content\sources\YouTubeVideoUrl.py
+resources\lib\content\sources\jsinterp.py
+resources\lib\content\sources\swfinterp.py
+resources\lib\content\sources\streams.cfg
+resources\lib\content\resolvers\__init__.py
+resources\lib\content\resolvers\aadecode.py
+resources\lib\content\resolvers\hqqresolver.py
+resources\lib\content\resolvers\openload3.py
+resources\lib\content\resolvers\hdgo.py
+resources\lib\content\resolvers\kapnob.py
+resources\lib\content\resolvers\kodik.py
+resources\lib\content\resolvers\youtuberesolver.py
+resources\picons\*
+) do echo f | xcopy /y   %%f %TARGET%%%f
+
+xcopy /y /q resources\lib\content\picons\* %TARGET%resources\picons\
+
+rem xcopy /y /d addon_data\settings.xml "C:\Users\user\AppData\Roaming\Kodi\userdata\addon_data\plugin.video.playstream\settings.xml"
+
+pause

download_service.py

@@ -0,0 +1,59 @@
+# -*- coding: utf-8 -*-
+try:
+    import wingdbstub
+except:
+    pass
+import os,os.path,sys, datetime, traceback
+from kodiswift import Plugin, ListItem, storage
+from kodiswift import xbmc, xbmcgui, xbmcplugin, xbmcvfs, CLI_MODE
+
+sys.path.append(os.path.join(os.path.dirname(__file__), "resources", "lib"))
+#from resources.lib import ContentSources, util
+#sys.path.insert(0, os.path.join(os.path.dirname(os.path.abspath(__file__)),"resources","lib","sources"))
+from twisted.web import client
+from twisted.internet import reactor, defer, ssl, task
+
+import content.Downloader as Downloader
+import sys,os, os.path, re
+import urlparse, requests
+
+print "twisted imported"
+#str(time.time())
+
+plugin = Plugin()
+plugin.load_addon_settings()
+download_dir = plugin.get_setting("general_download_dir",str)
+queue_dir = os.path.join(plugin.storage_path,"downloads)")
+if not os.path.exists(queue_dir):
+    os.mkdir(queue_dir)
+
+class DownloadQueue(object):
+    def __init__(self):
+        self.flist=[]
+        self.q=[]
+
+    def check_queue(self):
+        print "check_queue"
+        flist = os.listdir(queue_dir)
+        print "Checking queue"
+
+    def start_download(self):
+        pass
+
+    def download_ok(self):
+        pass
+
+    def download_err(self):
+        pass
+
+def notify(text, title="Info", time=10000):
+    if isinstance(text, unicode):
+        text = text.encode("utf8")
+    #xbmc.executebuiltin('Notification(Hello World,This is a simple example of notifications,5000,/script.hellow.world.png)')
+    xbmc.executebuiltin('Notification(%s, %s, %d, %s)'%("Info", text, time, xbmcgui.NOTIFICATION_INFO))
+
+
+queue = DownloadQueue()
+loop = task.LoopingCall(queue.check_queue)
+loop.start(2)
+reactor.run()

downloadqueue.py

@@ -0,0 +1,64 @@
+# -*- coding: utf-8 -*-
+try:
+    import wingdbstub
+except:
+    pass
+
+import sys, os, urllib2, urllib, re, requests, datetime, json
+from resources.lib.content import file
+#CLI_MODE = True
+# from kodiswift import xbmc, xbmcgui, CLI_MODE
+# from kodiswift import Plugin, storage
+
+
+class DownloadQueue(object):
+    def __init__(self, queue_dir):
+        self.queue_dir = queue_dir
+        if not os.path.isdir(queue_dir):
+            os.mkdir(queue_dir)
+
+    def job_get(self, job_id):
+        try:
+            job = json.loads(open(os.path.join(self.queue_dir, job_id), "r").read())
+        except:
+            job = None
+        return job
+
+    def job_put(self, job_id, job):
+        try:
+            s = json.dumps(job)
+            open(os.path.join(self.queue_dir, job_id), "w").write(s)
+        except:
+            raise Exception("Can not store job")
+
+    def job_remove(self, job_id):
+        try:
+            os.remove(os.path.join(self.queue_dir, job_id))
+        except:
+            pass
+
+
+    def job_ids(self, filer=""):
+        lst = os.listdir(self.queue_dir)
+        lst.sort()
+        return lst
+
+    def jobs(self, filter=""):
+        jobs = []
+        for job_id in self.job_ids():
+            jobs.append(self.job_get(job_id))
+        return jobs
+
+    def jobs_count(self):
+        count = {}
+        for job in jobs():
+            stat = job["status"]
+            if stat in count:
+                count[stat] += 1
+            else:
+                count[stat] = 1
+        return stat
+
+    def clear(self):
+        for job_id in self.job_ids():
+            os.remove(file.join(self.queue_dir, job_id))

get_version.py

@@ -0,0 +1,2 @@
+import re,sys
+print re.search('<addon version="([^"]+)',open(sys.argv[1]).read()).group(1)

kmake.bat

@@ -0,0 +1,124 @@
+@echo off
+
+:--- Pull content submodule ---
+pushd resources\lib\content
+:git commit -a -m a
+:git checkout .
+:git pull
+popd
+
+:=== Parameters ===
+python get_version.py addon.xml >version.txt
+set /p ver=<version.txt
+echo %ver%
+rem pause
+
+set prog=PlayStream
+set pack_name=plugin.video.playstream
+set desc=Play online streams from various sources, mostly Latvian
+
+set ipk_dir=ipkg\
+set release_dir=release\
+set repo_dir=..\repo\
+set feed_dir=q:\web\repo\
+
+set AR=\MinGW\bin\ar.exe
+set TAR=\MinGW\msys\1.0\bin\tar.exe
+rem set ZIP=\Program Files (x86)\Gow\bin\zip.exe
+
+:=== data files ===
+if exist "%pack_name%" rm -r -f "%pack_name%"
+mkdir "%pack_name%""
+if not exist %release_dir% mkdir %release_dir%
+if not exist %repo_dir% mkdir %repo_dir%
+if not exist  %repo_dir%%pack_name% mkdir  %repo_dir%%pack_name%
+
+
+for %%f in (
+readme.md
+changelog.md
+addon.xml
+addon.py
+context_menu.py
+context_download.py
+downloadqueue.py
+service.py
+icon.png
+kodiswift\*.py
+resources\__init__.py
+resources\settings.xml
+resources\icon.png
+resources\language\English\*
+resources\lib\__init__.py
+resources\lib\content\__init__.py
+resources\lib\content\ContentSources.py
+resources\lib\content\playstreamproxy.py
+resources\lib\content\Downloader.py
+resources\lib\content\resolver.py
+resources\lib\content\util.py
+resources\lib\content\run.py
+resources\lib\content\file.py
+resources\lib\content\demjson.py
+resources\lib\content\ordereddict.py
+resources\lib\content\sources\__init__.py
+resources\lib\content\sources\SourceBase.py
+resources\lib\content\sources\cinemalive.py
+resources\lib\content\sources\config.py
+resources\lib\content\sources\euronews.py
+resources\lib\content\sources\filmix.py
+resources\lib\content\sources\filmon.py
+resources\lib\content\sources\iplayer.py
+resources\lib\content\sources\movieplace.py
+resources\lib\content\sources\ltc.py
+resources\lib\content\sources\mtgplay.py
+resources\lib\content\sources\play24.py
+resources\lib\content\sources\replay.py
+resources\lib\content\sources\lmt.py
+resources\lib\content\sources\serialguru.py
+resources\lib\content\sources\tvdom.py
+resources\lib\content\sources\ustvnow.py
+resources\lib\content\sources\viaplay.py
+resources\lib\content\sources\filmas.py
+resources\lib\content\sources\YouTubeVideoUrl.py
+resources\lib\content\sources\jsinterp.py
+resources\lib\content\sources\swfinterp.py
+resources\lib\content\sources\streams.cfg
+resources\lib\content\resolvers\__init__.py
+resources\lib\content\resolvers\aadecode.py
+resources\lib\content\resolvers\hqqresolver.py
+resources\lib\content\resolvers\openload3.py
+resources\lib\content\resolvers\hdgo.py
+resources\lib\content\resolvers\kapnob.py
+resources\lib\content\resolvers\kodik.py
+resources\lib\content\resolvers\cloudsany.py
+resources\lib\content\resolvers\youtuberesolver.py
+) do echo f| xcopy %%f %pack_name%\%%f
+
+xcopy /y /q resources\lib\content\picons\* %pack_name%\resources\picons\
+
+pause
+
+if exist  %release_dir%%pack_name%-%ver%.zip rm %release_dir%%pack_name%-%ver%.zip
+rem zip  -r %release_dir%%pack_name%-%ver%.zip %pack_name%
+"C:\Program Files\WinRAR\winrar.exe" a -afzip -r %release_dir%%pack_name%-%ver%.zip %pack_name%
+copy  addon.xml  %repo_dir%%pack_name%\addon.xml /Y
+copy  %release_dir%%pack_name%-%ver%.zip  %repo_dir%%pack_name%\%pack_name%-%ver%.zip /Y
+python -c "import hashlib; print hashlib.md5(open(r'%repo_dir%%pack_name%\%pack_name%-%ver%.zip','r').read()).hexdigest()" >%repo_dir%%pack_name%\%pack_name%-%ver%.zip.md5
+
+git add %release_dir%%pack_name%-%ver%.zip
+rm -r -f "%pack_name%"
+
+if not ()==(%1%) (
+    git commit -m %ver%
+    git tag -d "%ver%"
+    git tag %ver%
+    git push
+
+    pushd  %repo_dir%..
+    call update_repo.bat
+    rem xcopy /s /y /u repo %feed_dir%
+    robocopy repo %feed_dir%  addons.* /copy:dat
+    robocopy repo\%pack_name% q:\web\repo\%pack_name% /copy:DAT /xo
+    popd
+)
+pause

link.bat

@@ -0,0 +1,2 @@
+set plugin=plugin.video.playstream
+mklink /j \users\user\AppData\Roaming\Kodi\addons\%plugin% %cd%

queue_management.py

@@ -0,0 +1,204 @@
+# -*- coding: utf-8 -*-
+try:
+    import wingdbstub
+except:
+    pass
+
+import sys, os, urllib2, urllib, re, requests, datetime, time, json
+#CLI_MODE = True
+from kodiswift import xbmc, xbmcgui, xbmcplugin, CLI_MODE
+from kodiswift import Plugin, storage
+import pyxbmct.addonwindow as pyxbmct
+from downloadqueue import DownloadQueue
+import traceback, threading
+from resources.lib.content import file
+
+
+plugin = Plugin(addon_id="plugin.video.playstream")
+prefix = "plugin://plugin.video.playstream/"
+#plugin.load_addon_settings()
+timer = None
+timer_file = os.path.join(xbmc.translatePath("special://temp"), "timer_active") if not CLI_MODE else "timer_active"
+if os.path.exists(timer_file): os.remove(timer_file)
+sleep_time = 5  # TODO jāliek iekš parametriem
+
+#print "argv=",sys.argv
+handle = int(sys.argv[1])
+handle = 7777
+cmd = sys.argv[2]
+job_id = sys.argv[3] if len(sys.argv) > 3 else None
+
+queue_dir = os.path.join(xbmc.translatePath("special://temp"), "download_queue") if not CLI_MODE else "download_queue"
+download_queue = DownloadQueue(queue_dir)
+
+if not os.path.exists(queue_dir):
+    os.mkdir(queue_dir)
+
+
+def main():
+
+    if cmd == "list":
+        ret = downloads_list()
+    elif cmd == "view":
+        ret = downloads_view_job(job_id)
+    else:
+        ret = downloads_cmd(cmd, job_id)
+
+def refresh_container():
+    global timer
+    if os.path.exists(timer_file):
+        xbmc.executebuiltin('Container.Refresh')
+    else:
+        timer.stop()
+
+def downloads_list():
+
+    #plugin.finish(items, view_mode=get_view_mode("WideList"), update_listing=True, cache_to_disc=False)
+    #xbmcplugin.endOfDirectory(handle, succeeded=True, updateListing=True, cacheToDisc=False)
+
+    items = ["Item {0}".format(i) for i in xrange(1, 11)]
+    dialog = MultiChoiceDialog("Select items", [])
+    dialog.doModal()
+    xbmcgui.Dialog().notification("Finished", "Selected: {0}".format(str(dialog.selected)))
+    del dialog #You need to delete your instance when it is no longer needed
+
+
+    timer = threading.Timer(4.0, refresh_container)
+    #timer.start()
+    #open(timer_file, "w").write("started")
+
+def get_jobs():
+    global timer
+    jobs = download_queue.jobs()
+    items = []
+    i = 1
+    for job in jobs:
+        progress = float(job["currentbytes"])/float(job["totalbytes"])*100 if job["currentbytes"] and  job["totalbytes"] else ""
+        msg = "%.1f%% (%iMB/%iMB)"%(progress, job["currentbytes"] / 1024 / 1024, job["totalbytes"] / 1024 / 1024)
+        title = "%s - %s: %s" % (job["status"], msg, job["output"])
+        data2 = prefix + "downloads::view/%s" % job["job_id"]
+        is_playable = False
+        img = None
+        desc = "%s\n%s\n%s\n%s\n%s" % (job["output"], msg, job["job_id"], job["file"], job["url"])
+        #print title.encode("utf8"),data2,img
+        context_menu = [
+            ("Cancel download job", u'RunPlugin(plugin://plugin.video.playstream/downloads::cancel/%s'%(job["job_id"])),
+            ("Pause download job", u'RunPlugin(plugin://plugin.video.playstream/downloads::pause/%s'%(job["job_id"])),
+            ("Continue paused download job", u'RunPlugin(plugin://plugin.video.playstream/downloads::continue/%s'%(job["job_id"])),
+            ("Cancel all jobs", u'RunPlugin(plugin://plugin.video.playstream/downloads::cancel_all'),
+        ]
+
+        item2 = xbmcgui.ListItem(title, "", "", "", data2)
+        item2.setInfo("Video", {"title":title, "plot": desc,})
+        item2.addContextMenuItems(context_menu)
+        #item.setProperty("is_folder", "true")
+        items.append(item2)
+        #xbmcplugin.addDirectoryItem(handle=handle, url=data2, listitem=item2, isFolder=False)
+        i += 1
+    return items
+
+
+def downloads_view_job(job_id):
+    pass
+
+def downloads_cmd(cmd, params):
+    pass
+
+def get_view_mode(vm):
+    modes = {
+        "skin.estuary": {
+            "None": None,
+            "List": 50,
+            "Poster": 51,
+            "IconWall":52 ,
+            "Shift": 53,
+            "InfoWall": 54,
+            "WideList": 55,
+            "Wall": 500,
+            "Banner": 501,
+            "FanArt": 502
+        },
+        "skin.estuary.is": {
+            "None": None,
+            "List": 50,
+            "Poster": 51,
+            "IconWall":52 ,
+            "Shift": 53,
+            "InfoWall": 54,
+            "WideList": 55,
+            "Wall": 500,
+            "Banner": 501,
+            "FanArt": 502
+        },
+    }
+    skin = xbmc.getSkinDir()
+    if skin in modes and vm in modes[skin]:
+        view_mode = modes[skin][vm]
+    else:
+        view_mode = 50
+    return view_mode
+
+class MultiChoiceDialog(pyxbmct.AddonDialogWindow):
+    def __init__(self, title="", items=None):
+        super(MultiChoiceDialog, self).__init__(title)
+        self.setGeometry(1200, 760, 10, 10)
+        self.selected = []
+        self.set_controls()
+        self.connect_controls()
+        self.update_list()
+        self.set_navigation()
+
+    def onAction(self, action):
+        action_id = action.getId()
+        if action_id in (101, 117):
+            print "Context menu"
+
+    def update_list(self):
+        items = get_jobs()
+        self.listing.reset()
+        self.listing.addItems(items)
+
+    def set_controls(self):
+        self.listing = pyxbmct.List(_imageWidth=15)
+        self.placeControl(self.listing, 0, 0, rowspan=10, columnspan=9)
+        self.ok_button = pyxbmct.Button("OK")
+        self.placeControl(self.ok_button, 1, 9)
+        self.cancel_button = pyxbmct.Button("Cancel")
+        self.placeControl(self.cancel_button, 2, 9)
+
+    def connect_controls(self):
+        self.connect(self.listing, self.item_selected)
+        self.connect(self.ok_button, self.ok)
+        self.connect(self.cancel_button, self.close)
+        self.connect(117, self.context_menu)
+
+    def set_navigation(self):
+        self.listing.controlRight(self.ok_button)
+        self.listing.controlLeft(self.ok_button)
+        self.ok_button.setNavigation(self.listing, self.listing, self.cancel_button, self.cancel_button)
+        self.cancel_button.setNavigation(self.listing, self.listing, self.ok_button, self.ok_button)
+        if self.listing.size():
+            self.setFocus(self.listing)
+        else:
+            self.setFocus(self.cancel_button)
+
+    def context_menu(self):
+        list_item = self.listing.getSelectedItem()
+        print "aaaa"
+
+
+    def item_selected(self):
+        list_item = self.listing.getSelectedItem()
+        pass
+
+
+    def ok(self):
+        self.selected = self.listing.getSelectedItem()
+        super(MultiChoiceDialog, self).close()
+
+    def close(self):
+        self.selected = None
+        super(MultiChoiceDialog, self).close()
+
+if __name__ == '__main__':
+    main()

readme.md

@@ -0,0 +1,36 @@
+PlayStream
+==========
+
+Kodi plugin to to play various online streams (mostly Latvian).
+Stream sources are in  subfolder "resources/lib/sources", and can be added/customized
+Currently implemented:
+- Main menu and manual stream definition in sources/streams.cfg file
+- **replay.lsm.lv** - Latvian TV live streams and archive (Latvian)
+- **skaties.lv** - skaties.lv streams (Latvian LNT, TV3, TV3+, TV6, TV2)
+- **lattelecom.tv(shortcut.lv)** - live, archive and video (Latvian, English, Russian), account required
+- **play24.lv** - RigaTV24 live and archive (Latvian)
+- **viaplay.lv** - video streams (partly working, only non-DRM - Latvian, Russian)
+- **LMT straume** - LMT video streams (Latvian)
+- **cinemalive.tv** - movies and series in Latvian (partly working)
+- **movieplace.lv** - movies and series in Latvian (partly working)
+- **dom.tv** - live and archive of Latvian and Russion TV channels, registration required
+- **BBC iPlayer** - BBC live and archive, UK IP address (VPN) required
+- **Euronews** - Euronews live and archive
+- **filmon.tv** - media portal content
+- **ustvnow.tv** - USA live TV (only SD), registration required
+- **filmix.net** - movies and series in Russian
+- **serialguru.ru** - movies and series in Russian (partly working)
+
+
+---
+Copyright (c) 2016 ivars777 (ivars777@gmail.com)
+Distributed under the GNU GPL v3. For full terms see http://www.gnu.org/licenses/gpl-3.0.en.html
+Used fragments of code from
+- enigma2-plugin-tv3play by Taapat (https://github.com/Taapat/enigma2-plugin-tv3play)
+- Kodi plugin script.module.stream.resolver (https://github.com/kodi-czsk/script.module.stream.resolver)
+- enigma2-plugin-youtube by Taapat (https://github.com/Taapat/enigma2-plugin-youtube), originally from https://github.com/rg3/youtube-dl/blob/master/youtube_dl
+
+
+
+
+

run.py

@@ -0,0 +1,10 @@
+#!C:\Python27\python2.7.exe
+# EASY-INSTALL-ENTRY-SCRIPT: 'xbmcswift2==0.3.0','console_scripts','xbmcswift2'
+__requires__ = 'xbmcswift2==0.3.0'
+import sys
+from pkg_resources import load_entry_point
+#import xbmcswift2
+
+if __name__ == '__main__':
+    sys.exit(load_entry_point('xbmcswift2==0.3.0', 'console_scripts', 'xbmcswift2')())
+    #xbmcswift2.Plugin.run()

service.py

@@ -0,0 +1,38 @@
+# -*- coding: utf-8 -*-
+try:
+    import wingdbstub
+except:
+    pass
+import os,os.path,sys, urllib, traceback
+from kodiswift import Plugin, ListItem, storage
+from kodiswift import xbmc, xbmcgui, xbmcplugin, xbmcvfs, CLI_MODE
+#from resources.lib import ContentSources, util
+#sys.path.insert(0, os.path.join(os.path.dirname(os.path.abspath(__file__)),"resources","lib","sources"))
+from  resources.lib.content import playstreamproxy
+from downloadqueue import DownloadQueue
+
+#monitor = xbmc.Monitor()
+
+plugin = Plugin()
+plugin.load_addon_settings()
+autostart = plugin.get_setting("general_autostart", bool)
+
+queue_dir = os.path.join(xbmc.translatePath("special://temp"), "download_queue") if not CLI_MODE else "download_queue"
+download_queue = DownloadQueue(queue_dir)
+download_queue.clear()  # TODO restarte nepabeigtos uzdevumus varbut?
+
+if autostart:
+    xbmc.executebuiltin("RunAddon(plugin.video.playstream)")
+# view_mode = plugin.get_setting("view_mode", str)
+
+port = plugin.get_setting("general_port",int)
+start_proxy = plugin.get_setting("general_proxy",bool)
+host = "localhost"
+if start_proxy:
+    plugin.notify("Starting playstreamproxy","Info",10000, xbmcgui.NOTIFICATION_INFO)
+    try:
+        playstreamproxy.start(host, port)
+    except Exception as e:
+        xbmcgui.Dialog().ok("Error starting playstreamproxyserver",unicode(e))
+        #plugin.notify(unicode(e), "Error", 10000, xbmcgui.NOTIFICATION_ERROR)
+        traceback.print_exc()

unlink.bat

@@ -0,0 +1,2 @@
+set plugin_name=plugin.video.playstream
+rmdir \users\user\AppData\Roaming\Kodi\addons\%plugin%

wingdbstub.py

@@ -0,0 +1,320 @@
+#########################################################################
+""" wingdbstub.py    -- Debug stub for debuggifying Python programs
+
+Copyright (c) 1999-2001, Archaeopteryx Software, Inc.  All rights reserved.
+
+Written by Stephan R.A. Deibel and John P. Ehresman
+
+Usage:
+-----
+
+This is the file that Wing DB users copy into their python project 
+directory if they want to be able to debug programs that are launched
+outside of the IDE (e.g., CGI scripts, in response to a browser page
+load).
+
+To use this, edit the configuration values below to match your 
+Wing installation and requirements of your project.
+
+Then, add the following line to your code:
+
+  import wingdbstub
+
+Debugging will start immediately after this import statements.
+
+Next make sure that your IDE is running and that it's configured to accept
+connections from the host the debug program will be running on.
+
+Now, invoking your python file should run the code within the debugger.
+Note, however, that Wing will not stop in the code unless a breakpoint
+is set.
+
+If the debug process is started before the IDE, or is not listening
+at the time this module is imported then the program will run with
+debugging until an attach request is seen.  Attaching only works 
+if the .wingdebugpw file is present; see the manual for details.
+
+On win32, you either need to edit WINGHOME in this script or
+pass in an environment variable called WINGHOME that points to
+the Wing installation directory.
+
+"""
+#########################################################################
+
+import sys
+import os
+import imp
+
+
+#------------------------------------------------------------------------
+# Default configuration values:  Note that the named environment 
+# variables, if set, will override these settings.
+
+# Set this to 1 to disable all debugging; 0 to enable debugging
+# (WINGDB_DISABLED environment variable)
+kWingDebugDisabled = 0
+
+# Host:port of the IDE within which to debug: As configured in the IDE
+# with the Server Port preference
+# (WINGDB_HOSTPORT environment variable)
+kWingHostPort = 'localhost:50005'
+
+# Port on which to listen for connection requests, so that the
+# IDE can (re)attach to the debug process after it has started.
+# Set this to '-1' to disable listening for connection requests.
+# This is only used when the debug process is not attached to
+# an IDE or the IDE has dropped its connection. The configured
+# port can optionally be added to the IDE's Common Attach Hosts
+# preference. Note that a random port is used instead if this 
+# port is already in use!
+# (WINGDB_ATTACHPORT environment variable)
+kAttachPort = '50015'
+
+# Set this to a filename to log verbose information about the debugger
+# internals to a file.  If the file does not exist, it will be created
+# as long as its enclosing directory exists and is writeable.  Use 
+# "<stderr>" or "<stdout>".  Note that "<stderr>" may cause problems 
+# on win32 if the debug process is not running in a console.
+# (WINGDB_LOGFILE environment variable)
+kLogFile = None
+
+# Set to get a tremendous amount of logging from the debugger internals
+# (WINGDB_LOGVERYVERBOSE)
+kLogVeryVerbose = 0
+
+# Set this to 1 when debugging embedded scripts in an environment that
+# creates and reuses a Python instance across multiple script invocations:  
+# It turns off automatic detection of program quit so that the debug session
+# can span multiple script invocations.  When this is turned on, you may
+# need to call ProgramQuit() on the debugger object to shut down the
+# debugger cleanly when your application exits or discards the Python
+# instance.  If multiple Python instances are created in the same run,
+# only the first one will be able to debug unless it terminates debug
+# and the environment variable WINGDB_ACTIVE is unset before importing
+# this module in the second or later Python instance.  See the Wing
+# IDE manual for details.
+kEmbedded = 0
+
+# Path to search for the debug password file and the name of the file
+# to use.  The password file contains the encryption type and connect 
+# password for all connections to the IDE and must match the wingdebugpw
+# file in the profile dir used by the IDE.  Any entry of '$<winguserprofile>' 
+# is replaced by the wing user profile directory for the user that the 
+# current process is running as
+# (WINGDB_PWFILEPATH environment variable)
+kPWFilePath = [os.path.dirname(__file__), '$<winguserprofile>']
+kPWFileName = 'wingdebugpw'
+
+# Whether to exit if the debugger fails to run or to connect with an IDE
+# for whatever reason
+kExitOnFailure = 0
+
+#------------------------------------------------------------------------
+# Find Wing debugger installation location
+
+# Edit this to point to your Wing installation or set to None to use env WINGHOME
+# On OS X this must be set to name of the Wing application bundle
+# (for example, /Applications/WingIDE.app)
+WINGHOME = None
+
+if sys.hexversion >= 0x03000000:
+  def has_key(o, key):
+    return key in o
+else:
+  def has_key(o, key):
+    return o.has_key(key)
+    
+# Check environment:  Must have WINGHOME defined if still == None
+if WINGHOME == None:
+  if has_key(os.environ, 'WINGHOME'):
+    WINGHOME=os.environ['WINGHOME']
+  else:
+    sys.stdout.write("*******************************************************************\n")
+    sys.stdout.write("Error: Could not find Wing installation!  You must set WINGHOME or edit\n")
+    sys.stdout.write("wingdbstub.py where indicated to point it to the location where\n")
+    sys.stdout.write("Wing is installed.\n")
+    sys.exit(1)
+
+kPWFilePath.append(WINGHOME)
+
+# The user settings dir where per-user settings & patches are located.  Will be
+# set from environment if left as None
+kUserSettingsDir = None
+if kUserSettingsDir is None:
+  kUserSettingsDir = os.environ.get('WINGDB_USERSETTINGS')
+  
+def _FindActualWingHome(winghome):
+  """ Find the actual directory to use for winghome.  Needed on OS X
+  where the .app directory is the preferred dir to use for WINGHOME and
+  .app/Contents/MacOS is accepted for backward compatibility. """
+  
+  if sys.platform != 'darwin':
+    return winghome
+  
+  app_dir = None
+  if os.path.isdir(winghome):
+    if winghome.endswith('/'):
+      wo_slash = winghome[:-1]
+    else:
+      wo_slash = winghome
+      
+    if wo_slash.endswith('.app'):
+      app_dir = wo_slash
+    elif wo_slash.endswith('.app/Contents/MacOS'):
+      app_dir = wo_slash[:-len('/Contents/MacOS')]
+    
+  if app_dir and os.path.isdir(os.path.join(app_dir, 'Contents', 'Resources')):
+    return os.path.join(app_dir, 'Contents', 'Resources')
+  
+  return winghome
+  
+def _ImportWingdb(winghome, user_settings=None):
+  """ Find & import wingdb module. """
+  
+  try:
+    exec_dict = {}
+    execfile(os.path.join(winghome, 'bin', '_patchsupport.py'), exec_dict)
+    find_matching = exec_dict['FindMatching']
+    dir_list = find_matching('bin', winghome, user_settings)
+  except Exception:
+    dir_list = []
+  dir_list.extend([os.path.join(winghome, 'bin'), os.path.join(winghome, 'src')])
+  for path in dir_list:
+    try:
+      f, p, d = imp.find_module('wingdb', [path])
+      try:
+        return imp.load_module('wingdb', f, p, d)
+      finally:
+        if f is not None:
+          f.close()
+      break
+    except ImportError:
+      pass
+
+#------------------------------------------------------------------------
+# Set debugger if it hasn't been set -- this is to handle module reloading
+# In the reload case, the debugger variable will be set to something
+try:
+  debugger
+except NameError:
+  debugger = None
+  
+# Unset WINGDB_ACTIVE env if it was inherited from another process
+# XXX Would be better to be able to call getpid() on dbgtracer but can't access it yet
+if 'WINGDB_ACTIVE' in os.environ and os.environ['WINGDB_ACTIVE'] != str(os.getpid()):
+  del os.environ['WINGDB_ACTIVE']
+
+# Start debugging if not disabled and this module has never been imported
+# before
+if (not kWingDebugDisabled and debugger is None
+    and not has_key(os.environ, 'WINGDB_DISABLED') and 
+    not has_key(os.environ, 'WINGDB_ACTIVE')):
+
+  exit_on_fail = 0
+  
+  try:
+    # Obtain exit if fails value
+    exit_on_fail = os.environ.get('WINGDB_EXITONFAILURE', kExitOnFailure)
+    
+    # Obtain configuration for log file to use, if any
+    logfile = os.environ.get('WINGDB_LOGFILE', kLogFile)
+    if logfile == '-' or logfile == None or len(logfile.strip()) == 0:
+      logfile = None
+
+    very_verbose_log = os.environ.get('WINGDB_LOGVERYVERBOSE', kLogVeryVerbose)
+    if type(very_verbose_log) == type('') and very_verbose_log.strip() == '':
+      very_verbose_log = 0
+      
+    # Determine remote host/port where the IDE is running
+    hostport = os.environ.get('WINGDB_HOSTPORT', kWingHostPort)
+    colonpos = hostport.find(':')
+    host = hostport[:colonpos]
+    port = int(hostport[colonpos+1:])
+  
+    # Determine port to listen on locally for attach requests
+    attachport = int(os.environ.get('WINGDB_ATTACHPORT', kAttachPort))
+  
+    # Check if running embedded script
+    embedded = int(os.environ.get('WINGDB_EMBEDDED', kEmbedded))
+  
+    # Obtain debug password file search path
+    if has_key(os.environ, 'WINGDB_PWFILEPATH'):
+      pwfile_path = os.environ['WINGDB_PWFILEPATH'].split(os.pathsep)
+    else:
+      pwfile_path = kPWFilePath
+    
+    # Obtain debug password file name
+    if has_key(os.environ, 'WINGDB_PWFILENAME'):
+      pwfile_name = os.environ['WINGDB_PWFILENAME']
+    else:
+      pwfile_name = kPWFileName
+    
+    # Load wingdb.py
+    actual_winghome = _FindActualWingHome(WINGHOME)
+    wingdb = _ImportWingdb(actual_winghome, kUserSettingsDir)
+    if wingdb == None:
+      sys.stdout.write("*******************************************************************\n")
+      sys.stdout.write("Error: Cannot find wingdb.py in $(WINGHOME)/bin or $(WINGHOME)/src\n")
+      sys.stdout.write("Error: Please check the WINGHOME definition in wingdbstub.py\n")
+      sys.exit(2)
+    
+    # Find the netserver module and create an error stream
+    netserver = wingdb.FindNetServerModule(actual_winghome, kUserSettingsDir)
+    err = wingdb.CreateErrStream(netserver, logfile, very_verbose_log)
+    
+    # Start debugging
+    debugger = netserver.CNetworkServer(host, port, attachport, err, 
+                                        pwfile_path=pwfile_path,
+                                        pwfile_name=pwfile_name,
+                                        autoquit=not embedded)
+    debugger.StartDebug(stophere=0)
+    os.environ['WINGDB_ACTIVE'] = str(os.getpid())
+    if debugger.ChannelClosed():
+      raise ValueError('Not connected')
+    
+  except:
+    if exit_on_fail:
+      raise
+    else:
+      pass
+
+def Ensure(require_connection=1, require_debugger=1):
+  """ Ensure the debugger is started and attempt to connect to the IDE if
+  not already connected.  Will raise a ValueError if:
+  
+  * the require_connection arg is true and the debugger is unable to connect
+  * the require_debugger arg is true and the debugger cannot be loaded
+  
+  If SuspendDebug() has been called through the low-level API, calling
+  Ensure() resets the suspend count to zero and additional calls to
+  ResumeDebug() will be ignored until SuspendDebug() is called again.
+  
+  Note that a change to the host & port to connect to will only
+  be use if a new connection is made.
+  
+  """
+  
+  if debugger is None:
+    if require_debugger:
+      raise ValueError("No debugger")
+    return
+
+  hostport = os.environ.get('WINGDB_HOSTPORT', kWingHostPort)
+  colonpos = hostport.find(':')
+  host = hostport[:colonpos]
+  port = int(hostport[colonpos+1:])
+  
+  resumed = debugger.ResumeDebug()
+  while resumed > 0:
+    resumed = debugger.ResumeDebug()
+  
+  debugger.SetClientAddress((host, port))  
+  
+  if not debugger.DebugActive():
+    debugger.StartDebug()
+  elif debugger.ChannelClosed():
+    debugger.ConnectToClient()
+    
+  if require_connection and debugger.ChannelClosed():
+    raise ValueError('Not connected')
+