Automatic download manager for binaries

.gitattributes

@@ -0,0 +1,10 @@
+*_test.py export-ignore  
+*.pyo export-ignore
+.idea/ export-ignore
+*.sln export-ignore 
+*.pyproj export-ignore 
+*.suo export-ignore 
+*.zip export-ignore
+*.exe export-ignore
+.gitattributes export-ignore  
+.gitignore export-ignore

.gitignore

@@ -1,3 +1,5 @@
 .idea/
 *.py[cod]
-bin/
+*.pyproj
+*.suo
+*.exe

addon.xml

@@ -1,9 +1,14 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
-<addon id="script.module.torrent2http" name="torrent2http" version="0.1.0" provider-name="anteo">
+<addon id="script.module.torrent2http" name="torrent2http" version="0.2.6" provider-name="anteo,DiMartino,-=Vd=-">
     <requires>
         <import addon="xbmc.python" version="2.14.0"/>
+		<import addon="script.module.requests" optional="false"/>
     </requires>
     <extension point="xbmc.python.module" library="lib"/>
+	<extension point="xbmc.python.script" library="main.py">
+		<provides>executable</provides>
+	</extension>
+	<extension point="xbmc.service" library="service.py" start="startup" />
     <extension point="xbmc.addon.metadata">
         <platform>all</platform>
         <language>en</language>

bin/android_arm/torrent2http.size.txt

@@ -0,0 +1 @@
+30366960

bin/darwin_x64/torrent2http.size.txt

@@ -0,0 +1 @@
+26146540

bin/linux_aarch64/torrent2http.size.txt

@@ -0,0 +1 @@
+25809824

bin/linux_arm/torrent2http.size.txt

@@ -0,0 +1 @@
+24466041

bin/linux_armv6/torrent2http.size.txt

@@ -0,0 +1 @@
+24522477

bin/linux_x64/torrent2http.size.txt

@@ -0,0 +1 @@
+29381937

bin/linux_x86/torrent2http.size.txt

@@ -0,0 +1 @@
+25228652

bin/public.py

@@ -0,0 +1,63 @@
+#-*- coding: utf-8 -*-
+'''
+    Torrenter v2 plugin for XBMC/Kodi
+    Copyright (C) 2015 srg70, RussakHH, DiMartino
+'''
+
+import os
+
+def get_libname(platform):
+    return ["torrent2http" + (".exe" if 'windows' in platform else "")]
+
+class Public:
+    def __init__( self ):
+        self.platforms=[]
+        self.root=os.path.dirname(__file__)
+        for dir in os.listdir(self.root):
+            if os.path.isdir(os.path.join(self.root,dir)):
+                self.platforms.append(dir)
+        self._generate_size_file()
+
+    def _generate_size_file( self ):
+        for platform in self.platforms:
+            for libname in get_libname(platform):
+                self.libname=libname
+                self.platform=platform
+                self.libdir = os.path.join(self.root, self.platform)
+                self.libpath = os.path.join(self.libdir, self.libname)
+                self.sizepath=self.libpath+'.size.txt'
+                self.zipname=self.libname+'.zip'
+                zippath=os.path.join(self.libdir, self.zipname)
+                system=platform+'/'
+                if os.path.exists(self.libpath):
+                    if not os.path.exists(self.sizepath):
+                        print system+self.libname+' NO SIZE'
+                        self._makezip()
+                    elif not os.path.exists(zippath):
+                        print system+self.libname+' NO ZIP'
+                        self._makezip()
+                    else:
+                        size=str(os.path.getsize(self.libpath))
+                        size_old=open( self.sizepath, "r" ).read()
+                        if size_old!=size:
+                            print system+self.libname+' NOT EQUAL'
+                            self._makezip()
+                        else:
+                            print system+self.libname+' NO ACTION'
+                else:
+                    print system+self.libname+' NO LIB'
+
+    def _makezip(self):
+        open( self.sizepath, "w" ).write( str(os.path.getsize(self.libpath)) )
+        os.chdir(self.libdir)
+        os.system('del %s' % (self.zipname))
+        os.system('"C:\\Program Files\\7-Zip\\7z.exe" a %s.zip %s' %
+                  (self.libname, self.libname))
+        os.chdir(self.root)
+        #os.system('"C:\\Program Files\\7-Zip\\7z.exe" a %s.zip %s' %
+        #          (self.platform['system']+os.sep+self.libname, self.platform['system']+os.sep+self.libname))
+
+if ( __name__ == "__main__" ):
+    # start
+    #TODO: publicate
+    Public()

bin/windows_x86/torrent2http.exe.size.txt

@@ -0,0 +1 @@
+22362887

changelog.txt

@@ -1,3 +1,21 @@
+[B]Version 0.2.1[/B]
++ WebUI (http://<host>:<port>/stat) by -=Vd=-
+
+[B]Version 0.2.0[/B]
++ Client\server mode, remote execution, standalone version by -=Vd=-
+
+[B]Version 0.1.4[/B]
++ Unix ARM x64 (aarch64) by srg70
+
+[B]Version 0.1.3[/B]
++ Android execute fix
+
+[B]Version 0.1.2[/B]
++ Torrent2http binaries for Raspberry Pi v1 (arm v6)
+
+[B]Version 0.1.1[/B]
++ Automatic download manager for binaries
+
 [B]Version 0.1.0[/B]
 + Torrent2http binaries updated to 1.0.5
 + Added Android Lollipop 5/Marshmallow 6 ARM support

lib/torrent2http/__init__.py

@@ -39,6 +39,17 @@ class Encryption:
 PeerInfo = namedtuple('PeerInfo', "ip, flags, source, up_speed, down_speed, total_upload, total_download, "
                                   "country, client")
 
-from engine import Engine
+from remote.remotesettings import *
+
+s = Settings()
+
+try:
+	if s.role == 'client':
+		from remote.remoteengine import ClientEngine as Engine
+	else:
+		from engine import Engine
+except:
+	from engine import Engine
+
 from platform import Platform
 from error import Error

lib/torrent2http/download.py

@@ -0,0 +1,65 @@
+#import sys
+import os
+import xbmc, xbmcgui, xbmcvfs, xbmcaddon
+from net import HTTP
+
+__libbaseurl__ = "https://github.com/DiMartinoXBMC/script.module.torrent2http/raw/master/bin"
+__settings__ = xbmcaddon.Addon(id='script.module.torrent2http')
+__version__ = __settings__.getAddonInfo('version')
+__plugin__ = __settings__.getAddonInfo('name') + " v." + __version__
+
+def get_libname(platform):
+    return ["torrent2http" + (".exe" if 'windows' in platform else "")]
+
+def log(msg):
+    try:
+        xbmc.log("### [%s]: %s" % (__plugin__,msg,), level=xbmc.LOGNOTICE )
+    except UnicodeEncodeError:
+        xbmc.log("### [%s]: %s" % (__plugin__,msg.encode("utf-8", "ignore"),), level=xbmc.LOGNOTICE )
+    except:
+        xbmc.log("### [%s]: %s" % (__plugin__,'ERROR LOG',), level=xbmc.LOGNOTICE )
+
+def getSettingAsBool(setting):
+    return __settings__.getSetting(setting).lower() == "true"
+
+class LibraryManager():
+    def __init__(self, dest_path, platform):
+        self.dest_path = dest_path
+        self.platform = platform
+
+    def check_update(self):
+        need_update=False
+        if __settings__.getSetting('plugin_name')!=__plugin__:
+            __settings__.setSetting('plugin_name', __plugin__)
+            for libname in get_libname(self.platform):
+                self.libpath = os.path.join(self.dest_path, libname)
+                self.sizepath=os.path.join(self.dest_path, libname+'.size.txt')
+                size=str(os.path.getsize(self.libpath))
+                size_old=open( self.sizepath, "r" ).read()
+                if size_old!=size:
+                    need_update=True
+        return need_update
+
+    def update(self):
+        if self.check_update():
+            for libname in get_libname(self.platform):
+                self.libpath = os.path.join(self.dest_path, libname)
+                xbmcvfs.delete(self.libpath)
+            self.download()
+
+    def download(self):
+        xbmcvfs.mkdirs(self.dest_path)
+        for libname in get_libname(self.platform):
+            dest = os.path.join(self.dest_path, libname)
+            log("try to fetch %s" % libname)
+            url = "%s/%s/%s.zip" % (__libbaseurl__, self.platform, libname)
+            try:
+                self.http = HTTP()
+                self.http.fetch(url, download=dest + ".zip", progress=True)
+                log("%s -> %s" % (url, dest))
+                xbmc.executebuiltin('XBMC.Extract("%s.zip","%s")' % (dest, self.dest_path), True)
+                xbmcvfs.delete(dest + ".zip")
+            except:
+                text = 'Failed download %s!' % libname
+                xbmc.executebuiltin("XBMC.Notification(%s,%s,%s)" % (__plugin__,text,750))
+        return True

lib/torrent2http/engine.py

@@ -9,6 +9,7 @@
 import urllib2
 import httplib
 from os.path import dirname
+from download import LibraryManager
 
 import logpipe
 import mimetypes
@@ -29,8 +30,12 @@ class Engine:
     def _ensure_binary_executable(self, path):
         st = os.stat(path)
         if not st.st_mode & stat.S_IEXEC:
-            self._log("%s is not executable, trying to change its mode..." % path)
-            os.chmod(path, st.st_mode | stat.S_IEXEC)
+            try:
+                self._log("%s is not executable, trying to change its mode..." % path)
+                os.chmod(path, st.st_mode | stat.S_IEXEC)
+            except Exception, e:
+                self._log("Failed! Exception: %s" % str(e))
+                return False
             st = os.stat(path)
             if st.st_mode & stat.S_IEXEC:
                 self._log("Succeeded")
@@ -53,12 +58,24 @@ def _get_binary_path(self, binaries_path):
         :param binaries_path:
         :return: torrent2http binary path
         """
+
+        arch = self.platform.arch
+        # Always use 32 bit binary on Windows
+        if self.platform.system == 'windows':
+            arch = arch.replace('x64', 'x86')
+
         binary = "torrent2http" + (".exe" if self.platform.system == 'windows' else "")
-        binary_dir = os.path.join(binaries_path, "%s_%s" % (self.platform.system, self.platform.arch))
+        binary_dir = os.path.join(binaries_path, "%s_%s" % (self.platform.system, arch))
+
         binary_path = os.path.join(binary_dir, binary)
+        lm=LibraryManager(binary_dir, "%s_%s" % (self.platform.system, arch))
         if not os.path.isfile(binary_path):
-            raise Error("Can't find torrent2http binary for %s" % self.platform,
-                        Error.UNKNOWN_PLATFORM, platform=str(self.platform))
+            success=lm.download()
+            if not success:
+                raise Error("Can't find torrent2http or download binary for %s" % self.platform,
+                            Error.UNKNOWN_PLATFORM, platform=str(self.platform))
+        #This is needed only if bin in folder that not deletes on update!
+        #else: lm.update()
 
         if not self._ensure_binary_executable(binary_path):
             if self.platform.system == "android":
@@ -472,6 +489,7 @@ def close(self):
                 else:
                     self._log("torrent2http successfully shut down.")
                 self.wait_on_close_timeout = None
+            self.process.wait()
         self.started = False
         self.logpipe = None
         self.process = None

lib/torrent2http/mimetypes.py

@@ -246,7 +246,7 @@ def enum_types(mimedb):
                 except EnvironmentError:
                     break
                 try:
-                    ctype = ctype.encode(default_encoding) # omit in 3.x!
+                    ctype = ctype#.encode(default_encoding) # omit in 3.x!
                 except UnicodeEncodeError:
                     pass
                 else: