You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

366 lines
12 KiB

  1. from __future__ import unicode_literals
  2. from .subtitles import SubtitlesInfoExtractor
  3. from .common import InfoExtractor
  4. from ..utils import (
  5. fix_xml_ampersands,
  6. parse_duration,
  7. qualities,
  8. strip_jsonp,
  9. unified_strdate,
  10. url_basename,
  11. )
  12. class NPOBaseIE(SubtitlesInfoExtractor):
  13. def _get_token(self, video_id):
  14. token_page = self._download_webpage(
  15. 'http://ida.omroep.nl/npoplayer/i.js',
  16. video_id, note='Downloading token')
  17. return self._search_regex(
  18. r'npoplayer\.token = "(.+?)"', token_page, 'token')
  19. class NPOIE(NPOBaseIE):
  20. IE_NAME = 'npo.nl'
  21. _VALID_URL = r'https?://(?:www\.)?npo\.nl/(?!live|radio)[^/]+/[^/]+/(?P<id>[^/?]+)'
  22. _TESTS = [
  23. {
  24. 'url': 'http://www.npo.nl/nieuwsuur/22-06-2014/VPWON_1220719',
  25. 'md5': '4b3f9c429157ec4775f2c9cb7b911016',
  26. 'info_dict': {
  27. 'id': 'VPWON_1220719',
  28. 'ext': 'm4v',
  29. 'title': 'Nieuwsuur',
  30. 'description': 'Dagelijks tussen tien en elf: nieuws, sport en achtergronden.',
  31. 'upload_date': '20140622',
  32. },
  33. },
  34. {
  35. 'url': 'http://www.npo.nl/de-mega-mike-mega-thomas-show/27-02-2009/VARA_101191800',
  36. 'md5': 'da50a5787dbfc1603c4ad80f31c5120b',
  37. 'info_dict': {
  38. 'id': 'VARA_101191800',
  39. 'ext': 'm4v',
  40. 'title': 'De Mega Mike & Mega Thomas show',
  41. 'description': 'md5:3b74c97fc9d6901d5a665aac0e5400f4',
  42. 'upload_date': '20090227',
  43. 'duration': 2400,
  44. },
  45. },
  46. {
  47. 'url': 'http://www.npo.nl/tegenlicht/25-02-2013/VPWON_1169289',
  48. 'md5': 'f8065e4e5a7824068ed3c7e783178f2c',
  49. 'info_dict': {
  50. 'id': 'VPWON_1169289',
  51. 'ext': 'm4v',
  52. 'title': 'Tegenlicht',
  53. 'description': 'md5:d6476bceb17a8c103c76c3b708f05dd1',
  54. 'upload_date': '20130225',
  55. 'duration': 3000,
  56. },
  57. },
  58. {
  59. 'url': 'http://www.npo.nl/de-nieuwe-mens-deel-1/21-07-2010/WO_VPRO_043706',
  60. 'info_dict': {
  61. 'id': 'WO_VPRO_043706',
  62. 'ext': 'wmv',
  63. 'title': 'De nieuwe mens - Deel 1',
  64. 'description': 'md5:518ae51ba1293ffb80d8d8ce90b74e4b',
  65. 'duration': 4680,
  66. },
  67. 'params': {
  68. # mplayer mms download
  69. 'skip_download': True,
  70. }
  71. },
  72. # non asf in streams
  73. {
  74. 'url': 'http://www.npo.nl/hoe-gaat-europa-verder-na-parijs/10-01-2015/WO_NOS_762771',
  75. 'md5': 'b3da13de374cbe2d5332a7e910bef97f',
  76. 'info_dict': {
  77. 'id': 'WO_NOS_762771',
  78. 'ext': 'mp4',
  79. 'title': 'Hoe gaat Europa verder na Parijs?',
  80. },
  81. },
  82. ]
  83. def _real_extract(self, url):
  84. video_id = self._match_id(url)
  85. return self._get_info(video_id)
  86. def _get_info(self, video_id):
  87. metadata = self._download_json(
  88. 'http://e.omroep.nl/metadata/aflevering/%s' % video_id,
  89. video_id,
  90. # We have to remove the javascript callback
  91. transform_source=strip_jsonp,
  92. )
  93. token = self._get_token(video_id)
  94. formats = []
  95. pubopties = metadata.get('pubopties')
  96. if pubopties:
  97. quality = qualities(['adaptive', 'wmv_sb', 'h264_sb', 'wmv_bb', 'h264_bb', 'wvc1_std', 'h264_std'])
  98. for format_id in pubopties:
  99. format_info = self._download_json(
  100. 'http://ida.omroep.nl/odi/?prid=%s&puboptions=%s&adaptive=yes&token=%s'
  101. % (video_id, format_id, token),
  102. video_id, 'Downloading %s JSON' % format_id)
  103. if format_info.get('error_code', 0) or format_info.get('errorcode', 0):
  104. continue
  105. streams = format_info.get('streams')
  106. if streams:
  107. video_info = self._download_json(
  108. streams[0] + '&type=json',
  109. video_id, 'Downloading %s stream JSON' % format_id)
  110. else:
  111. video_info = format_info
  112. video_url = video_info.get('url')
  113. if not video_url:
  114. continue
  115. if format_id == 'adaptive':
  116. formats.extend(self._extract_m3u8_formats(video_url, video_id))
  117. else:
  118. formats.append({
  119. 'url': video_url,
  120. 'format_id': format_id,
  121. 'quality': quality(format_id),
  122. })
  123. streams = metadata.get('streams')
  124. if streams:
  125. for i, stream in enumerate(streams):
  126. stream_url = stream.get('url')
  127. if not stream_url:
  128. continue
  129. if '.asf' not in stream_url:
  130. formats.append({
  131. 'url': stream_url,
  132. 'quality': stream.get('kwaliteit'),
  133. })
  134. continue
  135. asx = self._download_xml(
  136. stream_url, video_id,
  137. 'Downloading stream %d ASX playlist' % i,
  138. transform_source=fix_xml_ampersands)
  139. ref = asx.find('./ENTRY/Ref')
  140. if ref is None:
  141. continue
  142. video_url = ref.get('href')
  143. if not video_url:
  144. continue
  145. formats.append({
  146. 'url': video_url,
  147. 'ext': stream.get('formaat', 'asf'),
  148. 'quality': stream.get('kwaliteit'),
  149. })
  150. self._sort_formats(formats)
  151. subtitles = {}
  152. if metadata.get('tt888') == 'ja':
  153. subtitles['nl'] = 'http://e.omroep.nl/tt888/%s' % video_id
  154. if self._downloader.params.get('listsubtitles', False):
  155. self._list_available_subtitles(video_id, subtitles)
  156. return
  157. subtitles = self.extract_subtitles(video_id, subtitles)
  158. return {
  159. 'id': video_id,
  160. 'title': metadata['titel'],
  161. 'description': metadata['info'],
  162. 'thumbnail': metadata.get('images', [{'url': None}])[-1]['url'],
  163. 'upload_date': unified_strdate(metadata.get('gidsdatum')),
  164. 'duration': parse_duration(metadata.get('tijdsduur')),
  165. 'formats': formats,
  166. 'subtitles': subtitles,
  167. }
  168. class NPOLiveIE(NPOBaseIE):
  169. IE_NAME = 'npo.nl:live'
  170. _VALID_URL = r'https?://(?:www\.)?npo\.nl/live/(?P<id>.+)'
  171. _TEST = {
  172. 'url': 'http://www.npo.nl/live/npo-1',
  173. 'info_dict': {
  174. 'id': 'LI_NEDERLAND1_136692',
  175. 'display_id': 'npo-1',
  176. 'ext': 'mp4',
  177. 'title': 're:^Nederland 1 [0-9]{4}-[0-9]{2}-[0-9]{2} [0-9]{2}:[0-9]{2}$',
  178. 'description': 'Livestream',
  179. 'is_live': True,
  180. },
  181. 'params': {
  182. 'skip_download': True,
  183. }
  184. }
  185. def _real_extract(self, url):
  186. display_id = self._match_id(url)
  187. webpage = self._download_webpage(url, display_id)
  188. live_id = self._search_regex(
  189. r'data-prid="([^"]+)"', webpage, 'live id')
  190. metadata = self._download_json(
  191. 'http://e.omroep.nl/metadata/%s' % live_id,
  192. display_id, transform_source=strip_jsonp)
  193. token = self._get_token(display_id)
  194. formats = []
  195. streams = metadata.get('streams')
  196. if streams:
  197. for stream in streams:
  198. stream_type = stream.get('type').lower()
  199. if stream_type == 'ss':
  200. continue
  201. stream_info = self._download_json(
  202. 'http://ida.omroep.nl/aapi/?stream=%s&token=%s&type=jsonp'
  203. % (stream.get('url'), token),
  204. display_id, 'Downloading %s JSON' % stream_type)
  205. if stream_info.get('error_code', 0) or stream_info.get('errorcode', 0):
  206. continue
  207. stream_url = self._download_json(
  208. stream_info['stream'], display_id,
  209. 'Downloading %s URL' % stream_type,
  210. transform_source=strip_jsonp)
  211. if stream_type == 'hds':
  212. f4m_formats = self._extract_f4m_formats(stream_url, display_id)
  213. # f4m downloader downloads only piece of live stream
  214. for f4m_format in f4m_formats:
  215. f4m_format['preference'] = -1
  216. formats.extend(f4m_formats)
  217. elif stream_type == 'hls':
  218. formats.extend(self._extract_m3u8_formats(stream_url, display_id, 'mp4'))
  219. else:
  220. formats.append({
  221. 'url': stream_url,
  222. })
  223. self._sort_formats(formats)
  224. return {
  225. 'id': live_id,
  226. 'display_id': display_id,
  227. 'title': self._live_title(metadata['titel']),
  228. 'description': metadata['info'],
  229. 'thumbnail': metadata.get('images', [{'url': None}])[-1]['url'],
  230. 'formats': formats,
  231. 'is_live': True,
  232. }
  233. class NPORadioIE(InfoExtractor):
  234. IE_NAME = 'npo.nl:radio'
  235. _VALID_URL = r'https?://(?:www\.)?npo\.nl/radio/(?P<id>[^/]+)/?$'
  236. _TEST = {
  237. 'url': 'http://www.npo.nl/radio/radio-1',
  238. 'info_dict': {
  239. 'id': 'radio-1',
  240. 'ext': 'mp3',
  241. 'title': 're:^NPO Radio 1 [0-9]{4}-[0-9]{2}-[0-9]{2} [0-9]{2}:[0-9]{2}$',
  242. 'is_live': True,
  243. },
  244. 'params': {
  245. 'skip_download': True,
  246. }
  247. }
  248. @staticmethod
  249. def _html_get_attribute_regex(attribute):
  250. return r'{0}\s*=\s*\'([^\']+)\''.format(attribute)
  251. def _real_extract(self, url):
  252. video_id = self._match_id(url)
  253. webpage = self._download_webpage(url, video_id)
  254. title = self._html_search_regex(
  255. self._html_get_attribute_regex('data-channel'), webpage, 'title')
  256. stream = self._parse_json(
  257. self._html_search_regex(self._html_get_attribute_regex('data-streams'), webpage, 'data-streams'),
  258. video_id)
  259. codec = stream.get('codec')
  260. return {
  261. 'id': video_id,
  262. 'url': stream['url'],
  263. 'title': self._live_title(title),
  264. 'acodec': codec,
  265. 'ext': codec,
  266. 'is_live': True,
  267. }
  268. class NPORadioFragmentIE(InfoExtractor):
  269. IE_NAME = 'npo.nl:radio:fragment'
  270. _VALID_URL = r'https?://(?:www\.)?npo\.nl/radio/[^/]+/fragment/(?P<id>\d+)'
  271. _TEST = {
  272. 'url': 'http://www.npo.nl/radio/radio-5/fragment/174356',
  273. 'md5': 'dd8cc470dad764d0fdc70a9a1e2d18c2',
  274. 'info_dict': {
  275. 'id': '174356',
  276. 'ext': 'mp3',
  277. 'title': 'Jubileumconcert Willeke Alberti',
  278. },
  279. }
  280. def _real_extract(self, url):
  281. audio_id = self._match_id(url)
  282. webpage = self._download_webpage(url, audio_id)
  283. title = self._html_search_regex(
  284. r'href="/radio/[^/]+/fragment/%s" title="([^"]+)"' % audio_id,
  285. webpage, 'title')
  286. audio_url = self._search_regex(
  287. r"data-streams='([^']+)'", webpage, 'audio url')
  288. return {
  289. 'id': audio_id,
  290. 'url': audio_url,
  291. 'title': title,
  292. }
  293. class TegenlichtVproIE(NPOIE):
  294. IE_NAME = 'tegenlicht.vpro.nl'
  295. _VALID_URL = r'https?://tegenlicht\.vpro\.nl/afleveringen/.*?'
  296. _TESTS = [
  297. {
  298. 'url': 'http://tegenlicht.vpro.nl/afleveringen/2012-2013/de-toekomst-komt-uit-afrika.html',
  299. 'md5': 'f8065e4e5a7824068ed3c7e783178f2c',
  300. 'info_dict': {
  301. 'id': 'VPWON_1169289',
  302. 'ext': 'm4v',
  303. 'title': 'Tegenlicht',
  304. 'description': 'md5:d6476bceb17a8c103c76c3b708f05dd1',
  305. 'upload_date': '20130225',
  306. },
  307. },
  308. ]
  309. def _real_extract(self, url):
  310. name = url_basename(url)
  311. webpage = self._download_webpage(url, name)
  312. urn = self._html_search_meta('mediaurn', webpage)
  313. info_page = self._download_json(
  314. 'http://rs.vpro.nl/v2/api/media/%s.json' % urn, name)
  315. return self._get_info(info_page['mid'])