# -*- coding: utf-8 -*- # vStream https://github.com/Kodi-vStream/venom-xbmc-addons # vstream = xbmcaddon.Addon('plugin.video.vstream') # sLibrary = VSPath(vstream.getAddonInfo("path")).decode("utf-8") # sys.path.append (sLibrary) import json import xbmcvfs import xbmc import xbmcgui import sys try: # Python 2 import urllib2 except ImportError: # Python 3 import urllib.request as urllib2 from resources.lib.comaddon import addon, dialog, VSlog, window, VSPath, siteManager try: from sqlite3 import dbapi2 as sqlite VSlog('SQLITE 3 as DB engine') except: from pysqlite2 import dbapi2 as sqlite VSlog('SQLITE 2 as DB engine') SITE_IDENTIFIER = 'runscript' SITE_NAME = 'runscript' class cClear: DIALOG = dialog() ADDON = addon() def __init__(self): self.main(sys.argv[1]) def main(self, env): if (env == 'urlresolver'): addon('script.module.urlresolver').openSettings() return if (env == 'metahandler'): addon('script.module.metahandler').openSettings() return if (env == 'changelog_old'): sUrl = 'https://raw.githubusercontent.com/Kodi-vStream/venom-xbmc-addons/master/plugin.video.vstream/changelog.txt' try: oRequest = urllib2.Request(sUrl) oResponse = urllib2.urlopen(oRequest) # En python 3 on doit décoder la reponse if xbmc.getInfoLabel('system.buildversion')[0:2] >= '19': sContent = oResponse.read().decode('utf-8') else: sContent = oResponse.read() self.TextBoxes('vStream Changelog', sContent) except: self.DIALOG.VSerror("%s, %s" % (self.ADDON.VSlang(30205), sUrl)) return if (env == 'changelog'): class XMLDialog(xbmcgui.WindowXMLDialog): def __init__(self, *args, **kwargs): xbmcgui.WindowXMLDialog.__init__(self) pass def onInit(self): self.container = self.getControl(6) self.button = self.getControl(5) self.getControl(3).setVisible(False) self.getControl(1).setLabel('ChangeLog') self.button.setLabel('OK') sUrl = 'https://api.github.com/repos/Kodi-vStream/venom-xbmc-addons/commits' oRequest = urllib2.Request(sUrl) oResponse = urllib2.urlopen(oRequest) # En python 3 on doit décoder la reponse if xbmc.getInfoLabel('system.buildversion')[0:2] >= '19': sContent = oResponse.read().decode('utf-8') else: sContent = oResponse.read() result = json.loads(sContent) listitems = [] for item in result: # autor icon = item['author']['avatar_url'] login = item['author']['login'] # message try: desc = item['commit']['message'].encode("utf-8") except: desc = 'None' listitem = xbmcgui.ListItem(label=login, label2=desc) listitem.setArt({'icon': icon, 'thumb': icon}) listitems.append(listitem) self.container.addItems(listitems) self.setFocus(self.container) def onClick(self, controlId): self.close() return def onFocus(self, controlId): self.controlId = controlId def _close_dialog(self): self.close() path = "special://home/addons/plugin.video.vstream" wd = XMLDialog('DialogSelect.xml', path, "Default") wd.doModal() del wd return if (env == 'soutient'): sUrl = 'https://raw.githubusercontent.com/Kodi-vStream/venom-xbmc-addons/master/plugin.video.vstream/soutient.txt' try: oRequest = urllib2.Request(sUrl) oResponse = urllib2.urlopen(oRequest) # En python 3 on doit décoder la reponse if xbmc.getInfoLabel('system.buildversion')[0:2] >= '19': sContent = oResponse.read().decode('utf-8') else: sContent = oResponse.read() self.TextBoxes('vStream Soutient', sContent) except: self.DIALOG.VSerror("%s, %s" % (self.ADDON.VSlang(30205), sUrl)) return if (env == 'clean'): liste = ['Historiques des recherches', 'Marque-Pages', 'En cours de lecture', 'Niveau de lecture', 'Marqués vues', 'Téléchargements'] ret = self.DIALOG.VSselect(liste, self.ADDON.VSlang(30110)) cached_DB = "special://home/userdata/addon_data/plugin.video.vstream/vstream.db" # important seul xbmcvfs peux lire le special try: cached_DB = VSPath(cached_DB).decode("utf-8") except AttributeError: cached_DB = VSPath(cached_DB) sql_drop = "" if ret > -1: if ret == 0: sql_drop = 'DELETE FROM history' elif ret == 1: sql_drop = 'DELETE FROM favorite' elif ret == 2: sql_drop = 'DELETE FROM viewing' elif ret == 3: sql_drop = 'DELETE FROM resume' elif ret == 4: sql_drop = 'DELETE FROM watched' elif ret == 5: sql_drop = 'DELETE FROM download' try: db = sqlite.connect(cached_DB) dbcur = db.cursor() dbcur.execute(sql_drop) db.commit() dbcur.close() db.close() self.DIALOG.VSok(self.ADDON.VSlang(30090)) except Exception as err: self.DIALOG.VSerror(self.ADDON.VSlang(30091)) VSlog("Exception runscript sql_drop: {0}".format(err)) return # activer toutes les sources if (env == 'enableSources'): if self.DIALOG.VSyesno(self.ADDON.VSlang(30456)): sitesManager = siteManager() sitesManager.enableAll() sitesManager.save() self.DIALOG.VSinfo(self.ADDON.VSlang(30014)) return # désactiver toutes les sources if (env == 'disableSources' or env == 'disableSourcesSilent' ): if env == 'disableSources' and not self.DIALOG.VSyesno(self.ADDON.VSlang(30456)): return sitesManager = siteManager() sitesManager.disableAll() sitesManager.save() self.DIALOG.VSinfo(self.ADDON.VSlang(30014)) return # aciver/désactiver les sources if (env == 'search'): from resources.lib.handler.pluginHandler import cPluginHandler valid = '[COLOR green][x][/COLOR]' class XMLDialog(xbmcgui.WindowXMLDialog): ADDON = addon() sitesManager = siteManager() def __init__(self, *args, **kwargs): xbmcgui.WindowXMLDialog.__init__(self) pass def onInit(self): self.container = self.getControl(6) self.button = self.getControl(5) self.getControl(3).setVisible(False) self.getControl(1).setLabel(self.ADDON.VSlang(30094)) self.button.setLabel('OK') listitems = [] oPluginHandler = cPluginHandler() aPlugins = oPluginHandler.getAllPlugins() #self.data = json.load(open(self.path)) for aPlugin in aPlugins: # teste si deja dans le dsip sPluginName = aPlugin[1] isActive = self.sitesManager.isActive(sPluginName) icon = "special://home/addons/plugin.video.vstream/resources/art/sites/%s.png" % sPluginName stitle = self.sitesManager.getProperty(sPluginName, self.sitesManager.LABEL) if isActive: stitle = ('%s %s') % (stitle, valid) listitem = xbmcgui.ListItem(label=stitle, label2=aPlugin[2]) listitem.setArt({'icon': icon, 'thumb': icon}) listitem.setProperty('Addon.Summary', aPlugin[2]) listitem.setProperty('sitename', aPlugin[1]) if isActive: listitem.select(True) listitems.append(listitem) self.container.addItems(listitems) self.setFocus(self.container) def onClick(self, controlId): if controlId == 5: # OK self.sitesManager.save() self.close() return elif controlId == 99: window = xbmcgui.Window(xbmcgui.getCurrentWindowId()) del window self.close() return elif controlId == 7: window = xbmcgui.Window(xbmcgui.getCurrentWindowId()) del window self.close() return elif controlId == 6: item = self.container.getSelectedItem() if item.isSelected() == True: label = item.getLabel().replace(valid, '') item.setLabel(label) item.select(False) sPluginSettingsName = item.getProperty('sitename') self.sitesManager.setActive(sPluginSettingsName, False) else: label = ('%s %s') % (item.getLabel(), valid) item.setLabel(label) item.select(True) sPluginSettingsName = item.getProperty('sitename') self.sitesManager.setActive(sPluginSettingsName, True) return def onFocus(self, controlId): self.controlId = controlId path = "special://home/addons/plugin.video.vstream" wd = XMLDialog('DialogSelect.xml', path, "Default") wd.doModal() del wd return if (env == 'sauv'): select = self.DIALOG.VSselect(['Import', 'Export']) DB = "special://home/userdata/addon_data/plugin.video.vstream/vstream.db" if select >= 0: try: if select == 0: # sélection d'un fichier new = self.DIALOG.VSbrowse(1, 'vStream', "files") if new: xbmcvfs.delete(DB) xbmcvfs.copy(new, DB) self.DIALOG.VSinfo(self.ADDON.VSlang(30099)) elif select == 1: # sélection d'un répertoire new = self.DIALOG.VSbrowse(3, 'vStream', "files") if new: xbmcvfs.copy(DB, new + 'vstream.db') self.DIALOG.VSinfo(self.ADDON.VSlang(30099)) except: self.DIALOG.VSerror(self.ADDON.VSlang(30100)) return if (env == 'testpremium'): # tester un compte premium from resources.lib.gui.hoster import cHosterGui oHoster = cHosterGui().getHoster("alldebrid") oHoster.testPremium() return if (env == 'addon' or env == 'cleanAll'): # Vider le cache des métadonnées if env == 'cleanAll' or self.DIALOG.VSyesno(self.ADDON.VSlang(30456)): cached_Cache = "special://home/userdata/addon_data/plugin.video.vstream/video_cache.db" # important seul xbmcvfs peux lire le special try: cached_Cache = VSPath(cached_Cache).decode("utf-8") except AttributeError: cached_Cache = VSPath(cached_Cache) try: db = sqlite.connect(cached_Cache) dbcur = db.cursor() dbcur.execute('DELETE FROM movie') dbcur.execute('DELETE FROM tvshow') dbcur.execute('DELETE FROM saga') dbcur.execute('DELETE FROM season') dbcur.execute('DELETE FROM episode') db.commit() dbcur.close() db.close() if env != 'cleanAll': self.DIALOG.VSinfo(self.ADDON.VSlang(30090)) except: self.DIALOG.VSerror(self.ADDON.VSlang(30091)) if (env == 'xbmc' or env == 'cleanAll'): if env == 'cleanAll' or self.DIALOG.VSyesno(self.ADDON.VSlang(30456)): path = "special://temp/" try: xbmcvfs.rmdir(path, True) if env != 'cleanAll': self.DIALOG.VSok(self.ADDON.VSlang(30092)) except: self.DIALOG.VSerror(self.ADDON.VSlang(30093)) if (env == 'fi' or env == 'cleanAll'): if env == 'cleanAll' or self.DIALOG.VSyesno(self.ADDON.VSlang(30456)): path = "special://temp/archive_cache/" try: xbmcvfs.rmdir(path, True) if env != 'cleanAll': self.DIALOG.VSok(self.ADDON.VSlang(30095)) except: self.DIALOG.VSerror(self.ADDON.VSlang(30096)) if (env == 'thumb' or env == 'cleanAll'): if env == 'cleanAll' or self.DIALOG.VSyesno(self.ADDON.VSlang(30098)): text = False path = "special://userdata/Thumbnails/" path_DB = "special://userdata/Database" try: xbmcvfs.rmdir(path, True) text = 'Clear Thumbnail Folder, Successful[CR]' except: text = 'Clear Thumbnail Folder, Error[CR]' folder, items = xbmcvfs.listdir(path_DB) items.sort() for sItemName in items: if "extures" in sItemName: cached_Cache = "/".join([path_DB, sItemName]) try: xbmcvfs.delete(cached_Cache) text += 'Clear Thumbnail DB, Successful[CR]' except: text += 'Clear Thumbnail DB, Error[CR]' text = "%s [CR][COLOR Red]IMPORTANT[/COLOR] - Redémarrer Kodi" % text if env != 'cleanAll': self.DIALOG.VSok(text) return # def ClearDir(self, dir, clearNested=False): # try: # dir = dir.decode("utf8") # except: # pass # for the_file in os.listdir(dir): # file_path = os.path.join(dir, the_file).encode('utf-8') # if clearNested and os.path.isdir(file_path): # self.ClearDir(file_path, clearNested) # try: # os.rmdir(file_path) # except Exception as e: # print(str(e)) # else: # try: # os.unlink(file_path) # except Exception as e: # print str(e) # def ClearDir2(self, dir, clearNested=False): # try: # dir = dir.decode("utf8") # except: # pass # try: # os.unlink(dir) # except Exception as e: # print(str(e)) def TextBoxes(self, heading, anounce): # activate the text viewer window xbmc.executebuiltin("ActivateWindow(%d)" % 10147) # get window win = window(10147) # win.show() # give window time to initialize xbmc.sleep(100) # set heading win.getControl(1).setLabel(heading) win.getControl(5).setText(anounce) return cClear()