Python module (submodule repositary), which provides content (video streams) from various online stream sources to corresponding Enigma2, Kodi, Plex plugins

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316
  1. #!/usr/bin/env python
  2. # coding=utf8
  3. #
  4. # This file is part of PlayStream - enigma2 plugin to play video streams from various sources
  5. # Copyright (c) 2016 ivars777 (ivars777@gmail.com)
  6. # Distributed under the GNU GPL v3. For full terms see http://www.gnu.org/licenses/gpl-3.0.en.html
  7. #
  8. try:
  9. import json
  10. except:
  11. import simplejson as json
  12. import os
  13. import urllib2, urllib
  14. import datetime, re, sys
  15. import ssl
  16. if "_create_unverified_context" in dir(ssl):
  17. ssl._create_default_https_context = ssl._create_unverified_context
  18. from SourceBase import SourceBase
  19. import util
  20. API_URL = 'http://replay.lsm.lv/%s/'
  21. headers2dict = lambda h: dict([l.strip().split(": ") for l in h.strip().splitlines()])
  22. headers0 = headers2dict("""
  23. User-Agent: Mozilla/5.0 (Linux; U; Android 4.4.4; Nexus 5 Build/KTU84P) AppleWebkit/534.30 (KHTML, like Gecko) Version/4.0 Mobile Safari/534.30
  24. """)
  25. import HTMLParser
  26. h = HTMLParser.HTMLParser()
  27. from YouTubeVideoUrl import YouTubeVideoUrl
  28. class Source(SourceBase):
  29. def __init__(self,country="lv",cfg_path=None):
  30. self.name = "replay"
  31. self.title = "Replay.lv (LTV)"
  32. self.img = "replay.png"
  33. self.desc = "LSM replay.lv satura skatīšanās"
  34. self.country=country
  35. self.pic_size = "327x250" #"1000x765"
  36. def get_content(self, data):
  37. print "[replay] get_content:", data
  38. if "::" in data:
  39. data = data.split("::")[1]
  40. path = data.split("?")[0]
  41. clist = path.split("/")[0]
  42. params = data[data.find("?"):] if "?" in data else ""
  43. qs = dict(map(lambda x:x.split("="),re.findall("\w+=\w+",params)))
  44. lang = qs["lang"] if "lang" in qs else self.country
  45. content=[]
  46. content.append(("..return", "back","back.png","Return back"))
  47. if clist=="home":
  48. content.extend([
  49. ("Live streams", "replay::tiesraide","","TV live streams"),
  50. ("Search LV", "replay::search/?term={0}&lang=lv","","Search content LV"),
  51. ("Last videos LV", "replay::visi/jaunakie/?source=ltv&lang=lv","","Last aired videos LV"),
  52. ("Last videos by categories LV", "replay::kategorijas/?lang=lv","","Last videos by categories LV"),
  53. ("All programs LV", "replay::raidijumi/?type=video","","All programs by name LV"),
  54. ("Programs by categories LV", "replay::categories?lang=lv","","All programs by categories LV"),
  55. #("Channels", "replay::channels?language=%s"%self.country,"","TV channels"),
  56. ("Videos by popularity LV", "replay::visi/popularie/?source=ltv&lang=lv","","Programs by popularity"),
  57. ("Search RU", "replay::search/?term={0}&lang=ru","","Search content RU"),
  58. ("Last videos RU", "replay::vse/novie/?source=ltv&lang=ru","","Last aired videos RU"),
  59. ("Last videos by categories RU", "replay::kategorijas/?lang=ru","","Last videos by categories RU"),
  60. ("All programs RU", "replay::peredachi/?lang=ru&type=video","","All programs by name"),
  61. ("Programs by categories RU", "replay::categories?lang=ru","","Programs by categories RU")
  62. ])
  63. return content
  64. ### programmu kategorijas ###
  65. elif clist=="categories":
  66. url = "http://replay.lsm.lv/lv/raidijumi/?lang=lv&type=video" if lang =="lv" else "http://replay.lsm.lv/ru/peredachi/?lang=ru&type=video"
  67. r = self._http_request(url)
  68. for item in re.findall(r'<a .+href="(\?lang=\w+&type=video&theme=\d+)">([^<]+)</a>\t', r):
  69. title = item[1]
  70. data2 = url.split("?")[0]+item[0]
  71. data2 = data2.replace(API_URL%lang,"")
  72. img = ""
  73. desc = title
  74. content.append((title,self.name+"::"+data2,img,desc))
  75. return content
  76. ### jaunāko raidijumu kategorijas ###
  77. elif clist=="kategorijas":
  78. url = "http://replay.lsm.lv/lv/" if lang =="lv" else "http://replay.lsm.lv/ru/"
  79. r = self._http_request(url)
  80. for item in re.findall(r'<a href="/(lv|ru)/kategorija/(\w+)/">.+?<i class="[^"]+"></i>.+?<span>([^<]+)</span>', r, re.DOTALL):
  81. title = item[2]
  82. data2 = "kategorija/%s/?lang=%s"%(item[1],item[0])
  83. img = ""
  84. desc = title
  85. content.append((title,self.name+"::"+data2,img,desc))
  86. return content
  87. ### Tiešraides kanānālu saraksts
  88. elif path=="tiesraide":
  89. url2 = "http://replay.lsm.lv/styles/main.css"
  90. r2= self._http_request(url2)
  91. url = "http://replay.lsm.lv/lv/tiesraide/ltv1/"
  92. # <div class="visible-xs">
  93. r= self._http_request(url)
  94. i2 = r.find('<div class="visible-xs">')
  95. result = re.findall(r"""onclick="RE.tools.navigate\('/lv/(tiesraide/\w+/)'\).+?<h5>([^<]+)</h5>.+?<time>([^<]+)</time>""", r[0:i2], re.DOTALL)
  96. for item in result:
  97. data2 = item[0]
  98. ch = data2.split("/")[1]
  99. title = ch.upper()
  100. m = re.search(r'channel-logo--%s{background-image:url\("([^"]+)"\)' % ch, r2, re.DOTALL)
  101. img = "http://replay.lsm.lv" + m.group(1)
  102. desc = item[1]
  103. # 00:10 &ndash; 00:45
  104. desc = desc + " (%s)" % item[2].replace("&ndash;", "-")
  105. content.append((title,self.name+"::"+data2,img,desc))
  106. return content
  107. ### Kanāla tiesraide
  108. elif clist == "tiesraide" and "/" in data:
  109. ch = data.split('/')[1]
  110. veids = "audio" if "lr" in ch else "video"
  111. #url = "http://replay.lsm.lv/lv/tiesraide/ltv7/"
  112. url = "http://replay.lsm.lv/lv/tiesraide/%s/"%ch
  113. r= self._http_request(url)
  114. m = re.search('%s/">.+?<h5>([^<]+)+</h5>.*?<time>([^<]+)</time>'%ch, r, re.DOTALL)
  115. tagad = m.group(1).strip() if m else ""
  116. laiks = m.group(2).strip() if m else ""
  117. laiks = h.unescape(laiks).encode("utf8")
  118. m = re.search("<h1>([^<]+)</h1>", r)
  119. title = m.group(1).strip() if m else path.split("/")[1].upper()
  120. title = "%s - %s (%s)"%(title,tagad,laiks)
  121. if veids == "video":
  122. m = re.search('<div class="video"><iframe.+src="([^"]+)"', r)
  123. if not m:
  124. raise Exception("No stream found")
  125. url = m.group(1)
  126. headers = headers2dict("""
  127. User-Agent: Mozilla/5.0 (Linux; U; Android 4.4.4; Nexus 5 Build/KTU84P) AppleWebkit/534.30 (KHTML, like Gecko) Version/4.0 Mobile Safari/534.30
  128. Referer: http://replay.lsm.lv/lv/ieraksts/ltv/70398/tiesa-runa.-lielbritanija-gatavojas-referendumam-par-tu/
  129. """)
  130. r = self._http_request(url,headers=headers)
  131. #m = re.search('<div class="video-player"><iframe.+src="([^"]+)"', r)
  132. m = re.search(r'iframe src=\\"([^"]+)\\', r)
  133. if not m:
  134. raise Exception("No stream found")
  135. url = m.group(1).replace('\\/', "/")
  136. m = re.search('poster":"([^"]+)"', r, re.DOTALL)
  137. img = "http://ltv.lsm.lv" + m.group(1).replace("\\","") if m else ""
  138. r = self._http_request(url,headers=headers)
  139. m = re.search('"([^"]+m3u8[^"]+)"', r)
  140. if not m:
  141. raise Exception("No stream found")
  142. data2 = m.group(1).replace("\\","")
  143. #r = self._http_request(data2, headers=headers)
  144. else: # audio
  145. lrn = ch.replace("lr","")
  146. url = "http://www.latvijasradio.lsm.lv/lv/tiesraide/?channel=%s"%lrn
  147. r = self._http_request(url)
  148. m = re.search('"file":"([^"]+?m3u8.*?)"', r)
  149. if not m:
  150. raise Exception("No stream found")
  151. data2 = m.group(1).replace("\\","")
  152. img = ""
  153. desc = ""
  154. desc = title
  155. content =(title,data2,img,desc)
  156. return content
  157. #m = re.search(r'(\?page=\d+)" class=" paging__prev', r, re.IGNORECASE)
  158. #if m:
  159. # data = re.sub("\?page=\d+", "", data)
  160. # data2 = data+m.group(1)
  161. # content.append(("Previous page",self.name+"::"+data2,"","Previous page"))
  162. r = self.call(data, lang=lang)
  163. if not r:
  164. return content
  165. if clist == "search":
  166. #for r2 in re.findall('<article itemtype="http://schema.org/Article" itemscope class="thumbnail thumbnail--default ">(.+?)</article>', r2, re.DOTALL):
  167. for item in re.findall('itemprop="image" data-image="([^"]+)".+?<figcaption><h5 itemprop="name"><a itemprop="url" href="([^<]+)">([^<]+)</a></h5></figcaption>', r):
  168. title = item[2]
  169. data2 = item[1].replace("/%s/"%lang,"")+"?lang=%s"%lang
  170. img = "http://replay.lsm.lv" + item[0]
  171. desc = title
  172. content.append((title,self.name+"::"+data2,img,desc))
  173. #for item in re.findall('itemprop="image" data-image="([^"]+)".+?<figcaption><h4 itemprop="about"><a href="([^"]+)">([^<]+)</a></h4>.*?<h5 itemprop="name"><a itemprop="url" href="([^"]+)">([^<]+)</a></h5>.+?datetime="([^"]+)" class="thumbnail__date ">([^<]+)</time>', r2):
  174. for item in re.findall('itemprop="image" data-image="([^"]+)".+? class="icon-(ltv|lr).+?<figcaption><h4 itemprop="about"><a href="([^"]+)">([^<]+)</a></h4>.*?<h5 itemprop="name"><a itemprop="url" href="([^"]+)">([^<]+)</a></h5>.+?datetime="([^"]+)" class="thumbnail__date ">([^<]+)</time>', r):
  175. if item[1]=="lr":continue
  176. title = "%s - %s (%s)"%(item[3],item[5],item[7])
  177. data2 = item[4].replace("/%s/"%lang,"")+"?lang=%s"%lang
  178. img = item[0].replace("https:","http:")
  179. desc = title
  180. content.append((title,self.name+"::"+data2,img,desc))
  181. ### Raidijumi (programmas) ###
  182. elif clist in ( "raidijumi","peredachi"):
  183. for item in re.findall('<li itemprop="name"><a href="([^"]+)" itemprop="url">([^<]+)', r):
  184. #for item in re.findall('<li itemprop="name"><a href="([^"]+)" itemprop="url">([^<]+)</a></li>', r):
  185. title = item[1].strip()
  186. data2 = item[0].replace("/%s/"%lang,"")+"?lang=%s"%lang
  187. img = ""
  188. desc = ""
  189. content.append((title,self.name+"::"+data2,img,desc))
  190. ### Raidijuma ieraksti speciālie###
  191. elif clist in ( "visi","vse",):
  192. for item in re.findall('(?i)<figure><a href="([^"]+)" itemprop="image" data-image="([^"]+)".+class="thumbnail__duration">([^<]+)</time></figure><figcaption><h4 itemprop="about"><a href="[^"]+">([^<]+)</a></h4>.+>([^<]+).*</h5>.+>([^<]+)</time></figcaption>', r):
  193. title = item[3].strip()
  194. data2 = item[0].replace("/%s/"%lang,"")+"?lang=%s"%lang
  195. img = item[1].replace("https:","http:")
  196. desc = "%s - %s\n%s"%(item[5],item[2],item[4])
  197. content.append((title,self.name+"::"+data2,img,desc))
  198. ### Raidijuma ieraksti (videos)
  199. elif clist in ("raidijums","peredacha","kategorija"):
  200. for item in re.findall('<article .+ href="([^"]+)".+image="([^"]+)".+class="thumbnail__duration">([^<]+).+">([^<]+).+class="thumbnail__date ">([^"]+)</time></figcaption></article>', r):
  201. title = item[3].strip()
  202. data2 = item[0].replace("/%s/"%lang,"")+"?lang=%s"%lang
  203. img = item[1].replace("https:","http:")
  204. desc = "%s - %s"%(item[4],item[2])
  205. desc = desc.strip()
  206. content.append((title,self.name+"::"+data2,img,desc))
  207. ### Ieraksts (video) ###
  208. elif clist in ("ieraksts","statja"):
  209. m = re.search('src="([^"]+)"></iframe>', r)
  210. if m:
  211. url2 = m.group(1)
  212. m = re.search('<meta property="og:title" content="([^"]+)"', r, re.DOTALL)
  213. title = m.group(1)
  214. m = re.search('<meta property="og:image" content="([^"]+)"', r, re.DOTALL)
  215. img = m.group(1)
  216. m = re.search('<meta property="og:description" content="([^"]+)"', r, re.DOTALL)
  217. desc = m.group(1)
  218. m = re.search('<div class="media-description">(.+)<div id="tab-comments">', r, re.DOTALL)
  219. if m:
  220. rr = re.sub("<.+?>", " ", m.group(1))
  221. rr = re.sub("[\t\n]", " ", rr)
  222. desc = re.sub(" {2,100}", " ", rr).strip()
  223. headers = headers2dict("""
  224. User-Agent: Mozilla/5.0 (Linux; U; Android 4.4.4; Nexus 5 Build/KTU84P) AppleWebkit/534.30 (KHTML, like Gecko) Version/4.0 Mobile Safari/534.30
  225. Referer: http://replay.lsm.lv/lv/ieraksts/ltv/70398/tiesa-runa.-lielbritanija-gatavojas-referendumam-par-tu/
  226. """)
  227. r2 = self._http_request(url2,headers=headers)
  228. m = re.search('"file":"([^"]+)', r2)
  229. if m:
  230. data2 = m.group(1).replace("\\","")
  231. m = re.search('"idstring":"([^"]+)', r2)
  232. #title = m.group(1).strip() if m else ""
  233. #title = title.decode("unicode-escape").encode("utf8")
  234. #title = title.replace("\n","")
  235. #img = ""
  236. #desc = ""
  237. if "youtube" in data2:
  238. video_id = re.search(r"/watch\?v=([^&]+)",data2).group(1)
  239. data2 = YouTubeVideoUrl().extract(video_id)
  240. if not data2:
  241. content=("No stream found %s"%data,"","","No stream found")
  242. return content
  243. content =(title,data2,img,desc)
  244. return content
  245. content=("No stream found %s"%data,"","","No stream found")
  246. return content
  247. m = re.search(r'href="\?([^"]+)" class=" paging__next', r)
  248. if m:
  249. page = int(re.search("page=(\d+)",m.group(1)).group(1))
  250. if "page="in data:
  251. data2 = re.sub("page=\d+","page=%i"%page,data)
  252. else:
  253. if "?" in data:
  254. data2 =data+"&page=%i"%page
  255. else:
  256. data2 =data+"?page=%i"%page
  257. content.append(("Next page",self.name+"::"+data2,"","Next page"))
  258. return content
  259. def is_video(self,data):
  260. if "::" in data:
  261. data = data.split("::")[1]
  262. cmd = data.split("/")
  263. if cmd[0] in ("ieraksts","statja"):
  264. return True
  265. elif cmd[0]=="tiesraide" and len(cmd)>1:
  266. return True
  267. else:
  268. return False
  269. def call(self, data,headers=headers0,lang=""):
  270. if not lang: lang = self.country
  271. url = API_URL%lang + data
  272. #print "[TVPlay Api] url: ",url
  273. result = []
  274. content = self._http_request(url,headers=headers0)
  275. return content
  276. if __name__ == "__main__":
  277. sys.path.insert(0, os.path.dirname(os.path.dirname(__file__)))
  278. import run
  279. source = Source()
  280. data= sys.argv[1] if len(sys.argv)>1 else source.name+"::home"
  281. run.run(source, data)
  282. sys.exit()