(.+?)<', r, title2)
m = re.search('
([^<]+)
([^<]+)
', r)
if m:
ep1 = m.group(1)
ep2 = m.group(2)
nfo["title"] = "%s - %s(%s)"%(nfo["set"], ep1, ep2)
nfo["originaltitle"] = nfo["originaltitle"] + "(%s)" % ep2
m = re.search("S(\d+)E(\d+)", ep2)
if m:
nfo["season"] = m.group(1)
nfo["eposode"] = m.group(2)
nfo["thumb"] = tt('
Gads<.+?content">([^<]+)<', r, "")
nfo["runtime"] = tt('movie-informatio-title">Garums<.+?content">([^<]+)<', r, "")
nfo["quality"] = tt('movie-informatio-title">Kvalitāte<.+?content">([^<]+)<', r, "")
nfo["genre"]=tt('movie-informatio-title">Žanrs<.+?content">([^<]+)<', r, "")
nfo["director"] = tt('movie-informatio-title">Režisors<.+?content">([^<]+)<', r, "")
nfo["actor"] = tt2('movie-informatio-title">Aktieri<.+?content">([^<]+)<', r, "")
nfo["language"] = tt2('movie-informatio-title">Valodas*<.+?content">([^<]+)<', r, "")
nfo["subtitles"] = tt2('movie-informatio-title">Subtitri<.+?content">([^<]+)<', r, "")
nfo["plot"] = tt('movie-informatio-title">Apraksts<.+?content">([^<]+)<', r, "")
nfo["tagline"] = nfo["plot"]
return nfo
def get_stream_url2(self,data):
video_id=data[data.find("/")+1:]
if not self.is_logedin2():
if not self.login2():
return []
#data2 = self.get_noma_url(video_id)
nfo = self.get_info2(data)
title = util.nfo2title(nfo)
desc = util.nfo2desc(nfo)
img = nfo["thumb"]
#xml = util.nfo2xml(nfo)
url = "https://www.lattelecom.tv/xmls/%s.xml"%video_id
headers = self.headers2
headers["Cookie"] = self.session_id
response = urllib2.urlopen(urllib2.Request(url, headers=headers))
r = response.read()
servers = re.findall("(?s)
([^<]+)", r)
streams_xml = re.findall('
(mp4:\w+(\w\w)_(\w\w).mp4)',r)
resource_id = re.search("(?s)
([^<]+)", r).group(1)
token = re.search("(?s)
([^<]+)", r).group(1)
streams=[]
captions = []
llist = ["fr","en","ru","lv"]
for s in re.findall('
([^<]+)', r, re.DOTALL):
sub = {}
sub["url"] = s[1]
sub["lang"] = s[0]
sub["name"] = "captions (vtt)"
sub["type"] = "vtt"
sub["order"] = llist.index(sub["lang"])*10 if sub["lang"] in llist else 0
captions.append(sub)
captions = sorted(captions,key=lambda item: item["order"],reverse=True)
for s in streams_xml:
for server in servers:
stream = util.item()
server2 = self.load_balancer(server)
url = "http://%s/mobile-vod/%s/playlist.m3u8?resource_id=%s&auth_token=%s"%(server2,s[0],resource_id,token)
# TODO Engima2 gstreamer vajag lai padod playlist nevis chunklist
# r3 = self._http_request(url)
# sss = re.findall(r"#EXT-X-STREAM-INF:.*?BANDWIDTH=(\d+).*?\n(.+?)$", r3, re.IGNORECASE | re.MULTILINE)
# if sss:
# url2 = sss[0][1]
# stream["headers"] = {"Referer":url}
# if url2.startswith("http"):
# url = url2
# else:
# url = util.hls_base(url)+url2
stream["url"]=url
stream["lang"]=s[1]
stream["quality"]=s[2]
stream["name"]=title
stream["desc"]=desc
stream["img"] = img
stream["nfo"] = {"movie":nfo}
stream["type"]="hls" #stream_type(url)
stream["subs"] = []
for c in captions:
c2= c.copy()
#c2["url"] ="http://%s/mobile-vod/%s/%s?resource_id=%s&auth_token=%s"%(server2,s[0],c["url"],resource_id,token)
c2["url"] ="http://%s/mobile-vod/%s/%s"%(server2,s[0],c["url"])
stream["subs"].append(c2)
pass
streams.append(stream)
break # TODO ņem tikai pirmo serveri, varētu pārbaudit, kurš no tiem strādā, kurš ne
return streams
#data = {}
#data["server"] = re.findall("(?s)
([^<]+)", r)[1]
#data["language"]=re.findall('(?s)
', r)
#data["language"]="lv" if "lv" in data["language"] else "ru" if "ru" in data["language"] else "en"
#data["qs"]=re.findall('(?s)([^<]+)', r)
#data["qs"]=dict(data["qs"])
#qs = data["qs"].keys()
#data["quality"] = "hd" if "hd" in qs else "hq" if "hq" in qs else "mhq" if "mhq" in qs else "lq"
#data["mp4"] = data["qs"][data["quality"]]
#data["token"] = re.search("(?s)([^<]+)", r).group(1)
#data["resource_id"]=re.search("(?s)([^<]+)", r).group(1)
#data["server"]=self.load_balancer(data["server"])
#data["hls"] = "http://%s/mobile-vod/%s/playlist.m3u8?resource_id=%s&auth_token=%s"%(data["server"],data["mp4"],data["resource_id"],data["token"])
##data["hls"]="http://%s/mobile-vod/mp4:%s/playlist.m3u8?resource_id=%s&auth_token=app_%s"%(data["server"],data["mp4"],data["resource_id"],data["token"])
### wwww.lattelecom.tv izsaukumi
def login2(self,user="",password=""):
"""Login in to site, create session cookies"""
if not user: user=self.options["user"]
if not password: password = self.options["password"]
url0 = "https://www.lattelecom.tv"
class NoRedirectHandler(urllib2.HTTPRedirectHandler):
def http_error_302(self, req, fp, code, msg, headers):
infourl = urllib.addinfourl(fp, headers, req.get_full_url())
infourl.status = code
infourl.code = code
return infourl
http_error_300 = http_error_302
http_error_301 = http_error_302
http_error_303 = http_error_302
http_error_307 = http_error_302
# Dabūjam sesijas id un url_gif, kas redirektējas uz auth_url
headers = headers2dict("""
Host: www.lattelecom.tv
User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:46.0) Gecko/20100101 Firefox/46.0
Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8
Accept-Language: en-US,en;q=0.5
DNT: 1
Connection: keep-alive
""")
response = urllib2.urlopen(urllib2.Request(url0, headers=headers))
session_id = response.headers["set-cookie"].split(";")[0]
html = response.read()
url_gif = url0 + re.search('(/auth/\d+\.gif)', html).group(1)
# Dabūtjam auth_url
headers = headers2dict("""
Host: www.lattelecom.tv
User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:46.0) Gecko/20100101 Firefox/46.0
Accept: image/png,image/*;q=0.8,*/*;q=0.5
Accept-Language: en-US,en;q=0.5
DNT: 1
Referer: https://www.lattelecom.tv/
""")
headers["Cookie"] = session_id
urllib2.install_opener(urllib2.build_opener(NoRedirectHandler()))
response = urllib2.urlopen(urllib2.Request(url_gif, headers=headers))
if response.code == 302:
url_auth = response.headers["location"]
else:
self.error = u"auth.gif nenostrādāja"
#raise u"auth.gif nenostrādāja"
return False
# Pierakstāmies iekš auth.lattelecom.lv
headers = headers2dict("""
Host: auth.lattelecom.lv
User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:46.0) Gecko/20100101 Firefox/46.0
Accept: image/png,image/*;q=0.8,*/*;q=0.5
Accept-Language: en-US,en;q=0.5
DNT: 1
Referer: https://www.lattelecom.tv/
""")
response = urllib2.urlopen(urllib2.Request(url_auth, headers=headers))
if not response.code == 302:
self.error = u"pierakstīšanās auth.lattelecom.lv nenostrādāja"
return False
#raise "pierakstīšanās auth.lattelecom.lv nenostrādāja"
# Mēģinam ielogoties
headers = headers2dict("""
Host: www.lattelecom.tv
User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:46.0) Gecko/20100101 Firefox/46.0
Accept: text/javascript, application/javascript, application/ecmascript, application/x-ecmascript, */*; q=0.01
Accept-Language: en-US,en;q=0.5
DNT: 1
X-Requested-With: XMLHttpRequest
Referer: https://www.lattelecom.tv/
""")
headers["Cookie"] = session_id
#data = "login=yes&email=%s&passw=%s"%(user,password)
url = "https://www.lattelecom.tv/login.json?callback=jQuery111303344749731668816_1463817318435&username=%s&password=%s&captcha=&sid=&_="%(user,password)
req = urllib2.Request(url, headers=headers)
response = urllib2.urlopen(req)
#with open("auth.htm","w") as f: f.write(response.read())
if not response.code == 200:
#self.error = u"kļūda ielogojoties"
raise Exception(u"kļūda ielogojoties")
html = response.read()
if not '"success":true' in html:
err = re.search('"error":"(.+?)"',html).group(1) if re.search('"error":"(.+?)"',html) else ""
raise Exception(u"Kļūda ielogojoties - %s"%err.decode("utf8"))
self.session_id = session_id
self.headers2["Cookie"] = "%s; "%(self.session_id)
self.error = ""
return True
def check_logedin2(self):
if not self.session_id:
return False
else:
url = "https://www.lattelecom.tv/profils"
response = urllib2.urlopen(urllib2.Request(url, headers=self.headers2))
if response.code == 200:
return True
else:
self.session_id = ""
return False
def is_logedin2(self):
if self.session_id:
return True
else:
return False
def load_balancer(self,server,streams=[]):
headers = headers2dict("""
Connection: keep-alive
User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.102 Safari/537.36
X-Requested-With: ShockwaveFlash/21.0.0.242
""")
url = "http://%s/loadbalancer"%server
response = urllib2.urlopen(urllib2.Request(url, headers=headers))
r = response.read()
statuss = re.search("(\d+)",r).group(1)
edge = re.search("([^<>]+)",r).group(1)
return edge
def test_hls(self,url):
headers = headers2dict("""
Connection: keep-alive
User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.102 Safari/537.36
""")
try:
response = urllib2.urlopen(urllib2.Request(url, headers=headers))
except Exception as ex:
print "hls failed: %s %s"%(ex.getcode(),url)
return False
if response.code == 200:
html = response.read()
url0 = re.search("(http://[^/]+/)",url).group(1)
chunklist = re.search("(chunklist.+)",html).group(1).strip()
url2 = url.split('/')[:-1]
url2 ="/".join(url2)+"/"+chunklist
try:
response2 = urllib2.urlopen(urllib2.Request(url2, headers=headers))
except Exception as ex:
print "hls chunk failed: %s %s"%(ex.getcode(),url2)
return False
if response2.code == 200:
return True
else:
return False
else:
return False
if __name__ == "__main__":
sys.path.insert(0, os.path.dirname(os.path.dirname(__file__)))
import run
source = Source()
data= sys.argv[1] if len(sys.argv)>1 else source.name+"::home"
run.run(source, data)
sys.exit()
c.get_info2(sys.argv[1])
if len(sys.argv)>1 and not "ltc::" in sys.argv[1]:
vid = vid2 = sys.argv[1]
password = sys.argv[2]
print "login - %s"%c.login("ivars777",password)
#vid = "1069"
#vid = "1462566072086"
#channelid="101"
#vid = "1350462656767"
#data = c.get_stream_url(vid,"vod")
#call([r"c:\Program Files\VideoLAN\VLC\vlc.exe",data["stream"]])
#pass
print "login2 - %s"%c.login2("ivars777",password)
#vid2 = "animation/ultimate_avengers_ii"
#vid2 = "animation/ice_age"
#vid2 = "tiesraide/ltv1"
#vid2 = "arhivs/1456521417815"
streams = c.get_stream_url2(vid2)
stream = streams[-1]
print
#for s in data:
#call([r"c:\Program Files\VideoLAN\VLC\vlc.exe",stream["url"]])
cmd = ["ffplay.exe",
"-headers","Referer:%s"%(quote(stream["headers"]["Referer"])),
"-headers","Connection:Keep-Alive",
stream["url"]]
print " ".join(cmd)
call(cmd)
pass
else:
if len(sys.argv)>1:
data= sys.argv[1]
else:
data = "ltc::home"
content = c.get_content(data)
for item in content:
print item
#cat = api.get_categories(country)
#chan = api.get_channels("lv")
#prog = api.get_programs(channel=6400)
#prog = api.get_programs(category=55)
#seas = api.get_seasons(program=6453)
#str = api.get_streams(660243)
#res = api.get_videos(802)
#formats = api.getAllFormats()
#det = api.detailed("1516")
#vid = api.getVideos("13170")
pass