From 096c4fcd2e8f66ee55b30b3a81e38e4a9fb0cfa1 Mon Sep 17 00:00:00 2001 From: Lunatixz Date: Sun, 4 Jun 2017 16:28:36 -0400 Subject: [plugin.video.plutotv] 1.0.0 (#1241) --- plugin.video.plutotv/default.py | 463 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 463 insertions(+) create mode 100644 plugin.video.plutotv/default.py (limited to 'plugin.video.plutotv/default.py') diff --git a/plugin.video.plutotv/default.py b/plugin.video.plutotv/default.py new file mode 100644 index 0000000..b22d4c3 --- /dev/null +++ b/plugin.video.plutotv/default.py @@ -0,0 +1,463 @@ +# Copyright (C) 2017 Lunatixz +# +# +# This file is part of PlutoTV. +# +# PlutoTV is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# PlutoTV is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with PlutoTV. If not, see . + +# -*- coding: utf-8 -*- +import os, sys, time, datetime, net, requests, re +import urllib, socket, json, urlresolver, collections +import xbmc, xbmcgui, xbmcplugin, xbmcvfs, xbmcaddon + +from simplecache import use_cache, SimpleCache + +# Plugin Info +ADDON_ID = 'plugin.video.plutotv' +REAL_SETTINGS = xbmcaddon.Addon(id=ADDON_ID) +ADDON_NAME = REAL_SETTINGS.getAddonInfo('name') +SETTINGS_LOC = REAL_SETTINGS.getAddonInfo('profile').decode('utf-8') +ADDON_PATH = REAL_SETTINGS.getAddonInfo('path').decode('utf-8') +ADDON_VERSION = REAL_SETTINGS.getAddonInfo('version') +ICON = REAL_SETTINGS.getAddonInfo('icon') +FANART = REAL_SETTINGS.getAddonInfo('fanart') + + +## GLOBALS ## +TIMEOUT = 15 +USER_EMAIL = REAL_SETTINGS.getSetting('User_Email') +PASSWORD = REAL_SETTINGS.getSetting('User_Password') +FIT_REGION = REAL_SETTINGS.getSetting('Filter_Region') == 'true' +DEBUG = REAL_SETTINGS.getSetting('Enable_Debugging') == 'true' +HIDE_PLUTO = REAL_SETTINGS.getSetting("Hide_Ads") == "true" +COOKIE_JAR = xbmc.translatePath(os.path.join(SETTINGS_LOC, "cookiejar.lwp")) +PTVL_RUN = xbmcgui.Window(10000).getProperty('PseudoTVRunning') == 'True' +IGNORE_KEYS = ['pluto.tv','plutotv','pluto tv','promo'] +YTURL = 'plugin://plugin.video.youtube/play/?video_id=' +VMURL = 'plugin://plugin.video.vimeo/play/?video_id=' +BASE_URL = 'http://pluto.tv/'#'http://silo.pluto.tv/' +BASE_API = 'https://api.pluto.tv/v1' +BASE_LINEUP = 'https://api.pluto.tv/v1/channels.json' +BASE_GUIDE = 'https://api.pluto.tv/v1/timelines/%s.000Z/%s.000Z/matrix.json' +BASE_CLIPS = 'https://api.pluto.tv/v2/episodes/%s/clips.json' +USER_REGION = 'US' +PLUTO_MENU = [("Channel Guide" , BASE_LINEUP, 0), + ("Browse Channels", BASE_LINEUP, 1)] + +def log(msg, level=xbmc.LOGDEBUG): + if DEBUG == True: + xbmc.log(ADDON_ID + '-' + ADDON_VERSION + '-' + stringify(msg), level) + +def stringify(string): + if isinstance(string, list): + string = stringify(string[0]) + elif isinstance(string, (int, float, long, complex, bool)): + string = str(string) + if isinstance(string, basestring): + if not isinstance(string, unicode): + string = unicode(string, 'utf-8') + elif isinstance(string, unicode): + string = string.encode('ascii', 'ignore') + else: + string = string.encode('utf-8', 'ignore') + return string + +def getParams(): + param=[] + if len(sys.argv[2])>=2: + params=sys.argv[2] + cleanedparams=params.replace('?','') + if (params[len(params)-1]=='/'): + params=params[0:len(params)-2] + pairsofparams=cleanedparams.split('&') + param={} + for i in range(len(pairsofparams)): + splitparams={} + splitparams=pairsofparams[i].split('=') + if (len(splitparams))==2: + param[splitparams[0]]=splitparams[1] + return param + +socket.setdefaulttimeout(TIMEOUT) +class PlutoTV(): + def __init__(self): + log('__init__') + self.net = net.Net() + self.cache = SimpleCache() + self.categoryMenu = self.getCategories() + self.login() + + + @use_cache(1) + def login(self): + log('login') + header_dict = {} + header_dict['Accept'] = 'application/json, text/javascript, */*; q=0.01' + header_dict['Host'] = 'api.pluto.tv' + header_dict['Connection'] = 'keep-alive' + header_dict['Referer'] = 'http://pluto.tv/' + header_dict['Origin'] = 'http://pluto.tv' + header_dict['User-Agent'] = 'Mozilla/5.0 (Windows NT 6.2; rv:24.0) Gecko/20100101 Firefox/24.0' + + if USER_EMAIL != '': + + if xbmcvfs.exists(COOKIE_JAR) == False: + try: + xbmcvfs.mkdirs(COOKIE_JAR) + except: + log('Unable to create the storage directory', xbmc.LOGERROR) + + form_data = ({'optIn': 'true', 'password': PASSWORD,'synced': 'false', 'userIdentity': USER_EMAIL}) + self.net.set_cookies(COOKIE_JAR) + try: + loginlink = self.loadJson(self.net.http_POST(BASE_API + '/auth/local', form_data=form_data, headers=header_dict).content.encode("utf-8").rstrip()) + if loginlink and loginlink['email'].lower() == USER_EMAIL.lower(): + xbmcgui.Dialog().notification(ADDON_NAME, 'Welcome Back %s' % loginlink['displayName'], ICON, 4000) + self.net.save_cookies(COOKIE_JAR) + return True + else: + raise Exception() + except Exception,e: + xbmcgui.Dialog().notification(ADDON_NAME, 'Invalid User Credentials', ICON, 4000) + + + @use_cache(1) + def openURL(self, url): + log('openURL, url = ' + url) + try: + header_dict = {} + header_dict['Accept'] = 'application/json, text/javascript, */*; q=0.01' + header_dict['Host'] = 'api.pluto.tv' + header_dict['Connection'] = 'keep-alive' + header_dict['Referer'] = 'http://pluto.tv/' + header_dict['Origin'] = 'http://pluto.tv' + header_dict['User-Agent'] = 'Mozilla/5.0 (Windows NT 6.2; rv:24.0) Gecko/20100101 Firefox/24.0' + self.net.set_cookies(COOKIE_JAR) + trans_table = ''.join( [chr(i) for i in range(128)] + [' '] * 128 ) + try: + req = self.net.http_GET(url, headers=header_dict).content.encode("utf-8", 'ignore') + except: + req = self.net.http_GET(url, headers=header_dict).content.translate(trans_table) + self.net.save_cookies(COOKIE_JAR) + return req + except: + xbmcgui.Dialog().notification(ADDON_NAME, 'Unable to Connect, Check User Credentials', ICON, 4000) + return '{}' + + + def loadJson(self, string): + if len(string) == 0: + return {} + try: + return json.loads(stringify(string)) + except Exception,e: + return {} + + + def mainMenu(self): + log('mainMenu') + for item in PLUTO_MENU: + self.addDir(*item) + + + def browseMenu(self): + log('browseMenu') + for item in self.categoryMenu: + self.addDir(*item) + + + @use_cache(1) + def getCategories(self): + log('getCategories') + collect= [] + lineup = [] + data = self.loadJson(self.openURL(BASE_LINEUP)) + for channel in data: + collect.append(channel['category']) + counter = collections.Counter(collect) + for key, value in sorted(counter.iteritems()): + lineup.append(("%s"%(key), BASE_LINEUP, 2)) + lineup.insert(0,("Featured" , BASE_LINEUP, 2)) + lineup.insert(2,("All Channels", BASE_LINEUP, 2)) + del collect[:] + return lineup + + + def browse(self, chname, url): + log('browse, chname = ' + chname) + data = self.loadJson(self.openURL(url)) + for channel in data: + id = channel['_id'] + cat = channel['category'] + number = channel['number'] + region = channel['regionFilter']['exclude'] + name = channel['name'] + plot = channel['description'] + feat = (channel.get('featured','') or 0) == -1 + + if FIT_REGION == True and USER_REGION in region: + continue + + thumb = ICON + if 'thumbnail' in channel: + thumb = (channel['thumbnail']['path'] or ICON) + land = FANART + if 'featuredImage' in channel: + land = (channel['featuredImage']['path'] or FANART) + logo = ICON + if 'logo' in channel: + logo = (channel['logo']['path'] or ICON) + + if chname == "All Channels": + title = "%s - %s: %s" % (cat, number, name) + infoLabels ={"label":title ,"title":title ,"plot":plot, "code":number, "genre":cat, "imdbnumber":id} + infoArt ={"thumb":thumb,"poster":thumb,"fanart":land,"icon":logo,"logo":logo} + self.addDir(title, id, 8, infoLabels, infoArt) + elif chname == "Featured" and feat == True: + title = "%s - %s: %s" % (cat, number, name) + infoLabels ={"label":title ,"title":title ,"plot":plot, "code":number, "genre":cat, "imdbnumber":id} + infoArt ={"thumb":thumb,"poster":thumb,"fanart":land,"icon":logo,"logo":logo} + self.addDir(title, id, 8, infoLabels, infoArt) + + elif chname.lower() == cat.lower(): + title = "%s: %s" % (number, name) + infoLabels ={"label":title ,"title":title ,"plot":plot, "code":number, "genre":cat, "imdbnumber":id} + infoArt ={"thumb":thumb,"poster":thumb,"fanart":land,"icon":logo,"logo":logo} + self.addDir(title, id, 8, infoLabels, infoArt) + + + def pagination(self, seq, rowlen): + for start in xrange(0, len(seq), rowlen): + yield seq[start:start+rowlen] + + + def browseGuide(self, start=0, end=24): + log('browseGuide') + start = 0 if start == BASE_LINEUP else int(start) + data = self.loadJson(self.openURL(BASE_LINEUP)) + data = list(self.pagination(data, end)) + start = 0 if start >= len(data) else start + for channel in data[start]: + chid = channel['_id'] + chcat = channel['category'] + chnum = channel['number'] + region = channel['regionFilter']['exclude'] + chname = channel['name'] + chplot = channel['description'] + chthumb = (channel['thumbnail']['path'] or ICON) + feat = (channel.get('featured','') or 0) == -1 + + if FIT_REGION == True and USER_REGION in region: + continue + + t1 = datetime.datetime.now().strftime('%Y-%m-%dT%H:00:00') + t2 = (datetime.datetime.now() + datetime.timedelta(hours=8)).strftime('%Y-%m-%dT%H:00:00') + link = self.loadJson(self.openURL(BASE_GUIDE % (t1,t2))) + item = link[chid][0] + epid = (item['episode']['_id']) + epname = item['episode']['name'] + epplot = item['episode']['description'] + epgenre = item['episode']['genre'] + epdur = int(item['episode']['duration'] or '0') // 1000 + live = item['episode']['liveBroadcast'] + thumb = chthumb #(item['episode']['thumbnail']['path'] or chthumb) #site doesn't update missing episode thumbs + + title = "%s: %s - %s" % (chnum, chname, epname) + infoLabels ={"label":title ,"title":title ,"plot":epplot, "code":epid, "genre":epgenre, "imdbnumber":chid, "duration":epdur} + infoArt ={"thumb":thumb,"poster":thumb,"fanart":FANART,"icon":ICON,"logo":ICON} + self.addLink(title, chid, 9, infoLabels, infoArt, end) + start += 1 + self.addDir('>> Next', '%s'%(start), 0) + + + def resolveURL(self, provider, url): + log('resolveURL, provider = ' + provider) + print url + if provider == 'jwplatform' or url[-4:] == 'm3u8': + return url + elif provider == 'youtube': + if len(re.findall('http[s]?://www.youtube.com/watch', url)) > 0: + return YTURL + url.split('/watch?v=')[1] + elif len(re.findall('http[s]?://youtu.be/', url)) > 0: + return YTURL + url.split('/youtu.be/')[1] + elif provider == 'vimeo': + if len(re.findall('http[s]?://vimeo.com/', url)) > 0: + return VMURL + url.split('/vimeo.com/')[1] + return urlresolver.resolve(url) + + + def playChannel(self, name, url): + log('playChannel') + if PTVL_RUN == True: + return + + origurl = url + playlist = xbmc.PlayList(xbmc.PLAYLIST_VIDEO) + playlist.clear() + + if not 'sched' in url: + t1 = datetime.datetime.now().strftime('%Y-%m-%dT%H:00:00') + t2 = (datetime.datetime.now() + datetime.timedelta(hours=8)).strftime('%Y-%m-%dT%H:00:00') + link = self.loadJson(self.openURL(BASE_GUIDE % (t1,t2))) + item = link[origurl][0] + id = item['episode']['_id'] + ch_start = datetime.datetime.fromtimestamp(time.mktime(time.strptime(item["start"].replace('.000Z','').replace('T',' '), "%Y-%m-%d %H:%M:%S"))) + ch_timediff = (datetime.datetime.now() - ch_start).seconds + else: + id = url.replace('sched','') + + data = self.loadJson(self.openURL(BASE_CLIPS %(id))) + dur_sum = 0 + for idx, field in enumerate(data): + url = (field['url'] or field['code']) + name = field['name'] + thumb = (field['thumbnail'] or ICON) + provider = field['provider'] + url = self.resolveURL(provider, url) + dur = int(field['duration'] or '0') // 1000 + dur_start = dur_sum + dur_sum += dur + + if HIDE_PLUTO == True and any(k in name.lower() for k in IGNORE_KEYS): + continue + + liz=xbmcgui.ListItem(name, path=url) + infoList = {"label":name,"title":name,"duration":dur} + infoArt = {"thumb":thumb,"poster":thumb,"icon":ICON,"fanart":FANART} + liz.setInfo(type="Video", infoLabels=infoList) + liz.setArt(infoArt) + liz.setProperty("IsPlayable","true") + liz.setProperty("IsInternetStream",str(field['liveBroadcast']).lower()) + + if dur_start < ch_timediff and dur_sum > ch_timediff: + vid_offset = ch_timediff - dur_start + liz.setProperty('ResumeTime', str(vid_offset)) + playlist.add(url, liz, idx) + xbmcplugin.setResolvedUrl(int(sys.argv[1]), True, liz) + + + def playContent(self, name, url): + log('playContent') + origurl = url + if not 'sched' in url: + t1 = datetime.datetime.now().strftime('%Y-%m-%dT%H:00:00') + t2 = (datetime.datetime.now() + datetime.timedelta(hours=8)).strftime('%Y-%m-%dT%H:00:00') + link = self.loadJson(self.openURL(BASE_GUIDE % (t1,t2))) + item = link[origurl][0] + id = item['episode']['_id'] + ch_start = datetime.datetime.fromtimestamp(time.mktime(time.strptime(item["start"].replace('.000Z','').replace('T',' '), "%Y-%m-%d %H:%M:%S"))) + ch_timediff = (datetime.datetime.now() - ch_start).seconds + else: + id = url.replace('sched','') + + data = self.loadJson(self.openURL(BASE_CLIPS %(id))) + dur_sum = 0 + for idx, field in enumerate(data): + print field + url = (field['url'] or field['code']) + name = field['name'] + thumb = (field['thumbnail'] or ICON) + provider = field['provider'] + url = self.resolveURL(provider, url) + dur = int(field['duration'] or '0') // 1000 + dur_start = dur_sum + dur_sum += dur + + if HIDE_PLUTO == True and any(k in name.lower() for k in IGNORE_KEYS): + continue + + liz=xbmcgui.ListItem(name, path=url) + infoList = {"label":name,"title":name,"duration":dur} + infoArt = {"thumb":thumb,"poster":thumb,"icon":ICON,"fanart":FANART} + liz.setInfo(type="Video", infoLabels=infoList) + liz.setArt(infoArt) + liz.setProperty("IsPlayable","true") + liz.setProperty("IsInternetStream",str(field['liveBroadcast']).lower()) + + if dur_start < ch_timediff and dur_sum > ch_timediff: + vid_offset = ch_timediff - dur_start + liz.setProperty('ResumeTime', str(vid_offset) ) + self.addLink(name, url, 7, infoList, infoArt, len(data)) + + + def playVideo(self, name, url, list=None): + log('playVideo') + if not list: + list = xbmcgui.ListItem(name, path=url) + xbmcplugin.setResolvedUrl(int(sys.argv[1]), True, list) + + + def addLink(self, name, u, mode, infoList=False, infoArt=False, total=0): + name = stringify(name) + log('addLink, name = ' + name) + liz=xbmcgui.ListItem(name) + liz.setProperty('IsPlayable', 'true') + if infoList == False: + liz.setInfo( type="Video", infoLabels={"label":name,"title":name} ) + else: + liz.setInfo(type="Video", infoLabels=infoList) + + if infoArt == False: + liz.setArt({'thumb':ICON,'fanart':FANART}) + else: + liz.setArt(infoArt) + u=sys.argv[0]+"?url="+urllib.quote_plus(u)+"&mode="+str(mode)+"&name="+urllib.quote_plus(name) + xbmcplugin.addDirectoryItem(handle=int(sys.argv[1]),url=u,listitem=liz,totalItems=total) + + + def addDir(self, name, u, mode, infoList=False, infoArt=False): + name = stringify(name) + log('addDir, name = ' + name) + liz=xbmcgui.ListItem(name) + liz.setProperty('IsPlayable', 'false') + if infoList == False: + liz.setInfo(type="Video", infoLabels={"label":name,"title":name} ) + else: + liz.setInfo(type="Video", infoLabels=infoList) + if infoArt == False: + liz.setArt({'thumb':ICON,'fanart':FANART}) + else: + liz.setArt(infoArt) + u=sys.argv[0]+"?url="+urllib.quote_plus(u)+"&mode="+str(mode)+"&name="+urllib.quote_plus(name) + xbmcplugin.addDirectoryItem(handle=int(sys.argv[1]),url=u,listitem=liz,isFolder=True) + +params=getParams() +try: + url=urllib.unquote_plus(params["url"]) +except: + url=None +try: + name=urllib.unquote_plus(params["name"]) +except: + name=None +try: + mode=int(params["mode"]) +except: + mode=None + +log("Mode: "+str(mode)) +log("URL : "+str(url)) +log("Name: "+str(name)) + +if mode==None: PlutoTV().mainMenu() +elif mode == 0: PlutoTV().browseGuide(url) +elif mode == 1: PlutoTV().browseMenu() +elif mode == 2: PlutoTV().browse(name, url) +elif mode == 7: PlutoTV().playVideo(name, url) +elif mode == 8: PlutoTV().playContent(name, url) +elif mode == 9: PlutoTV().playChannel(name, url) + +xbmcplugin.addSortMethod(int(sys.argv[1]), xbmcplugin.SORT_METHOD_NONE ) +xbmcplugin.addSortMethod(int(sys.argv[1]), xbmcplugin.SORT_METHOD_LABEL ) +xbmcplugin.endOfDirectory(int(sys.argv[1]),cacheToDisc=True) \ No newline at end of file -- cgit v1.2.3