# -*- coding: utf-8 -*- # vStream https://github.com/Kodi-vStream/venom-xbmc-addons import xbmcplugin import xbmc import xbmcgui import json import xbmcaddon from resources.lib.comaddon import addon, dialog, isKrypton, VSlog, addonManager from resources.lib.db import cDb from resources.lib.gui.gui import cGui from resources.lib.handler.inputParameterHandler import cInputParameterHandler from resources.lib.handler.pluginHandler import cPluginHandler from resources.lib.upnext import UpNext from resources.lib.util import cUtil, Unquote, urlHostName from resources.lib.trakt import cTrakt from os.path import splitext # pour les sous titres # https://github.com/amet/service.subtitles.demo/blob/master/service.subtitles.demo/service.py # player API # http://mirrors.xbmc.org/docs/python-docs/stable/xbmc.html#Player class cPlayer(xbmc.Player): ADDON = addon() def __init__(self, *args): sPlayerType = self.__getPlayerType() xbmc.Player.__init__(self, sPlayerType) self.Subtitles_file = [] self.SubtitleActive = False oInputParameterHandler = cInputParameterHandler() self.sHosterIdentifier = oInputParameterHandler.getValue('sHosterIdentifier') self.sTitle = oInputParameterHandler.getValue('sFileName') if self.sTitle: self.sTitle = Unquote(self.sTitle) self.sCat = oInputParameterHandler.getValue('sCat') self.sSaison = oInputParameterHandler.getValue('sSeason') self.sEpisode = oInputParameterHandler.getValue('sEpisode') self.tvShowTitle = oInputParameterHandler.getValue('tvShowTitle') self.sSite = oInputParameterHandler.getValue('siteUrl') self.sSource = oInputParameterHandler.getValue('sourceName') self.sFav = oInputParameterHandler.getValue('sourceFav') self.saisonUrl = oInputParameterHandler.getValue('saisonUrl') self.nextSaisonFunc = oInputParameterHandler.getValue('nextSaisonFunc') self.movieUrl = oInputParameterHandler.getValue('movieUrl') self.movieFunc = oInputParameterHandler.getValue('movieFunc') self.sTmdbId = oInputParameterHandler.getValue('sTmdbId') self.sImdbId = oInputParameterHandler.getValue('sImdbId') self.playBackEventReceived = False self.playBackStoppedEventReceived = False self.forcestop = False VSlog('player initialized') def clearPlayList(self): oPlaylist = self.__getPlayList() oPlaylist.clear() def __getPlayList(self): return xbmc.PlayList(xbmc.PLAYLIST_VIDEO) def addItemToPlaylist(self, oGuiElement): oGui = cGui() oListItem = oGui.createListItem(oGuiElement) self.__addItemToPlaylist(oGuiElement, oListItem) def __addItemToPlaylist(self, oGuiElement, oListItem): oPlaylist = self.__getPlayList() oPlaylist.add(oGuiElement.getMediaUrl(), oListItem) def AddSubtitles(self, files): if type(files) is list or type(files) is tuple: self.Subtitles_file = files else: self.Subtitles_file.append(files) def run(self, oGuiElement, sUrl): # Vérification et récupération des IDs TMDB ou IMDb, puis attribution dans les propriétés 'ids' de script.trakt pour le scrobbling. if self.ADDON.getSetting('use_trakt_addon') == 'true': if self.sImdbId: ids = json.dumps({u'imdb': self.sImdbId}) xbmcgui.Window(10000).setProperty('script.trakt.ids', ids) elif not self.sTmdbId: if self.sTitle or self.tvShowTitle: if self.sCat: ctrakt = cTrakt() sType = ctrakt.convertCatToType(self.sCat) if sType != -1: self.sTmdbId = int(ctrakt.getTmdbID(self.sTitle, sType, oGuiElement.getItemValue('year'))) if self.sTmdbId: ids = json.dumps({u'tmdb': self.sTmdbId}) xbmcgui.Window(10000).setProperty('script.trakt.ids', ids) # Lancement d'une vidéo sans avoir arrêté la précédente if self.isPlaying(): sEpisode = str(oGuiElement.getEpisode()) if sEpisode: # la vidéo précédente doit être marquée comme VUE numEpisode = int(sEpisode) prevEpisode = numEpisode - 1 sPrevEpisode = '%02d' % prevEpisode self._setWatched(sPrevEpisode) else: self._setWatched() self.totalTime = 0 self.currentTime = 0 sPluginHandle = cPluginHandler().getPluginHandle() oGui = cGui() item = oGui._createListItem(oGuiElement) item.setPath(oGuiElement.getMediaUrl()) # Sous titres if self.Subtitles_file: try: item.setSubtitles(self.Subtitles_file) VSlog('Load SubTitle :' + str(self.Subtitles_file)) self.SubtitleActive = True except: VSlog("Can't load subtitle:" + str(self.Subtitles_file)) player_conf = self.ADDON.getSetting('playerPlay') # Si lien dash, methode prioritaire mpd = splitext(urlHostName(sUrl))[-1] in [".mpd", ".m3u8"] mpd |= '&ct=6&' in sUrl # mpd venant de ok.ru, n'a pas d'extension if mpd: if isKrypton() == True: addonManager().enableAddon('inputstream.adaptive') item.setProperty('inputstream', 'inputstream.adaptive') if '.m3u8' in sUrl: item.setProperty('inputstream.adaptive.manifest_type', 'hls') else: item.setProperty('inputstream.adaptive.manifest_type', 'mpd') xbmcplugin.setResolvedUrl(sPluginHandle, True, listitem=item) VSlog('Player use inputstream addon') else: dialog().VSerror('Nécessite kodi 17 minimum') return # 1 er mode de lecture elif player_conf == '0': self.play(sUrl, item) VSlog('Player use Play() method') # 2 eme mode non utilise elif player_conf == 'neverused': xbmc.executebuiltin('PlayMedia(' + sUrl + ')') VSlog('Player use PlayMedia() method') # 3 eme mode (defaut) else: xbmcplugin.setResolvedUrl(sPluginHandle, True, item) VSlog('Player use setResolvedUrl() method') # Attend que le lecteur démarre, avec un max de 20s for _ in range(20): if self.playBackEventReceived: break xbmc.sleep(1000) # active/désactive les sous-titres suivant l'option choisie dans la config if self.getAvailableSubtitleStreams(): if self.ADDON.getSetting('srt-view') == 'true': self.showSubtitles(True) else: self.showSubtitles(False) dialog().VSinfo('Des sous-titres sont disponibles', 'Sous-titres', 4) waitingNext = 0 while self.isPlaying() and not self.forcestop: try: self.currentTime = self.getTime() waitingNext += 1 if waitingNext == 180: # attendre un peu avant de chercher le prochain épisode d'une série self.totalTime = self.getTotalTime() self.infotag = self.getVideoInfoTag() UpNext().nextEpisode(oGuiElement) except Exception as err: VSlog("Exception run: {0}".format(err)) xbmc.sleep(1000) if not self.playBackStoppedEventReceived: self.onPlayBackStopped() # Uniquement avec la lecture avec play() if player_conf == '0': r = xbmcplugin.addDirectoryItem(handle=sPluginHandle, url=sUrl, listitem=item, isFolder=False) return r VSlog('Closing player') return True # fonction light servant par exemple pour visualiser les DL ou les chaines de TV def startPlayer(self, window=False): oPlayList = self.__getPlayList() self.play(oPlayList, windowed=window) def onPlayBackEnded(self): self.onPlayBackStopped() # Attention pas de stop, si on lance une seconde video sans fermer la premiere def onPlayBackStopped(self): VSlog('player stopped') # reçu deux fois, on n'en prend pas compte if self.playBackStoppedEventReceived: return self.playBackStoppedEventReceived = True self._setWatched(self.sEpisode) # MARQUER VU # utilise les informations de la vidéo qui vient d'etre lue # qui n'est pas celle qui a été lancée si plusieurs vidéos se sont enchainées # sEpisode = l'épisode précédent en cas d'enchainement d'épisode def _setWatched(self, sEpisode=''): try: with cDb() as db: if self.isPlaying(): self.totalTime = self.getTotalTime() self.currentTime = self.getTime() self.infotag = self.getVideoInfoTag() if self.totalTime > 0: pourcent = float('%.2f' % (self.currentTime / self.totalTime)) saisonViewing = False # calcul le temp de lecture # Dans le cas où on a vu intégralement le contenu, percent = 0.0 # Mais on a tout de meme terminé donc le temps actuel est egal au temps total. # if (pourcent > 0.90) or (pourcent == 0.0 and self.currentTime == self.totalTime): VALUE_WATCHTIME = 0.90 TRAKT_ID = "script.trakt" if self.ADDON.getSetting('use_trakt_addon') == 'true': traktAddon = xbmcaddon.Addon(TRAKT_ID) VALUE_WATCHTIME = int(traktAddon.getSetting("rate_min_view_time")) / 100 if (pourcent > VALUE_WATCHTIME) or (pourcent == 0.0 and self.currentTime == self.totalTime): # Marquer VU dans la BDD Vstream sTitleWatched = self.infotag.getOriginalTitle() if sTitleWatched: if sEpisode : # changement d'épisode suite à un enchainement automatique, fin de l'épisode précédent sTitle = '%s S%sE%s' % (self.tvShowTitle, self.sSaison, sEpisode) else: sTitle = self.sTitle meta = {} meta['cat'] = self.sCat meta['title'] = sTitle meta['titleWatched'] = sTitleWatched if self.movieUrl and self.movieFunc: meta['siteurl'] = self.movieUrl meta['fav'] = self.movieFunc else: meta['siteurl'] = self.sSite meta['fav'] = self.sFav meta['tmdbId'] = self.sTmdbId meta['site'] = self.sSource if self.sSaison: meta['season'] = self.sSaison meta['seasonUrl'] = self.saisonUrl meta['seasonFunc'] = self.nextSaisonFunc db.insert_watched(meta) # RAZ du point de reprise db.del_resume(meta) # Sortie des LECTURES EN COURS pour les films, pour les séries la suppression est manuelle if self.sCat == '1': db.del_viewing(meta) elif self.sCat == '8': # A la fin de la lecture d'un episode, on met la saison en "Lecture en cours" saisonViewing = True # Marquer VU dans les comptes perso self.__setWatchlist(sEpisode) # Sauvegarde du point de lecture pour une reprise elif self.currentTime > 180.0: sTitleWatched = self.infotag.getOriginalTitle() if sTitleWatched: meta = {} meta['title'] = self.sTitle meta['titleWatched'] = sTitleWatched meta['site'] = self.sSite meta['point'] = self.currentTime meta['total'] = self.totalTime db.insert_resume(meta) # point de reprise dans les comptes externes self.__setProgress(sEpisode, self.currentTime, self.totalTime) # Lecture en cours meta['cat'] = self.sCat meta['site'] = self.sSource meta['tmdbId'] = self.sTmdbId # Lecture d'un épisode, on sauvegarde la saison if self.sCat == '8': saisonViewing = True else: # Lecture d'un film # les 'divers' de moins de 45 minutes peuvent être de type 'adultes' # pas de sauvegarde en attendant mieux if self.sCat == '5' and self.totalTime < 2700: pass else: if self.movieUrl and self.movieFunc: meta['siteurl'] = self.movieUrl meta['fav'] = self.movieFunc else: meta['siteurl'] = self.sSite meta['fav'] = self.sFav db.insert_viewing(meta) # Lecture d'un épisode, on met la saison "En cours de lecture" if saisonViewing: meta['cat'] = '4' # saison meta['tmdbId'] = self.sTmdbId tvShowTitleWatched = cUtil().titleWatched(self.tvShowTitle).replace(' ', '') if self.sSaison: meta['season'] = self.sSaison meta['title'] = self.tvShowTitle + " S" + self.sSaison meta['titleWatched'] = tvShowTitleWatched + "_S" + self.sSaison else: meta['title'] = self.tvShowTitle meta['titleWatched'] = tvShowTitleWatched meta['site'] = self.sSource meta['siteurl'] = self.saisonUrl meta['fav'] = self.nextSaisonFunc db.insert_viewing(meta) except Exception as err: VSlog("ERROR Player_setWatched : {0}".format(err)) # def onPlayBackStarted(self): def onAVStarted(self): VSlog('player started') # Si on recoit une nouvelle fois l'event, c'est que ca buggue, on stope tout if self.playBackEventReceived: self.forcestop = True return self.playBackEventReceived = True with cDb() as db: # Reprendre la lecture if self.isPlayingVideo() and self.getTime() < 180: # si supérieur à 3 minutes, la reprise a été assuré par KODI self.infotag = self.getVideoInfoTag() sTitleWatched = self.infotag.getOriginalTitle() if sTitleWatched: meta = {'titleWatched': sTitleWatched} resumePoint, total = db.get_resume(meta) if resumePoint: if total == 1: # Gestion en pourcentage total = self.getTotalTime() resumePoint = total * resumePoint # au moins 3 minutes et si pas vu en entier if resumePoint > 180 and resumePoint < 0.9*total: h = resumePoint//3600 ms = resumePoint-h*3600 m = ms//60 s = ms-m*60 ret = dialog().VSselect(['Reprendre depuis %02d:%02d:%02d' %(h, m, s), 'Lire depuis le début'], 'Reprendre la lecture') if ret == 0: self.seekTime(resumePoint) elif ret == 1: self.seekTime(0.0) # RAZ du point de reprise db.del_resume(meta) # Marqué VU dans les comptes externes def __setWatchlist(self, sEpisode=''): # Vérification de l'utilisation de l'addon Trakt -> si oui: on quitte la fonction. if self.ADDON.getSetting('use_trakt_addon') == 'true': return # Suivi de lecture dans Trakt si compte if self.ADDON.getSetting('bstoken') == '': return plugins = __import__('resources.lib.trakt', fromlist=['trakt']).cTrakt() function = getattr(plugins, 'getAction') function(Action="SetWatched", sEpisode=sEpisode) # Progression dans les comptes externes def __setProgress(self, sEpisode='', currentTime=0, totalTime=0): # Vérification de l'utilisation de l'addon Trakt -> si oui: on quitte la fonction. if self.ADDON.getSetting('use_trakt_addon') == 'true': return # Suivi de lecture dans Trakt si compte if self.ADDON.getSetting('bstoken') == '': return if totalTime == 0: return progress = currentTime/ totalTime plugins = __import__('resources.lib.trakt', fromlist=['trakt']).cTrakt() function = getattr(plugins, 'getAction') function(Action="SetProgress", sEpisode=sEpisode, progress=progress) def __getPlayerType(self): sPlayerType = self.ADDON.getSetting('playerType') try: if sPlayerType == '0': VSlog('playertype from config: auto') return xbmc.PLAYER_CORE_AUTO if sPlayerType == '1': VSlog('playertype from config: mplayer') return xbmc.PLAYER_CORE_MPLAYER if sPlayerType == '2': VSlog('playertype from config: dvdplayer') return xbmc.PLAYER_CORE_DVDPLAYER except: return False