diff options
Diffstat (limited to 'plugin.video.ustvnow/resources/lib/ustvnow.py')
| -rw-r--r-- | plugin.video.ustvnow/resources/lib/ustvnow.py | 787 |
1 files changed, 787 insertions, 0 deletions
diff --git a/plugin.video.ustvnow/resources/lib/ustvnow.py b/plugin.video.ustvnow/resources/lib/ustvnow.py new file mode 100644 index 0000000..13d566c --- /dev/null +++ b/plugin.video.ustvnow/resources/lib/ustvnow.py @@ -0,0 +1,787 @@ +# Copyright (C) 2017 Lunatixz +# +# +# This file is part of USTVnow +# +# USTVnow 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. +# +# USTVnow 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 USTVnow. If not, see <http://www.gnu.org/licenses/>. + +# -*- coding: utf-8 -*- +import os, sys, datetime, re, traceback, HTMLParser, calendar +import urllib, urllib2, socket, json, collections, net, random +import xbmc, xbmcvfs, xbmcgui, xbmcplugin, xbmcaddon + +from simplecache import SimpleCache +# Plugin Info +ADDON_ID = 'plugin.video.ustvnow' +REAL_SETTINGS = xbmcaddon.Addon(id=ADDON_ID) +ADDON_NAME = REAL_SETTINGS.getAddonInfo('name') +SETTINGS_LOC = REAL_SETTINGS.getAddonInfo('profile') +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') +LANGUAGE = REAL_SETTINGS.getLocalizedString + +## GLOBALS ## +TIMEOUT = 30 +CONTENT_TYPE = 'files' +USER_EMAIL = REAL_SETTINGS.getSetting('User_Email') +PASSWORD = REAL_SETTINGS.getSetting('User_Password') +LAST_TOKEN = REAL_SETTINGS.getSetting('User_Token') +LAST_PASSKEY = REAL_SETTINGS.getSetting('User_Paskey') +DEBUG = REAL_SETTINGS.getSetting('Enable_Debugging') == 'true' +PTVL_RUN = xbmcgui.Window(10000).getProperty('PseudoTVRunning') == 'True' +BASEURL = 'https://m-api.ustvnow.com/' +BASEWEB = 'https://watch.ustvnow.com' +BASEMOB = 'http://mc.ustvnow.com/' +IMG_PATH = os.path.join(ADDON_PATH,'resources','images') +IMG_BASE = 'http://m.poster.static-ustvnow.com' +IMG_SOURCE = IMG_BASE + '/%s/%s/%s/med' +IMG_CHLOGO_W = 'http://tvdata.ustvnow.com/inverse-logos/360/%s.png' +IMG_CHLOGO = 'http://m.ustvnow.com/images/%s.png' +COOKIE_JAR = xbmc.translatePath(os.path.join(SETTINGS_LOC, "cookiejar.lwp")) +MEDIA_TYPES = {'SP':'video','SH':'episode','EP':'episode','MV':'movie'} +FREE_CHANS = ['CW','ABC','FOX','PBS','CBS','NBC','MY9'] +URL_TYPE = {0:'m3u8',1:'mp4'}[int(REAL_SETTINGS.getSetting('URL_Type'))] +URL_QUALITY = int(REAL_SETTINGS.getSetting('URL_Quality')) + 1 +CHAN_NAMES = {'whtm':'ABC','ABC':'ABC','amchd':'AMC','AMC':'AMC','animalplanet':'Animal Planet','Animal Planet':'Animal Planet','bravo':'Bravo','Bravo':'Bravo','whphd':'CBS','CBS':'CBS','cnbc':'CNBC','CNBC':'CNBC','wlyh':'CW','CW':'CW','comedycentral':'Comedy Central','Comedy Central':'Comedy Central','discovery':'Discovery Channel','Discovery Channel':'Discovery Channel','espn':'ESPN','ESPN':'ESPN', + 'FOX':'FOX','wpmt':'FOX','fxhd':'FX','FX':'FX','Fox News Channel':'Fox News','foxnews':'Fox News','frfrm':'Freeform','Freeform':'Freeform','msnbc':'MSNBC','MSNBC':'MSNBC','wgal':'NBC','NBC':'NBC','natgeo':'National Geographic','National Geographic Channel':'National Geographic','nickelodeon':'Nickelodeon','Nickelodeon':'Nickelodeon','wpsu':'PBS','PBS':'PBS', + 'spiketv':'SPIKE TV','SPIKE TV':'SPIKE TV','sndnc':'SundanceTV','SundanceTV':'SundanceTV','syfy':'Syfy','Syfy':'Syfy','AE':'A&E','My9':'MY9','whvl':'MY9','bbca':'BBC America','BBCA':'BBC America','espntwo':'ESPN 2','ESPN2':'ESPN 2','nbcsnhd':'NBCSN','NBCSNHD':'NBCSN','tlchd':'TLC','The Learning Channel':'TLC','Universal HD':'Universal', + 'usahd':'USA Network','USA':'USA Network'} + +USTVNOW_MENU = [("Live" , '', 0), + ("Schedules" , '', 1), + ("Recordings" , '', 2), + ("Lineup" , '', 3), + ("Movies" , '', 5), + ("Highlights", '', 12), + ("OnDemand" , '', 13), + ("Search" , '', 11), + ("Guide" , '', 20)] + +# if xbmc.getCondVisibility('System.HasAddon(script.module.uepg)') == 1: + # USTVNOW_MENU.append(("uEPG Guide", '', 20)) + +uEPG_PARAMS = {"runtime":"duration","stream_code":"studio","description":"plot","synopsis":"plotoutline","ut_start":"starttime","orig_air_date":"firstaired"} +FILE_PARAMS = ["title", "artist", "albumartist", "genre", "year", "rating", "album", "track", "duration", "comment", "lyrics", "musicbrainztrackid", "musicbrainzartistid", "musicbrainzalbumid", "musicbrainzalbumartistid", "playcount", "fanart", "director", "trailer", "tagline", "plot", "plotoutline", "originaltitle", "lastplayed", "writer", "studio", "mpaa", "cast", "country", "imdbnumber", "premiered", "productioncode", "runtime", "set", "showlink", "streamdetails", "top250", "votes", "firstaired", "season", "episode", "showtitle", "thumbnail", "file", "resume", "artistid", "albumid", "tvshowid", "setid", "watchedepisodes", "disc", "tag", "art", "genreid", "displayartist", "albumartistid", "description", "theme", "mood", "style", "albumlabel", "sorttitle", "episodeguide", "uniqueid", "dateadded", "size", "lastmodified", "mimetype", "specialsortseason", "specialsortepisode"] +PVR_PARAMS = ["title","plot","plotoutline","starttime","endtime","runtime","progress","progresspercentage","genre","episodename","episodenum","episodepart","firstaired","hastimer","isactive","parentalrating","wasactive","thumbnail","rating","originaltitle","cast","director","writer","year","imdbnumber","hastimerrule","hasrecording","recording","isseries"] +ART_PARAMS = ["thumb","poster","fanart","banner","landscape","clearart","clearlogo"] + +def uni(string, encoding = 'utf-8'): + if isinstance(string, basestring): + if not isinstance(string, unicode): + string = unicode(string, encoding) + elif isinstance(string, unicode): + string = string.encode('ascii', 'replace') + return string + +def unescape(string): + try: + parser = HTMLParser.HTMLParser() + return (parser.unescape(string)) + except: + return string + +def log(msg, level=xbmc.LOGDEBUG): + if DEBUG == False and level != xbmc.LOGERROR: return + if level == xbmc.LOGERROR: msg += ' ,' + traceback.format_exc() + xbmc.log(ADDON_ID + '-' + ADDON_VERSION + '-' + (msg.encode("utf-8")), level) + +def inputDialog(heading=ADDON_NAME, default='', key=xbmcgui.INPUT_ALPHANUM, opt=0, close=0): + retval = xbmcgui.Dialog().input(heading, default, key, opt, close) + if len(retval) > 0: + return retval + +def okDialog(str1, str2='', str3='', header=ADDON_NAME): + xbmcgui.Dialog().ok(header, str1, str2, str3) + +def yesnoDialog(str1, str2='', str3='', header=ADDON_NAME, yes='', no='', autoclose=0): + return xbmcgui.Dialog().yesno(header, str1, str2, str3, no, yes, autoclose) + +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 USTVnow(): + def __init__(self): + log('__init__') + self.net = net.Net() + self.cache = SimpleCache() + self.isFree = REAL_SETTINGS.getSetting('User_isFree') == "True" + if self.login(USER_EMAIL, PASSWORD) == False: raise SystemExit + + + def mainMenu(self): + log('mainMenu') + for item in USTVNOW_MENU: + self.addDir(*item) + + + def buildHeader(self): + header_dict = {} + header_dict['Accept'] = 'application/json, text/javascript, */*; q=0.01' + header_dict['Host'] = 'm-api.ustvnow.com' + header_dict['Connection'] = 'keep-alive' + header_dict['Referer'] = 'http://watch.ustvnow.com' + header_dict['Origin'] = 'http://watch.ustvnow.com' + header_dict['User-Agent'] = 'Mozilla/5.0 (X11; U; Linux i686; en-US) AppleWebKit/533.4 (KHTML, like Gecko) Chrome/5.0.375.127 Large Screen Safari/533.4 GoogleTV/162671' + return header_dict + + + def login(self, user, password): + log('login') + if len(user) > 0: + try: xbmcvfs.rmdir(COOKIE_JAR) + except: pass + + if xbmcvfs.exists(COOKIE_JAR) == False: + try: + xbmcvfs.mkdirs(SETTINGS_LOC) + f = xbmcvfs.File(COOKIE_JAR, 'w') + f.close() + except: log('login, Unable to create the storage directory', xbmc.LOGERROR) + header_dict = self.buildHeader() + self.net.set_cookies(COOKIE_JAR) + + try: + #check token + dvrlink = None + custlink = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/getcustomerkey', form_data={'token':LAST_TOKEN}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'username': u'', u'ip': u'', u'customerkey': u''}''' + self.custkey = (custlink.get('customerkey','') or 0) + if custlink and 'username' in custlink and user.lower() == custlink['username'].lower(): + log('login, using existing token, passkey') + self.token = LAST_TOKEN + self.passkey = LAST_PASSKEY + else: + #login + loginlink = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/login', form_data={'username':user,'password':password,'device':'gtv','redir':'0'}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'token': u'', u'result': u'success'}''' + if loginlink and 'token' in loginlink and loginlink['result'].lower() == 'success': + log('login, creating new token') + self.token = loginlink['token'] + REAL_SETTINGS.setSetting('User_Token',self.token) + + #passkey + dvrlink = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/viewdvrlist', form_data={'token':self.token}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'globalparams': {u'passkey': u''}, u'results': []}''' + if dvrlink and 'globalparams' in dvrlink: + log('login, creating new passkey') + self.passkey = dvrlink['globalparams']['passkey'] + REAL_SETTINGS.setSetting('User_Paskey',self.passkey) + else: raise Exception + + #check user credentials + userlink = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/getuserbytoken', form_data={'token':self.token}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'status': u'success', u'data': {u'username': u'', u'need_account_activation': False, u'plan_id': 1, u'language': u'en', u'plan_free': 1, u'sub_id': u'7', u'lname': u'', u'currency': u'USD', u'points': 1, u'need_account_renew': False, u'fname': u'', u'plan_name': u'Free Plan'}}''' + log('login, checking user account') + if userlink and 'data' in userlink and userlink['status'].lower() == 'success': + REAL_SETTINGS.setSetting('User_Plan' ,userlink['data']['plan_name']) + expires = 'Never' if userlink['data']['plan_name'] == 'Free Plan' else '' + REAL_SETTINGS.setSetting('User_Expires' ,'%s'%expires) + REAL_SETTINGS.setSetting('User_isFree' ,str(userlink['data']['plan_name'] == 'Free Plan')) + dvrPlan = 2 if 'dvr' in (userlink['data']['plan_name']).lower() else None + REAL_SETTINGS.setSetting('User_DVRpoints' ,str(dvrPlan or userlink['data']['points'] or 0)) + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30006) + userlink['data']['fname'], ICON, 4000) + + if userlink['data']['need_account_renew'] == True: + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30016) + userlink['data']['fname'], ICON, 4000) + elif userlink['data']['need_account_activation'] == True: + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30022) + userlink['data']['fname'], ICON, 4000) + else: + if REAL_SETTINGS.getSetting('User_DVRpoints') != REAL_SETTINGS.getSetting('Last_DVRpoints'): + REAL_SETTINGS.setSetting('Last_DVRpoints',REAL_SETTINGS.getSetting('User_DVRpoints')) + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30021) + userlink['data']['fname'], ICON, 4000) + + #check subscription + try: + #error prone, isolate and debug. + sublink = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/getaccountsubscription', form_data={'username':user,'customerkey':self.custkey}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'username': u'', u'billingDatetime': u'', u'currency': u'USD', u'cgaccountstatusreason': u'', u'invoicehistory': u'', u'ocaccountstatus': u'Account active', u'ccLastFour': u'', u'lname': u'', u'x-cg-acnt-USD': False, u'fname': u'', u'sub_info': {u'cost': 0, u'plan': {u'sub_group': 4, u'plan_id': 1, u'name': u'Free Plan', u'language': u'en', u'date_expire': u'0000-00-00', u'sub_id': 7, u'price': 0, u'currency': u'USD', u'plan_code': u'7_FREETRIAL', + u'details': u'This plan lets you receive all major US terrestrial stations (ABC, CBS, CW, FOX, NBC, PBS). You can later upgrade to a paid plan with more channels and DVR.'}, u'packages': []}, u'pendinginvoices': u'', u'cgbillingstatus': u'', u'dvrpoints': 1, u'plans': {u'10': {u'price': 15, u'name': u'1 Week All Channel Plan $15 ($2.14/day)', + u'details': u'1 Week pass for all channels (No DVR)'}, u'23': {u'price': 19, u'name': u'All Channel Promo Plan $19/mo first 3 months', + u'details': u'Monthly subscription for all channels. This promotional price is for the first three months after which it will renew at $29. This plan automatically renews each month but you can cancel anytime and will not be billed again when your current 30 day period has expired. '}, u'31': {u'price': 29, u'name': u'All Channel Promo Plan w/DVR $29/mo first 3 months', + u'details': u'Monthly subscription for all channels. This promotional price is for the first three months after which it will renew at $39. This plan automatically renews each month but you can cancel anytime and will not be billed again when your current 30 day period has expired.'}, u'7': {u'price': 0, u'name': u'Free Plan', + u'details': u'This plan lets you receive all major US terrestrial stations (ABC, CBS, CW, FOX, NBC, PBS). You can later upgrade to a paid plan with more channels and DVR.'}, u'9': {u'price': 0.00, u'name': u'3 Day All Channel Plan $6.99 ($2.33/day)', + u'details': u'3 Day pass for all channels (No DVR)'}, u'8': {u'price': 2.99, u'name': u'1 Day All Channel Plan $2.99', + u'details': u'24 hour pass for all channels (No DVR)'}}, u'cgredirectUrl': u'', u'cgaccountstatus': False, u'isfacebookuser': False, u'cgkey': u'', u'ocaccountstatuscode': 0, u'packages': [], u'subscription': u'Free Plan', u'language': u'en', u'sub_id': u'7', u'dateopened': u'December 01, 2000', u'canceledDatetime': u'', u'cgbillingmethod': u''}''' + if sublink: REAL_SETTINGS.setSetting('User_Expires' ,'%s'%(sublink['sub_info']['date_expire'])) + except: pass + else: raise Exception + self.net.save_cookies(COOKIE_JAR) + + self.channels = self.cache.get(ADDON_NAME + '.channelguide') + if not self.channels: + log('login, refreshing channels') + channels = sorted(json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/channelguide', form_data={'token':self.token}, headers=header_dict).content.encode("utf-8").rstrip())['results'], key=lambda x: x['displayorder']) + '''{u'app_name': u'preview', u'stream': u'00000WXYZustvnow', u'af': u'US', u'dvraction': u'add', u'callsign': u'WHTM', u'event_inprogress': 1, + u'srsid': 3560383, u'guideremainingtime': 3660, u'scheduleid': 9952642, u'favoriteaction': u'remove', u'event_time': u'00:00:00',u'title': u'Shark Tank', + u'timemark': 1498867200, u'recordedon': u'June 30, 2017 20:00', u'prg_img': u'h3/NowShowing/9977826/p9977826_b1t_h3_aa.jpg', u'title_10': u'', + u'xcdrappname': u'livehd', u'event_date': u'2017-07-01', u'has_img': 1, u'stream_code': u'ABC', u'updated': u'2017-06-29 11:49:08', + u'description': u'Durable bags made out of the material that protects on the front lines of firefighting; a vibrating mat that helps calm babies; + an ointment made from essential oils; a natural snack made with acai.', u'actualremainingtime': 3281, u'content_allowed': False, + u'dvrtimeraction': u'add', u'mediatype': u'EP', u'auth': None, u'stream_origin': u'dne.ustvnow.com', u'dvrtimertype': 0, u'scode': u'whtm', + u'aksid': 1, u'guideheight': 120, u'orig_air_date': u'2017-02-10', u'prgsvcid': 11534, u'runtime': 3660, u'img': u'images/WHTM.png', + u'connectorid': u'SH011581290000', u'ut_start': 1498867200, u'streamname': u'00000WXYZustvnow', u'episode_title': u'', u'synopsis': + u'A vibrating mat that helps calm babies.', u't': 1, u'edgetypes': 7, u'imgmark': u'live', u'content_id': u'EP011581290171', u'order': 1, + u'displayorder': 1}''' + self.cache.set(ADDON_NAME + '.channelguide', channels, expiration=datetime.timedelta(minutes=5)) + self.channels = self.cache.get(ADDON_NAME + '.channelguide') + + self.upcoming = self.cache.get(ADDON_NAME + '.upcoming') + if not self.upcoming: + log('login, refreshing upcoming') + upcoming = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/upcoming', form_data={'token':self.token}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'prgschid': 19479379, u'dvraction': u'add', u'callsign': u'AMC', u'newtimecat': True, u'srsid': 14930, u'timecat': u'Today', u'scheduleid': 9946282, + u'img': u'images/AMC.png', u'title': u'The Fugitive', u'prg_img': u'v5/NowShowing/14930/p14930_p_v5_aa.jpg', u'has_img': 1, u't': 0, u'sname': u'AMC', + u'description': u'U.S. marshal (Tommy Lee Jones) hunts doctor (Harrison Ford) for murder of his wife (Sela Ward).', u'dvrtimeraction': u'add', + u'auth': None, u'orig_air_date': None, u'dvrtimertype': 0, u'scode': u'amchd', u'prgsvcid': 10021, u'runtime': 10800, u'connectorid': u'MV000371790000', + u'episode_title': u'', u'synopsis': u'An innocent man must evade the law as he pursues a killer.', u'event_inprogress': 1, u'ut_start': 1499009400, + u'content_allowed': False, u'imgmark': u'live', u'content_id': u'MV000371790000', u'displayorder': 100}''' + self.cache.set(ADDON_NAME + '.upcoming', upcoming, expiration=datetime.timedelta(hours=6)) + self.upcoming = self.cache.get(ADDON_NAME + '.upcoming') + + self.highlights = self.cache.get(ADDON_NAME + '.highlights') + if not self.highlights: + log('login, refreshing highlights') + highlights = json.loads(self.net.http_POST(BASEURL + 'api/1/live/highlights', form_data={'token':self.token}, headers=header_dict).content.encode("utf-8").rstrip()) + '''{u'prgschid': 114059791, u'dvraction': u'add', u'bb_content': u'How would you like having Jim Morrison as a college roommate? ', u'callsign': u'WPSU', u'newtimecat': True, + u'srsid': 185479, u'timecat': u'Tomorrow', u'scheduleid': 49826153, u'img': u'images/WPSU.png', u'title': u'Antiques Roadshow', u'prg_img': u'h3/NowShowing/185479/p185479_b_h3_ag.jpg', + u'has_img': 1, u't': 1, u'sname': u'PBS', u'description': u'A French Art Deco diamond and platinum ring; a copy of "The History of Magic" signed by Jim Morrison; four Rembrandt', + u'dvrtimeraction': u'add', u'auth': None, u'orig_air_date': u'2014-02-17', u'dvrtimertype': 0, u'scode': u'wpsu', u'prgsvcid': 11786, u'runtime': 3600, u'connectorid': u'SH002036520000', + u'episode_title': u'Baton Rouge', u'synopsis': u'Diamond and platinum ring.', u'event_inprogress': 2, u'ut_start': 1508216400, u'content_allowed': True, u'imgmark': u'', u'content_id': + u'EP002036520417', u'displayorder': 6}''' + self.cache.set(ADDON_NAME + '.highlights', highlights, expiration=datetime.timedelta(hours=6)) + self.highlights = self.cache.get(ADDON_NAME + '.highlights') + + self.recorded = self.cache.get(ADDON_NAME + '.recorded') + if not self.recorded: + log('login, refreshing recorded') + '''{u'fn1': u'20170702', u'episode_season': 0, u'filename_smil': u'20170702_213000_220000_utc_SH000000010000_11534_11534_ABC.smil', u'app_name': u'dvrrokuplay', + u'stream': u'2F1ECWHTMUSTVNOW', u'imgmark': u'rem', u'dvrtimeraction': u'add', u'mediatype': u'SH', u'orig_air_date': None, u'content_id': u'SH000000010000', + u'callsign': u'WHTM', u'ut_expires': 1500327000, u'filename_med': u'20170702_213000_220000_utc_SH000000010000_11534_11534_ABC_650.mp4', + u'filename_high': u'20170702_213000_220000_utc_SH000000010000_11534_11534_ABC_950.mp4', u'dvrlocation': u'dvr6', u'episode_number': 0, u'srsid': 459763, + u'runtime': 1800, u'description': u'Paid programming.', u'scheduleid': 9952747, u'has_img': 1, u'fn3': u'220000', u'fn2': u'213000', + u'event_time': u'21:30:00', u'title': u'Paid Programming', u'recordedonmmddyyyy': u'07/02/2017', u'connectorid': u'SH000000010000', + u'recordedon': u'July 2, 2017', u'prg_img': u'h3/NowShowing/459763/p459763_b_h3_ae.jpg', u'filename_low': u'20170702_213000_220000_utc_SH000000010000_11534_11534_ABC_350.mp4', + u'episode_title': u'', u'synopsis': u'Paid programming.', u'dvrtimertype': 0, u'content_allowed': True, u'xcdrappname': u'livehd', u'event_date': u'2017-07-02', + u'event_inprogress': 2, u'prgsvcid': 11534, u'ut_start': 1499031000, u'stream_code': u'ABC'}''' + if dvrlink: recorded = dvrlink['results'] + else: recorded = (json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/viewdvrlist', form_data={'token':self.token}, headers=header_dict).content.encode("utf-8").rstrip()))['results'] + self.cache.set(ADDON_NAME + '.recorded', recorded, expiration=datetime.timedelta(minutes=1)) + self.recorded = self.cache.get(ADDON_NAME + '.recorded') + self.names = self.getChannelNames() + return True + except Exception as e: + log('login, Unable to login ' + str(e), xbmc.LOGERROR) + REAL_SETTINGS.setSetting('User_Token','') + REAL_SETTINGS.setSetting('User_Paskey','') + REAL_SETTINGS.setSetting('User_Activated',str(False)) + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30007), ICON, 4000) + return False + else: + #firstrun wizard + if yesnoDialog(LANGUAGE(30008),no=LANGUAGE(30009), yes=LANGUAGE(30010)): + user = inputDialog(LANGUAGE(30001)) + password = inputDialog(LANGUAGE(30002),opt=xbmcgui.ALPHANUM_HIDE_INPUT) + REAL_SETTINGS.setSetting('User_Email' ,user) + REAL_SETTINGS.setSetting('User_Password',password) + return self.login(user, password) + else: + okDialog(LANGUAGE(30003)) + return False + + + def getChannelNames(self): + collect = [] + if self.channels is None: xbmc.executebuiltin("Container.Refresh") + for channel in self.channels: + try: + name = CHAN_NAMES[channel['stream_code']] + if self.isFree == True and name not in FREE_CHANS: continue + collect.append(name) + except: pass + counter = collections.Counter(collect) + names = sorted(list(set(sorted(counter.elements())))) + log('getChannelNames, names = ' + str(names)) + return names + + + def browseLive(self): + log('browseLive') + d = datetime.datetime.utcnow() + now = datetime.datetime.fromtimestamp(calendar.timegm(d.utctimetuple())) + if self.channels is None: xbmc.executebuiltin("Container.Refresh") + for channel in self.channels: + try: + name = CHAN_NAMES[channel['stream_code']] + if self.isFree == True and name not in FREE_CHANS: continue + startime = datetime.datetime.fromtimestamp(channel['ut_start']) + endtime = startime + datetime.timedelta(seconds=channel['runtime']) + if endtime > now and startime <= now: + label, url, liz = self.buildChannelListItem(name, channel, opt='Live') + self.addLink(label, url, 9, liz, len(self.channels)) + except Exception as e: + log('browseLive, failed ' + str(e), xbmc.LOGERROR) + + + def browseRecordings(self, recorded=False): + log('browseRecordings') + d = datetime.datetime.utcnow() + now = datetime.datetime.fromtimestamp(calendar.timegm(d.utctimetuple())) + if self.recorded is None: xbmc.executebuiltin("Container.Refresh") + for channel in self.recorded: + try: + startime = datetime.datetime.fromtimestamp(channel['ut_start']) + endtime = startime + datetime.timedelta(seconds=channel['runtime']) + if recorded == False and channel['event_inprogress'] == 0: continue + elif recorded == True and channel['event_inprogress'] != 0: continue + label, url, liz = self.buildRecordedListItem(CHAN_NAMES[channel['stream_code']]) + mode = 10 if recorded == True else 21 + if mode == 21: liz.setProperty("IsPlayable","false") + self.addLink(label, url, mode, liz, len(self.recorded)) + except Exception as e: + log('browseRecordings, failed ' + str(e), xbmc.LOGERROR) + + + def browseGuide(self, name=None, upcoming=False): + log('browseGuide') + d = datetime.datetime.utcnow() + now = datetime.datetime.fromtimestamp(calendar.timegm(d.utctimetuple())) + if self.channels is None: xbmc.executebuiltin("Container.Refresh") + if name is None and upcoming == False: + for channel in sorted(self.names): + icon = (os.path.join(IMG_PATH,'logos','%s.png'%channel) or ICON) + infoArt = {"thumb":icon,"poster":icon,"icon":icon,"fanart":FANART} + self.addDir(channel, channel, 4, infoArt=infoArt) + else: + for channel in self.channels: + try: + if self.isFree == True and name not in FREE_CHANS: continue + if name == CHAN_NAMES[channel['stream_code']]: + startime = datetime.datetime.fromtimestamp(channel['ut_start']) + endtime = startime + datetime.timedelta(seconds=channel['runtime']) + if endtime > now and (startime <= now): + label, url, liz = self.buildChannelListItem(name, channel) + self.addLink(label, url, 9, liz, len(self.channels)) + elif endtime > now and (startime <= now or startime > now): + label, url, liz = self.buildChannelListItem(name, channel) + mode = 9 if PTVL_RUN == True else 21 + if mode == 21: liz.setProperty("IsPlayable","false") + self.addLink(label, url, mode, liz, len(self.channels)) + except Exception as e: + log('browseGuide, failed ' + str(e), xbmc.LOGERROR) + + + def browseFeatured(self, hlt=False): + log('browseFeatured') + d = datetime.datetime.utcnow() + now = datetime.datetime.fromtimestamp(calendar.timegm(d.utctimetuple())) + CONTENT_TYPE = 'movies' if not hlt else 'episodes' + optLST = self.highlights.get('programs') if hlt else self.upcoming + if optLST is None: xbmc.executebuiltin("Container.Refresh") + for channel in optLST: + try: + name = CHAN_NAMES[channel['sname']] + startime = datetime.datetime.fromtimestamp(channel['ut_start']) + endtime = startime + datetime.timedelta(seconds=channel['runtime']) + if endtime > now and (startime <= now or startime > now): + label, url, liz = self.buildChannelListItem(name, channel, opt='Featured') + liz.setProperty("IsPlayable","false") + self.addLink(label, url, 21, liz, len(optLST)) + except Exception as e: + log('browseFeatured, failed ' + str(e), xbmc.LOGERROR) + + + def browseVOD(self, url=None, limit=24): + log('browseVOD') + ''' + {u'paging': {u'current': u'/api/1/live/vod/?role=user&limit=24&status%5B0%5D=5', u'next_query': u'role=user&limit=24&status%5B0%5D=5&page=4954', u'next': u'/api/1/live/vod/?role=user&limit=24&status%5B0%5D=5&page=4954'}, + u'data': [{u'rented': None, u'ratings': [{u'description': u'', u'id': 12585970, u'name': u'TV-Y'}], u'scheduleid': u'V4954', u'description': u"HORSELAND: FIRST LOVE - Tomboyish Alma has a crush on a boy. Chloe . (CC)", + u'language': u'en', u'title': u'Horseland: First Love', u'content_allowed': False, u'price': u'0.99', u'created': 1493301489, u'genres': [], u'licensing_start': 1494475260, u'slug': u'V4954', u'director': None, + u'closed_caption': True, u'rent_due': 2, u'actors': [{u'lname': u'Donlan', u'id': 30781624, u'fname': u'Dana'}, {u'lname': u'Hernandez', u'id': 30781625, u'fname': u'Emily'}, {u'lname': u'Heyward', u'id': 30781626, u'fname': + u'Bianca'}], u'year': 2006, u'images': {u'posters': {u'small': u'/V4954/USTVNOW/mv/small', u'large': u'/V4954/USTVNOW/mv/large', u'medium': u'/V4954/USTVNOW/mv/medium'}}, u'runtime': u'00:21:15', u'id': 4954, + u'licensing_end': 1499745540}]} + ''' + if url is None: url = BASEWEB + '/vod/all-items' + items = self.net._json(url, form_data={'limit':limit,'token':self.token}) + if items and len(items) > 0: + label = '[B]%s[/B]'%LANGUAGE(30029) + liz = xbmcgui.ListItem(label) + liz.setArt({"thumb":ICON,"poster":ICON,"fanart":FANART}) + self.addLink(label, '', 22, liz, len(items)) + next = (items.get('paging','').get('next','') or '') + for item in items['data']: + label, url, liz = self.buildVODListItem(item) + liz.setProperty("IsPlayable","true") + liz.addContextMenuItems([('Purchase','')]) + self.addLink(label, url, 22, liz, len(items)) + # self.addDir('>> Next', BASEWEB + next, 13) + + + def search(self): + log('search') + kb = xbmc.Keyboard('', LANGUAGE(30027)%ADDON_NAME) + xbmc.sleep(1000) + kb.doModal() + if kb.isConfirmed(): + try: + query = kb.getText() + items = json.loads(self.net.http_POST(BASEURL + 'gtv/1/live/search', form_data={'token':self.token,'q_title':query}, headers=self.buildHeader()).content.encode("utf-8").rstrip())['results']['programs'] + for channel in items: + try: + name = CHAN_NAMES[channel['progs']['scode']] + label, url, liz = self.buildChannelListItem(name, channel['progs'], opt='Search') + liz.setProperty("IsPlayable","false") + self.addLink(label, url, 21, liz, len(items)) + except Exception as e: + log('search, error ' + str(e), xbmc.LOGERROR) + if len(items) == 0: + label = LANGUAGE(30028)%query + liz = xbmcgui.ListItem(label) + liz.setArt({"thumb":ICON,"poster":ICON,"fanart":FANART}) + self.addLink(label, '', 0, liz, 1) + except Exception as e: + log('search, failed ' + str(e), xbmc.LOGERROR) + else: self.mainMenu() + + + def buildVODListItem(self, item): + url = '' + title = unescape(item['title']) + price = item['price'] + year = item['year'] + h, m, s = item['runtime'].split(':') + runtime = int(h) * 3600 + int(m) * 60 + int(s) + label = '%s ($%s)'%(title,price) + label2 = item['price'] + plot = unescape(item['description']) + liz = xbmcgui.ListItem(label) + thumb = IMG_BASE + item['images']['posters']['large'] + infoList = {"mediatype":'movie',"label":label,"label2":label2,"title":label,"duration":runtime,"plot":plot} + liz.setInfo(type="Video", infoLabels=infoList) + liz.setArt({"thumb":thumb,"poster":thumb,"fanart":FANART}) + liz.setProperty("IsPlayable","true") + liz.setProperty("IsInternetStream","true") + log('buildVODListItem, label = ' + label + ', url = ' + url) + return label, url, liz + + + def buildChannelListItem(self, name, channel=None, opt=''): + if channel is None: + for idx, channel in enumerate(self.channels): + if name == CHAN_NAMES[channel['stream_code']]: break + startime = datetime.datetime.fromtimestamp(channel['ut_start']) + endtime = startime + datetime.timedelta(seconds=channel['runtime']) + title = unescape(channel['title']) + mediatype = (channel.get('mediatype','') or (channel.get('connectorid',''))[:2] or (channel.get('content_id',''))[:2] or 'SP') + mtype = MEDIA_TYPES[mediatype.upper()] + label = name if PTVL_RUN == True else '%s: %s - %s'%(startime.strftime('%I:%M %p').lstrip('0'),name,title) + label = '%s - %s'%(name,title) if opt == 'Live' else label + label2 = '%s - %s'%(startime.strftime('%I:%M %p').lstrip('0'),endtime.strftime('%I:%M %p').lstrip('0')) + url = name + liz = xbmcgui.ListItem(label) + thumb = IMG_SOURCE%(str(channel['srsid']),channel['callsign'],mediatype) + thumb = thumb + '/snapshot' if opt == 'Live' else thumb + poster = (os.path.join(IMG_PATH,'%s.png'%name) or ICON) + logo = IMG_CHLOGO%(channel['callsign']) + tag = ''#urllib.quote(json.dumps({"channelname":name,"channelnumber":self.names.index(name)+1,"channellogo":logo,"label":title,"label2":self.isHD(),"starttime":channel['ut_start']})) + infoList = {"mediatype":'episode',"label":label,"label2":label2,"title":label,"tagline":tag, + "studio":name,"duration":channel['runtime'],"plotoutline":unescape(channel.get('synopsis','')), + "plot":unescape(channel['description']),"aired":startime.strftime('%Y-%m-%d')} + liz.setInfo(type="Video", infoLabels=infoList) + liz.setArt({"thumb":thumb,"poster":thumb,"fanart":FANART,"clearlogo":logo}) + liz.setProperty("IsPlayable","true") + liz.setProperty("IsInternetStream","true") + if channel['dvrtimeraction'] == 'add': + opt = '@'.join([str(channel['prgsvcid']),(channel.get('event_time','') or str(channel.get('ut_start','')))])#lazy solution rather then create additional url parameters for this single function. + contextMenu = [('Set single recording' ,'XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['scheduleid']))+"&mode="+str(6)+"&name="+urllib.quote(opt))), + ('Set recurring recording','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['connectorid']))+"&mode="+str(7)+"&name="+urllib.quote(opt)))] + else: + contextMenu = [('Remove recording','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['scheduleid']))+"&mode="+str(8)+"&name="+urllib.quote(name)))] + liz.addContextMenuItems(contextMenu) + log('buildChannelListItem, label = ' + label + ', url = ' + url) + return label, url, liz + + + def buildRecordedListItem(self, name): + for channel in self.recorded: + if name == CHAN_NAMES[channel['stream_code']] or name == str(channel['scheduleid']): + startime = datetime.datetime.fromtimestamp(channel['ut_start']) + endtime = startime + datetime.timedelta(seconds=channel['runtime']) + title = unescape(channel['title']) + label = '%s - %s: %s - %s'%(startime.strftime('%Y-%m-%d'),startime.strftime('%I:%M %p').lstrip('0'),name,title) + label2 = '%s-%s'%(startime.strftime('%I:%M %p').lstrip('0'),endtime.strftime('%I:%M %p').lstrip('0')) + url = str(channel['scheduleid']) + liz = xbmcgui.ListItem(label) + mediatype = (channel.get('mediatype','') or (channel.get('connectorid',''))[:2] or (channel.get('content_id',''))[:2] or 'SP') + mtype = MEDIA_TYPES[mediatype.upper()] + infoList = {"mediatype":mtype,"label":label,"label2":label2,"title":label,"studio":CHAN_NAMES[channel['stream_code']], + "duration":channel['runtime'],"plotoutline":unescape(channel['synopsis']),"plot":unescape(channel['description']), + "aired":startime.strftime('%Y-%m-%d')} + thumb = IMG_SOURCE%(str(channel['srsid']),channel['callsign'],mediatype) + liz.setInfo(type="Video", infoLabels=infoList) + liz.setArt({"thumb":thumb,"poster":thumb,"fanart":FANART}) + liz.setProperty("IsPlayable","true") + liz.setProperty("IsInternetStream","true") + contextMenu = [] + # if channel['dvrtimeraction'] == 'add': + # opt = '@'.join([str(channel['prgsvcid']),channel['event_time']])#lazy solution rather then create additional url parameters for this single function. + # contextMenu = [('Set single recording' ,'XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['scheduleid']))+"&mode="+str(6)+"&name="+urllib.quote(opt))), + # ('Set recurring recording','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['connectorid']))+"&mode="+str(7)+"&name="+urllib.quote(opt)))] + contextMenu.extend([('Remove recording','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['scheduleid']))+"&mode="+str(8)+"&name="+urllib.quote(name)))]) + liz.addContextMenuItems(contextMenu) + log('buildRecordedListItem, label = ' + label + ', url = ' + url) + return label, url, liz + + + def resolveURL(self, url, dvr=False): + log('resolveURL, url = ' + url + ', dvr = ' + str(dvr)) + if dvr: + for channel in self.recorded: + if url == str(channel['scheduleid']): + try: + urllink = json.loads(self.net.http_POST(BASEURL + 'stream/1/dvr/play', form_data={'token':self.token,'key':self.passkey,'scheduleid':channel['scheduleid']}, headers=self.buildHeader()).content.encode("utf-8").rstrip()) + '''{u'pr': u'll', u'domain': u'ilvc02.ll.ustvnow.com',u'stream': u'http://ilvc02.ll.ustvnow.com/ilv10/pr/xxl/smil:0B64AWHTMUSTVNOW/playlist.m3u8?', + u'streamname': u'0B64AWHTMUSTVNOW', u'tr': u'', u'up': 1, u'pd': 0, u'pl': u'vjs'}''' + stream = urllink['stream'] + # if URL_TYPE == 'm3u8': stream = urllink['stream'] + # else: stream = (urllink['stream'].replace('smil:','mp4:').replace('USTVNOW','USTVNOW%d'%URL_QUALITY)) + log('resolveURL, url = ' + stream) + return stream + except Exception as e: + if channel and channel['scheduleid']: + self.replaceToken(url, dvr) + else: + for channel in self.channels: + if url == CHAN_NAMES[channel['stream_code']]: + try: + urllink = json.loads(self.net.http_POST(BASEURL + 'stream/1/live/view', form_data={'token':self.token,'key':self.passkey,'scode':channel['scode']}, headers=self.buildHeader()).content.encode("utf-8").rstrip()) + '''{u'pr': u'll', u'domain': u'ilvc02.ll.ustvnow.com',u'stream': u'http://ilvc02.ll.ustvnow.com/ilv10/pr/xxl/smil:0B64AWHTMUSTVNOW/playlist.m3u8?', + u'streamname': u'0B64AWHTMUSTVNOW', u'tr': u'', u'up': 1, u'pd': 0, u'pl': u'vjs'}''' + if URL_TYPE == 'm3u8': stream = urllink['stream'] + else: stream = (urllink['stream'].replace('smil:','mp4:').replace('USTVNOW','USTVNOW%d'%URL_QUALITY)) + log('resolveURL, stream = ' + stream) + return stream + except Exception as e: + if channel and channel['scode']: + self.replaceToken(url, dvr) + + + def replaceToken(self, url, dvr): + #generate alternative token using website endpoint rather then googletv. + try: + #get CSRF Token + response = urllib2.urlopen(BASEWEB + "/account/signin").read() + CSRF = re.findall(r'var csrf_value = "(.*?)"', response, re.DOTALL)[0] + #get WEB Token + response = (self.net.http_POST(BASEWEB + '/account/login', form_data={'csrf_ustvnow': CSRF, 'signin_email': USER_EMAIL, 'signin_password':PASSWORD, 'signin_remember':'1'}).content.encode("utf-8").rstrip()) + altToken = re.findall(r'var token(.*?)= "(.*?)";', response, re.DOTALL)[0][1] + if altToken and altToken != 'null': + self.token = altToken + log('replaceToken, replacing existing token') + REAL_SETTINGS.setSetting('User_Token',altToken) + self.resolveURL(url, dvr) + except Exception as e: + log('replaceToken, Unable to login ' + str(e), xbmc.LOGERROR) + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30005), ICON, 4000) + raise SystemExit + + + def setRecording(self, name, url, remove=False, recurring=False): + log('setRecording, name = ' + name + ', url = ' + url + ', remove = ' + str(remove)) + if remove == True: + setlink = (self.net.http_POST(BASEURL + 'gtv/1/dvr/updatedvr', form_data={'scheduleid':url,'token':self.token,'action':'remove'}, headers=self.buildHeader()).content.encode("utf-8").rstrip()) + else: + if int(REAL_SETTINGS.getSetting('User_DVRpoints')) <= 1: + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30019), ICON, 4000) + return + opt = name.split('@')#lazy solution rather then create additional url parameters for this single function. + if recurring == True: + setlink = (self.net.http_POST(BASEURL + 'gtv/1/dvr/updatedvrtimer', form_data={'connectorid':url,'prgsvcid':opt[0],'eventtime':opt[1],'token':self.token,'action':'add'}, headers=self.buildHeader()).content.encode("utf-8").rstrip()) + else: + setlink = (self.net.http_POST(BASEURL + 'gtv/1/dvr/updatedvr' , form_data={'scheduleid':url,'token':self.token,'action':'add'}, headers=self.buildHeader()).content.encode("utf-8").rstrip()) + '''<result><status>failure</status><action>add</action></result>''' + action = re.findall(r'<action>(.*?)</action>', setlink, re.DOTALL)[0] + status = re.findall(r'<status>(.*?)</status>', setlink, re.DOTALL)[0] + log('setRecording, action = ' + action + ', status = ' + status) + if status == 'failure': + log('setRecording, setlink = ' + str(setlink), xbmc.LOGERROR) + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30023)%action.title(), ICON, 4000) + return + self.cache.set(ADDON_NAME + '.recorded', None, expiration=datetime.timedelta(seconds=1)) + xbmcgui.Dialog().notification(ADDON_NAME, LANGUAGE(30024)%action.title(), ICON, 4000) + # xbmc.sleep(1001) + # xbmc.executebuiltin("Container.Update(plugin://plugin.video.ustvnow/?mode=1)") + # xbmc.executebuiltin("Container.Update(plugin://plugin.video.ustvnow/?mode=2)") + + + def playVideo(self, url, dvr=False): + log('playVideo, url = ' + url + ', dvr = ' + str(dvr)) + if dvr: label, path, liz = self.buildRecordedListItem(url) + else: label, path, liz = self.buildChannelListItem(url, opt='Live') + liz.setPath(self.resolveURL(url,dvr)) + xbmcplugin.setResolvedUrl(int(sys.argv[1]), True, liz) + + + def addLink(self, name, u, mode, liz, total=0): + log('addLink, name = ' + name) + u=sys.argv[0]+"?url="+urllib.quote(u)+"&mode="+str(mode)+"&name="+urllib.quote(uni(name)) + xbmcplugin.addDirectoryItem(handle=int(sys.argv[1]),url=u,listitem=liz,totalItems=total) + + + def addDir(self, name, u, mode, infoList=False, infoArt=False): + log('addDir, name = ' + name) + liz=xbmcgui.ListItem(name) + liz.setProperty('IsPlayable', 'false') + if infoList == False: liz.setInfo(type="Video", infoLabels={"mediatype":"video","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(u)+"&mode="+str(mode)+"&name="+urllib.quote(uni(name)) + xbmcplugin.addDirectoryItem(handle=int(sys.argv[1]),url=u,listitem=liz,isFolder=True) + + + def isHD(self): + if URL_TYPE == 'm3u8': return 'HD' + elif URL_QUALITY > 2: return 'HD' + return '' + + + def hasCC(self): + if URL_TYPE == 'm3u8': return True + return False + + + def uEPG(self): + log('uEPG') + #support for upcoming uEPG universal epg framework module, module will be available from the Kodi repository. + #https://github.com/Lunatixz/XBMC_Addons/tree/master/script.module.uepg + collect = [] + if self.channels is None: xbmc.executebuiltin("Container.Refresh") + for channel in self.channels: + try: + name = CHAN_NAMES[channel['stream_code']] + if self.isFree == True and name not in FREE_CHANS: continue + collect.append(name) + except: pass + + channelNum = 0 + counter = collections.Counter(collect) + for key, value in sorted(counter.iteritems()): + newChannel = {} + guidedata = [] + channelName = key + channelNum = channelNum + 1 + isHD = self.isHD() + hasCC = self.hasCC() + newChannel['channelname'] = channelName + newChannel['channelnumber'] = channelNum + for channel in self.channels: + try: + name = CHAN_NAMES[channel['stream_code']] + if self.isFree == True and name not in FREE_CHANS: continue + if name == channelName: + tmpdata = {} + mediatype = (channel.get('mediatype','') or (channel.get('connectorid',''))[:2] or (channel.get('content_id',''))[:2] or 'SP') + mtype = MEDIA_TYPES[mediatype.upper()] + thumb = IMG_SOURCE%(str(channel['srsid']),channel['callsign'],mediatype) + poster = thumb if mediatype.lower() == 'mv' else '' + logo = IMG_CHLOGO_W%(channel['callsign']) + newChannel['channellogo'] = logo + + for key, value in channel.iteritems(): + try: + tmpdata[uEPG_PARAMS[key]] = unescape(value) + except: + if key in FILE_PARAMS + PVR_PARAMS: + tmpdata[key] = unescape(value) + + # contextMenu = [('Schedules' ,'XBMC.RunPlugin(%s)'%(sys.argv[0]+"?mode="+str(1))), + # ('Recordings','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?mode="+str(2))), + # ('OnDemand' ,'XBMC.RunPlugin(%s)'%(sys.argv[0]+"?mode="+str(13)))] + + contextMenu = [] + if channel['dvrtimeraction'] == 'add': + opt = '@'.join([str(channel['prgsvcid']),(channel.get('event_time','') or str(channel.get('ut_start','')))])#lazy solution rather then create additional url parameters for this single function. + contextMenu.append(('Set single recording' ,'XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['scheduleid']))+"&mode="+str(6)+"&name="+urllib.quote(opt)))) + contextMenu.append(('Set recurring recording','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['connectorid']))+"&mode="+str(7)+"&name="+urllib.quote(opt)))) + else: + contextMenu.append(('Remove recording','XBMC.RunPlugin(%s)'%(sys.argv[0]+"?url="+urllib.quote(str(channel['scheduleid']))+"&mode="+str(8)+"&name="+urllib.quote(name)))) + + isNew = False #todo parse startime and data + label2 = isHD + tags = {'isHD':isHD,'hasCC':hasCC,'isNew':isNew} + tmpdata['label'] = unescape(channel['title']) + tmpdata['label2'] = label2 + # tmpdata['tagline'] = json.dumps(tags) + tmpdata['art'] = {"thumb":thumb,"poster":poster,"clearlogo":logo} + tmpdata['mediatype'] = mtype + tmpdata['url'] = sys.argv[0]+'?mode=9&url=%s'%name + tmpdata['contextmenu'] = json.dumps(contextMenu) + guidedata.append(tmpdata) + except: pass + newChannel['guidedata'] = guidedata + yield newChannel + +params=getParams() +try: url=urllib.unquote(params["url"]) +except: url=None +try: name=urllib.unquote(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: USTVnow().mainMenu() +elif mode == 0: USTVnow().browseLive() +elif mode == 1: USTVnow().browseRecordings() +elif mode == 2: USTVnow().browseRecordings(recorded=True) +elif mode == 3: USTVnow().browseGuide() +elif mode == 4: USTVnow().browseGuide(name) +elif mode == 5: USTVnow().browseFeatured() +elif mode == 6: USTVnow().setRecording(name,url) +elif mode == 7: USTVnow().setRecording(name,url,recurring=True) +elif mode == 8: USTVnow().setRecording(name,url,remove=True) +elif mode == 9: USTVnow().playVideo(url) +elif mode == 10:USTVnow().playVideo(url,dvr=True) +elif mode == 11:USTVnow().search() +elif mode == 12: USTVnow().browseFeatured(True) +elif mode == 13:USTVnow().browseVOD(url) +elif mode == 19:xbmc.executebuiltin("RunScript(script.module.uepg,listitem=%s&skin_path=%s&refresh_path=%s&refresh_interval=%s&row_count=%s)"%(urllib.quote(sys.argv[0]+"?mode=3"),urllib.quote(json.dumps(ADDON_PATH)),urllib.quote(json.dumps(sys.argv[0]+"?mode=19")),urllib.quote(json.dumps("7200")),urllib.quote(json.dumps("7")))) +elif mode == 20:xbmc.executebuiltin("RunScript(script.module.uepg,json=%s&skin_path=%s&refresh_path=%s&refresh_interval=%s&row_count=%s)"%(urllib.quote(json.dumps(list(USTVnow().uEPG()))),urllib.quote(json.dumps(ADDON_PATH)),urllib.quote(json.dumps(sys.argv[0]+"?mode=20")),urllib.quote(json.dumps("7200")),urllib.quote(json.dumps("7")))) +elif mode == 21:xbmc.executebuiltin("action(ContextMenu)") + +xbmcplugin.setContent(int(sys.argv[1]) , CONTENT_TYPE) +xbmcplugin.addSortMethod(int(sys.argv[1]) , xbmcplugin.SORT_METHOD_UNSORTED) +xbmcplugin.addSortMethod(int(sys.argv[1]) , xbmcplugin.SORT_METHOD_NONE) +xbmcplugin.addSortMethod(int(sys.argv[1]) , xbmcplugin.SORT_METHOD_LABEL) +xbmcplugin.addSortMethod(int(sys.argv[1]) , xbmcplugin.SORT_METHOD_TITLE) +xbmcplugin.endOfDirectory(int(sys.argv[1]), cacheToDisc=True)
\ No newline at end of file |