[extractor/common] Use float for scaled tbr
[youtube-dl] / youtube_dl / extractor / common.py
1 # coding: utf-8
2 from __future__ import unicode_literals
3
4 import base64
5 import datetime
6 import hashlib
7 import json
8 import netrc
9 import os
10 import random
11 import re
12 import socket
13 import sys
14 import time
15 import math
16
17 from ..compat import (
18     compat_cookiejar,
19     compat_cookies,
20     compat_etree_fromstring,
21     compat_getpass,
22     compat_http_client,
23     compat_os_name,
24     compat_str,
25     compat_urllib_error,
26     compat_urllib_parse_unquote,
27     compat_urllib_parse_urlencode,
28     compat_urllib_request,
29     compat_urlparse,
30 )
31 from ..downloader.f4m import remove_encrypted_media
32 from ..utils import (
33     NO_DEFAULT,
34     age_restricted,
35     base_url,
36     bug_reports_message,
37     clean_html,
38     compiled_regex_type,
39     determine_ext,
40     determine_protocol,
41     error_to_compat_str,
42     ExtractorError,
43     extract_attributes,
44     fix_xml_ampersands,
45     float_or_none,
46     GeoRestrictedError,
47     GeoUtils,
48     int_or_none,
49     js_to_json,
50     mimetype2ext,
51     orderedSet,
52     parse_codecs,
53     parse_duration,
54     parse_iso8601,
55     parse_m3u8_attributes,
56     RegexNotFoundError,
57     sanitized_Request,
58     sanitize_filename,
59     unescapeHTML,
60     unified_strdate,
61     unified_timestamp,
62     update_Request,
63     update_url_query,
64     urljoin,
65     url_basename,
66     xpath_element,
67     xpath_text,
68     xpath_with_ns,
69 )
70
71
72 class InfoExtractor(object):
73     """Information Extractor class.
74
75     Information extractors are the classes that, given a URL, extract
76     information about the video (or videos) the URL refers to. This
77     information includes the real video URL, the video title, author and
78     others. The information is stored in a dictionary which is then
79     passed to the YoutubeDL. The YoutubeDL processes this
80     information possibly downloading the video to the file system, among
81     other possible outcomes.
82
83     The type field determines the type of the result.
84     By far the most common value (and the default if _type is missing) is
85     "video", which indicates a single video.
86
87     For a video, the dictionaries must include the following fields:
88
89     id:             Video identifier.
90     title:          Video title, unescaped.
91
92     Additionally, it must contain either a formats entry or a url one:
93
94     formats:        A list of dictionaries for each format available, ordered
95                     from worst to best quality.
96
97                     Potential fields:
98                     * url        Mandatory. The URL of the video file
99                     * manifest_url
100                                  The URL of the manifest file in case of
101                                  fragmented media (DASH, hls, hds)
102                     * ext        Will be calculated from URL if missing
103                     * format     A human-readable description of the format
104                                  ("mp4 container with h264/opus").
105                                  Calculated from the format_id, width, height.
106                                  and format_note fields if missing.
107                     * format_id  A short description of the format
108                                  ("mp4_h264_opus" or "19").
109                                 Technically optional, but strongly recommended.
110                     * format_note Additional info about the format
111                                  ("3D" or "DASH video")
112                     * width      Width of the video, if known
113                     * height     Height of the video, if known
114                     * resolution Textual description of width and height
115                     * tbr        Average bitrate of audio and video in KBit/s
116                     * abr        Average audio bitrate in KBit/s
117                     * acodec     Name of the audio codec in use
118                     * asr        Audio sampling rate in Hertz
119                     * vbr        Average video bitrate in KBit/s
120                     * fps        Frame rate
121                     * vcodec     Name of the video codec in use
122                     * container  Name of the container format
123                     * filesize   The number of bytes, if known in advance
124                     * filesize_approx  An estimate for the number of bytes
125                     * player_url SWF Player URL (used for rtmpdump).
126                     * protocol   The protocol that will be used for the actual
127                                  download, lower-case.
128                                  "http", "https", "rtsp", "rtmp", "rtmpe",
129                                  "m3u8", "m3u8_native" or "http_dash_segments".
130                     * fragment_base_url
131                                  Base URL for fragments. Each fragment's path
132                                  value (if present) will be relative to
133                                  this URL.
134                     * fragments  A list of fragments of a fragmented media.
135                                  Each fragment entry must contain either an url
136                                  or a path. If an url is present it should be
137                                  considered by a client. Otherwise both path and
138                                  fragment_base_url must be present. Here is
139                                  the list of all potential fields:
140                                  * "url" - fragment's URL
141                                  * "path" - fragment's path relative to
142                                             fragment_base_url
143                                  * "duration" (optional, int or float)
144                                  * "filesize" (optional, int)
145                     * preference Order number of this format. If this field is
146                                  present and not None, the formats get sorted
147                                  by this field, regardless of all other values.
148                                  -1 for default (order by other properties),
149                                  -2 or smaller for less than default.
150                                  < -1000 to hide the format (if there is
151                                     another one which is strictly better)
152                     * language   Language code, e.g. "de" or "en-US".
153                     * language_preference  Is this in the language mentioned in
154                                  the URL?
155                                  10 if it's what the URL is about,
156                                  -1 for default (don't know),
157                                  -10 otherwise, other values reserved for now.
158                     * quality    Order number of the video quality of this
159                                  format, irrespective of the file format.
160                                  -1 for default (order by other properties),
161                                  -2 or smaller for less than default.
162                     * source_preference  Order number for this video source
163                                   (quality takes higher priority)
164                                  -1 for default (order by other properties),
165                                  -2 or smaller for less than default.
166                     * http_headers  A dictionary of additional HTTP headers
167                                  to add to the request.
168                     * stretched_ratio  If given and not 1, indicates that the
169                                  video's pixels are not square.
170                                  width : height ratio as float.
171                     * no_resume  The server does not support resuming the
172                                  (HTTP or RTMP) download. Boolean.
173
174     url:            Final video URL.
175     ext:            Video filename extension.
176     format:         The video format, defaults to ext (used for --get-format)
177     player_url:     SWF Player URL (used for rtmpdump).
178
179     The following fields are optional:
180
181     alt_title:      A secondary title of the video.
182     display_id      An alternative identifier for the video, not necessarily
183                     unique, but available before title. Typically, id is
184                     something like "4234987", title "Dancing naked mole rats",
185                     and display_id "dancing-naked-mole-rats"
186     thumbnails:     A list of dictionaries, with the following entries:
187                         * "id" (optional, string) - Thumbnail format ID
188                         * "url"
189                         * "preference" (optional, int) - quality of the image
190                         * "width" (optional, int)
191                         * "height" (optional, int)
192                         * "resolution" (optional, string "{width}x{height"},
193                                         deprecated)
194                         * "filesize" (optional, int)
195     thumbnail:      Full URL to a video thumbnail image.
196     description:    Full video description.
197     uploader:       Full name of the video uploader.
198     license:        License name the video is licensed under.
199     creator:        The creator of the video.
200     release_date:   The date (YYYYMMDD) when the video was released.
201     timestamp:      UNIX timestamp of the moment the video became available.
202     upload_date:    Video upload date (YYYYMMDD).
203                     If not explicitly set, calculated from timestamp.
204     uploader_id:    Nickname or id of the video uploader.
205     uploader_url:   Full URL to a personal webpage of the video uploader.
206     location:       Physical location where the video was filmed.
207     subtitles:      The available subtitles as a dictionary in the format
208                     {tag: subformats}. "tag" is usually a language code, and
209                     "subformats" is a list sorted from lower to higher
210                     preference, each element is a dictionary with the "ext"
211                     entry and one of:
212                         * "data": The subtitles file contents
213                         * "url": A URL pointing to the subtitles file
214                     "ext" will be calculated from URL if missing
215     automatic_captions: Like 'subtitles', used by the YoutubeIE for
216                     automatically generated captions
217     duration:       Length of the video in seconds, as an integer or float.
218     view_count:     How many users have watched the video on the platform.
219     like_count:     Number of positive ratings of the video
220     dislike_count:  Number of negative ratings of the video
221     repost_count:   Number of reposts of the video
222     average_rating: Average rating give by users, the scale used depends on the webpage
223     comment_count:  Number of comments on the video
224     comments:       A list of comments, each with one or more of the following
225                     properties (all but one of text or html optional):
226                         * "author" - human-readable name of the comment author
227                         * "author_id" - user ID of the comment author
228                         * "id" - Comment ID
229                         * "html" - Comment as HTML
230                         * "text" - Plain text of the comment
231                         * "timestamp" - UNIX timestamp of comment
232                         * "parent" - ID of the comment this one is replying to.
233                                      Set to "root" to indicate that this is a
234                                      comment to the original video.
235     age_limit:      Age restriction for the video, as an integer (years)
236     webpage_url:    The URL to the video webpage, if given to youtube-dl it
237                     should allow to get the same result again. (It will be set
238                     by YoutubeDL if it's missing)
239     categories:     A list of categories that the video falls in, for example
240                     ["Sports", "Berlin"]
241     tags:           A list of tags assigned to the video, e.g. ["sweden", "pop music"]
242     is_live:        True, False, or None (=unknown). Whether this video is a
243                     live stream that goes on instead of a fixed-length video.
244     start_time:     Time in seconds where the reproduction should start, as
245                     specified in the URL.
246     end_time:       Time in seconds where the reproduction should end, as
247                     specified in the URL.
248
249     The following fields should only be used when the video belongs to some logical
250     chapter or section:
251
252     chapter:        Name or title of the chapter the video belongs to.
253     chapter_number: Number of the chapter the video belongs to, as an integer.
254     chapter_id:     Id of the chapter the video belongs to, as a unicode string.
255
256     The following fields should only be used when the video is an episode of some
257     series, programme or podcast:
258
259     series:         Title of the series or programme the video episode belongs to.
260     season:         Title of the season the video episode belongs to.
261     season_number:  Number of the season the video episode belongs to, as an integer.
262     season_id:      Id of the season the video episode belongs to, as a unicode string.
263     episode:        Title of the video episode. Unlike mandatory video title field,
264                     this field should denote the exact title of the video episode
265                     without any kind of decoration.
266     episode_number: Number of the video episode within a season, as an integer.
267     episode_id:     Id of the video episode, as a unicode string.
268
269     The following fields should only be used when the media is a track or a part of
270     a music album:
271
272     track:          Title of the track.
273     track_number:   Number of the track within an album or a disc, as an integer.
274     track_id:       Id of the track (useful in case of custom indexing, e.g. 6.iii),
275                     as a unicode string.
276     artist:         Artist(s) of the track.
277     genre:          Genre(s) of the track.
278     album:          Title of the album the track belongs to.
279     album_type:     Type of the album (e.g. "Demo", "Full-length", "Split", "Compilation", etc).
280     album_artist:   List of all artists appeared on the album (e.g.
281                     "Ash Borer / Fell Voices" or "Various Artists", useful for splits
282                     and compilations).
283     disc_number:    Number of the disc or other physical medium the track belongs to,
284                     as an integer.
285     release_year:   Year (YYYY) when the album was released.
286
287     Unless mentioned otherwise, the fields should be Unicode strings.
288
289     Unless mentioned otherwise, None is equivalent to absence of information.
290
291
292     _type "playlist" indicates multiple videos.
293     There must be a key "entries", which is a list, an iterable, or a PagedList
294     object, each element of which is a valid dictionary by this specification.
295
296     Additionally, playlists can have "title", "description" and "id" attributes
297     with the same semantics as videos (see above).
298
299
300     _type "multi_video" indicates that there are multiple videos that
301     form a single show, for examples multiple acts of an opera or TV episode.
302     It must have an entries key like a playlist and contain all the keys
303     required for a video at the same time.
304
305
306     _type "url" indicates that the video must be extracted from another
307     location, possibly by a different extractor. Its only required key is:
308     "url" - the next URL to extract.
309     The key "ie_key" can be set to the class name (minus the trailing "IE",
310     e.g. "Youtube") if the extractor class is known in advance.
311     Additionally, the dictionary may have any properties of the resolved entity
312     known in advance, for example "title" if the title of the referred video is
313     known ahead of time.
314
315
316     _type "url_transparent" entities have the same specification as "url", but
317     indicate that the given additional information is more precise than the one
318     associated with the resolved URL.
319     This is useful when a site employs a video service that hosts the video and
320     its technical metadata, but that video service does not embed a useful
321     title, description etc.
322
323
324     Subclasses of this one should re-define the _real_initialize() and
325     _real_extract() methods and define a _VALID_URL regexp.
326     Probably, they should also be added to the list of extractors.
327
328     _GEO_BYPASS attribute may be set to False in order to disable
329     geo restriction bypass mechanisms for a particular extractor.
330     Though it won't disable explicit geo restriction bypass based on
331     country code provided with geo_bypass_country. (experimental)
332
333     _GEO_COUNTRIES attribute may contain a list of presumably geo unrestricted
334     countries for this extractor. One of these countries will be used by
335     geo restriction bypass mechanism right away in order to bypass
336     geo restriction, of course, if the mechanism is not disabled. (experimental)
337
338     NB: both these geo attributes are experimental and may change in future
339     or be completely removed.
340
341     Finally, the _WORKING attribute should be set to False for broken IEs
342     in order to warn the users and skip the tests.
343     """
344
345     _ready = False
346     _downloader = None
347     _x_forwarded_for_ip = None
348     _GEO_BYPASS = True
349     _GEO_COUNTRIES = None
350     _WORKING = True
351
352     def __init__(self, downloader=None):
353         """Constructor. Receives an optional downloader."""
354         self._ready = False
355         self._x_forwarded_for_ip = None
356         self.set_downloader(downloader)
357
358     @classmethod
359     def suitable(cls, url):
360         """Receives a URL and returns True if suitable for this IE."""
361
362         # This does not use has/getattr intentionally - we want to know whether
363         # we have cached the regexp for *this* class, whereas getattr would also
364         # match the superclass
365         if '_VALID_URL_RE' not in cls.__dict__:
366             cls._VALID_URL_RE = re.compile(cls._VALID_URL)
367         return cls._VALID_URL_RE.match(url) is not None
368
369     @classmethod
370     def _match_id(cls, url):
371         if '_VALID_URL_RE' not in cls.__dict__:
372             cls._VALID_URL_RE = re.compile(cls._VALID_URL)
373         m = cls._VALID_URL_RE.match(url)
374         assert m
375         return m.group('id')
376
377     @classmethod
378     def working(cls):
379         """Getter method for _WORKING."""
380         return cls._WORKING
381
382     def initialize(self):
383         """Initializes an instance (authentication, etc)."""
384         self._initialize_geo_bypass(self._GEO_COUNTRIES)
385         if not self._ready:
386             self._real_initialize()
387             self._ready = True
388
389     def _initialize_geo_bypass(self, countries):
390         """
391         Initialize geo restriction bypass mechanism.
392
393         This method is used to initialize geo bypass mechanism based on faking
394         X-Forwarded-For HTTP header. A random country from provided country list
395         is selected and a random IP belonging to this country is generated. This
396         IP will be passed as X-Forwarded-For HTTP header in all subsequent
397         HTTP requests.
398
399         This method will be used for initial geo bypass mechanism initialization
400         during the instance initialization with _GEO_COUNTRIES.
401
402         You may also manually call it from extractor's code if geo countries
403         information is not available beforehand (e.g. obtained during
404         extraction) or due to some another reason.
405         """
406         if not self._x_forwarded_for_ip:
407             country_code = self._downloader.params.get('geo_bypass_country', None)
408             # If there is no explicit country for geo bypass specified and
409             # the extractor is known to be geo restricted let's fake IP
410             # as X-Forwarded-For right away.
411             if (not country_code and
412                     self._GEO_BYPASS and
413                     self._downloader.params.get('geo_bypass', True) and
414                     countries):
415                 country_code = random.choice(countries)
416             if country_code:
417                 self._x_forwarded_for_ip = GeoUtils.random_ipv4(country_code)
418                 if self._downloader.params.get('verbose', False):
419                     self._downloader.to_stdout(
420                         '[debug] Using fake IP %s (%s) as X-Forwarded-For.'
421                         % (self._x_forwarded_for_ip, country_code.upper()))
422
423     def extract(self, url):
424         """Extracts URL information and returns it in list of dicts."""
425         try:
426             for _ in range(2):
427                 try:
428                     self.initialize()
429                     ie_result = self._real_extract(url)
430                     if self._x_forwarded_for_ip:
431                         ie_result['__x_forwarded_for_ip'] = self._x_forwarded_for_ip
432                     return ie_result
433                 except GeoRestrictedError as e:
434                     if self.__maybe_fake_ip_and_retry(e.countries):
435                         continue
436                     raise
437         except ExtractorError:
438             raise
439         except compat_http_client.IncompleteRead as e:
440             raise ExtractorError('A network error has occurred.', cause=e, expected=True)
441         except (KeyError, StopIteration) as e:
442             raise ExtractorError('An extractor error has occurred.', cause=e)
443
444     def __maybe_fake_ip_and_retry(self, countries):
445         if (not self._downloader.params.get('geo_bypass_country', None) and
446                 self._GEO_BYPASS and
447                 self._downloader.params.get('geo_bypass', True) and
448                 not self._x_forwarded_for_ip and
449                 countries):
450             country_code = random.choice(countries)
451             self._x_forwarded_for_ip = GeoUtils.random_ipv4(country_code)
452             if self._x_forwarded_for_ip:
453                 self.report_warning(
454                     'Video is geo restricted. Retrying extraction with fake IP %s (%s) as X-Forwarded-For.'
455                     % (self._x_forwarded_for_ip, country_code.upper()))
456                 return True
457         return False
458
459     def set_downloader(self, downloader):
460         """Sets the downloader for this IE."""
461         self._downloader = downloader
462
463     def _real_initialize(self):
464         """Real initialization process. Redefine in subclasses."""
465         pass
466
467     def _real_extract(self, url):
468         """Real extraction process. Redefine in subclasses."""
469         pass
470
471     @classmethod
472     def ie_key(cls):
473         """A string for getting the InfoExtractor with get_info_extractor"""
474         return compat_str(cls.__name__[:-2])
475
476     @property
477     def IE_NAME(self):
478         return compat_str(type(self).__name__[:-2])
479
480     def _request_webpage(self, url_or_request, video_id, note=None, errnote=None, fatal=True, data=None, headers={}, query={}):
481         """ Returns the response handle """
482         if note is None:
483             self.report_download_webpage(video_id)
484         elif note is not False:
485             if video_id is None:
486                 self.to_screen('%s' % (note,))
487             else:
488                 self.to_screen('%s: %s' % (video_id, note))
489         if isinstance(url_or_request, compat_urllib_request.Request):
490             url_or_request = update_Request(
491                 url_or_request, data=data, headers=headers, query=query)
492         else:
493             if query:
494                 url_or_request = update_url_query(url_or_request, query)
495             if data is not None or headers:
496                 url_or_request = sanitized_Request(url_or_request, data, headers)
497         try:
498             return self._downloader.urlopen(url_or_request)
499         except (compat_urllib_error.URLError, compat_http_client.HTTPException, socket.error) as err:
500             if errnote is False:
501                 return False
502             if errnote is None:
503                 errnote = 'Unable to download webpage'
504
505             errmsg = '%s: %s' % (errnote, error_to_compat_str(err))
506             if fatal:
507                 raise ExtractorError(errmsg, sys.exc_info()[2], cause=err)
508             else:
509                 self._downloader.report_warning(errmsg)
510                 return False
511
512     def _download_webpage_handle(self, url_or_request, video_id, note=None, errnote=None, fatal=True, encoding=None, data=None, headers={}, query={}):
513         """ Returns a tuple (page content as string, URL handle) """
514         # Strip hashes from the URL (#1038)
515         if isinstance(url_or_request, (compat_str, str)):
516             url_or_request = url_or_request.partition('#')[0]
517
518         # Some sites check X-Forwarded-For HTTP header in order to figure out
519         # the origin of the client behind proxy. This allows bypassing geo
520         # restriction by faking this header's value to IP that belongs to some
521         # geo unrestricted country. We will do so once we encounter any
522         # geo restriction error.
523         if self._x_forwarded_for_ip:
524             if 'X-Forwarded-For' not in headers:
525                 headers['X-Forwarded-For'] = self._x_forwarded_for_ip
526
527         urlh = self._request_webpage(url_or_request, video_id, note, errnote, fatal, data=data, headers=headers, query=query)
528         if urlh is False:
529             assert not fatal
530             return False
531         content = self._webpage_read_content(urlh, url_or_request, video_id, note, errnote, fatal, encoding=encoding)
532         return (content, urlh)
533
534     @staticmethod
535     def _guess_encoding_from_content(content_type, webpage_bytes):
536         m = re.match(r'[a-zA-Z0-9_.-]+/[a-zA-Z0-9_.-]+\s*;\s*charset=(.+)', content_type)
537         if m:
538             encoding = m.group(1)
539         else:
540             m = re.search(br'<meta[^>]+charset=[\'"]?([^\'")]+)[ /\'">]',
541                           webpage_bytes[:1024])
542             if m:
543                 encoding = m.group(1).decode('ascii')
544             elif webpage_bytes.startswith(b'\xff\xfe'):
545                 encoding = 'utf-16'
546             else:
547                 encoding = 'utf-8'
548
549         return encoding
550
551     def __check_blocked(self, content):
552         first_block = content[:512]
553         if ('<title>Access to this site is blocked</title>' in content and
554                 'Websense' in first_block):
555             msg = 'Access to this webpage has been blocked by Websense filtering software in your network.'
556             blocked_iframe = self._html_search_regex(
557                 r'<iframe src="([^"]+)"', content,
558                 'Websense information URL', default=None)
559             if blocked_iframe:
560                 msg += ' Visit %s for more details' % blocked_iframe
561             raise ExtractorError(msg, expected=True)
562         if '<title>The URL you requested has been blocked</title>' in first_block:
563             msg = (
564                 'Access to this webpage has been blocked by Indian censorship. '
565                 'Use a VPN or proxy server (with --proxy) to route around it.')
566             block_msg = self._html_search_regex(
567                 r'</h1><p>(.*?)</p>',
568                 content, 'block message', default=None)
569             if block_msg:
570                 msg += ' (Message: "%s")' % block_msg.replace('\n', ' ')
571             raise ExtractorError(msg, expected=True)
572         if ('<title>TTK :: Доступ к ресурсу ограничен</title>' in content and
573                 'blocklist.rkn.gov.ru' in content):
574             raise ExtractorError(
575                 'Access to this webpage has been blocked by decision of the Russian government. '
576                 'Visit http://blocklist.rkn.gov.ru/ for a block reason.',
577                 expected=True)
578
579     def _webpage_read_content(self, urlh, url_or_request, video_id, note=None, errnote=None, fatal=True, prefix=None, encoding=None):
580         content_type = urlh.headers.get('Content-Type', '')
581         webpage_bytes = urlh.read()
582         if prefix is not None:
583             webpage_bytes = prefix + webpage_bytes
584         if not encoding:
585             encoding = self._guess_encoding_from_content(content_type, webpage_bytes)
586         if self._downloader.params.get('dump_intermediate_pages', False):
587             try:
588                 url = url_or_request.get_full_url()
589             except AttributeError:
590                 url = url_or_request
591             self.to_screen('Dumping request to ' + url)
592             dump = base64.b64encode(webpage_bytes).decode('ascii')
593             self._downloader.to_screen(dump)
594         if self._downloader.params.get('write_pages', False):
595             try:
596                 url = url_or_request.get_full_url()
597             except AttributeError:
598                 url = url_or_request
599             basen = '%s_%s' % (video_id, url)
600             if len(basen) > 240:
601                 h = '___' + hashlib.md5(basen.encode('utf-8')).hexdigest()
602                 basen = basen[:240 - len(h)] + h
603             raw_filename = basen + '.dump'
604             filename = sanitize_filename(raw_filename, restricted=True)
605             self.to_screen('Saving request to ' + filename)
606             # Working around MAX_PATH limitation on Windows (see
607             # http://msdn.microsoft.com/en-us/library/windows/desktop/aa365247(v=vs.85).aspx)
608             if compat_os_name == 'nt':
609                 absfilepath = os.path.abspath(filename)
610                 if len(absfilepath) > 259:
611                     filename = '\\\\?\\' + absfilepath
612             with open(filename, 'wb') as outf:
613                 outf.write(webpage_bytes)
614
615         try:
616             content = webpage_bytes.decode(encoding, 'replace')
617         except LookupError:
618             content = webpage_bytes.decode('utf-8', 'replace')
619
620         self.__check_blocked(content)
621
622         return content
623
624     def _download_webpage(self, url_or_request, video_id, note=None, errnote=None, fatal=True, tries=1, timeout=5, encoding=None, data=None, headers={}, query={}):
625         """ Returns the data of the page as a string """
626         success = False
627         try_count = 0
628         while success is False:
629             try:
630                 res = self._download_webpage_handle(url_or_request, video_id, note, errnote, fatal, encoding=encoding, data=data, headers=headers, query=query)
631                 success = True
632             except compat_http_client.IncompleteRead as e:
633                 try_count += 1
634                 if try_count >= tries:
635                     raise e
636                 self._sleep(timeout, video_id)
637         if res is False:
638             return res
639         else:
640             content, _ = res
641             return content
642
643     def _download_xml(self, url_or_request, video_id,
644                       note='Downloading XML', errnote='Unable to download XML',
645                       transform_source=None, fatal=True, encoding=None, data=None, headers={}, query={}):
646         """Return the xml as an xml.etree.ElementTree.Element"""
647         xml_string = self._download_webpage(
648             url_or_request, video_id, note, errnote, fatal=fatal, encoding=encoding, data=data, headers=headers, query=query)
649         if xml_string is False:
650             return xml_string
651         if transform_source:
652             xml_string = transform_source(xml_string)
653         return compat_etree_fromstring(xml_string.encode('utf-8'))
654
655     def _download_json(self, url_or_request, video_id,
656                        note='Downloading JSON metadata',
657                        errnote='Unable to download JSON metadata',
658                        transform_source=None,
659                        fatal=True, encoding=None, data=None, headers={}, query={}):
660         json_string = self._download_webpage(
661             url_or_request, video_id, note, errnote, fatal=fatal,
662             encoding=encoding, data=data, headers=headers, query=query)
663         if (not fatal) and json_string is False:
664             return None
665         return self._parse_json(
666             json_string, video_id, transform_source=transform_source, fatal=fatal)
667
668     def _parse_json(self, json_string, video_id, transform_source=None, fatal=True):
669         if transform_source:
670             json_string = transform_source(json_string)
671         try:
672             return json.loads(json_string)
673         except ValueError as ve:
674             errmsg = '%s: Failed to parse JSON ' % video_id
675             if fatal:
676                 raise ExtractorError(errmsg, cause=ve)
677             else:
678                 self.report_warning(errmsg + str(ve))
679
680     def report_warning(self, msg, video_id=None):
681         idstr = '' if video_id is None else '%s: ' % video_id
682         self._downloader.report_warning(
683             '[%s] %s%s' % (self.IE_NAME, idstr, msg))
684
685     def to_screen(self, msg):
686         """Print msg to screen, prefixing it with '[ie_name]'"""
687         self._downloader.to_screen('[%s] %s' % (self.IE_NAME, msg))
688
689     def report_extraction(self, id_or_name):
690         """Report information extraction."""
691         self.to_screen('%s: Extracting information' % id_or_name)
692
693     def report_download_webpage(self, video_id):
694         """Report webpage download."""
695         self.to_screen('%s: Downloading webpage' % video_id)
696
697     def report_age_confirmation(self):
698         """Report attempt to confirm age."""
699         self.to_screen('Confirming age')
700
701     def report_login(self):
702         """Report attempt to log in."""
703         self.to_screen('Logging in')
704
705     @staticmethod
706     def raise_login_required(msg='This video is only available for registered users'):
707         raise ExtractorError(
708             '%s. Use --username and --password or --netrc to provide account credentials.' % msg,
709             expected=True)
710
711     @staticmethod
712     def raise_geo_restricted(msg='This video is not available from your location due to geo restriction', countries=None):
713         raise GeoRestrictedError(msg, countries=countries)
714
715     # Methods for following #608
716     @staticmethod
717     def url_result(url, ie=None, video_id=None, video_title=None):
718         """Returns a URL that points to a page that should be processed"""
719         # TODO: ie should be the class used for getting the info
720         video_info = {'_type': 'url',
721                       'url': url,
722                       'ie_key': ie}
723         if video_id is not None:
724             video_info['id'] = video_id
725         if video_title is not None:
726             video_info['title'] = video_title
727         return video_info
728
729     def playlist_from_matches(self, matches, video_id, video_title, getter=None, ie=None):
730         urlrs = orderedSet(
731             self.url_result(self._proto_relative_url(getter(m) if getter else m), ie)
732             for m in matches)
733         return self.playlist_result(
734             urlrs, playlist_id=video_id, playlist_title=video_title)
735
736     @staticmethod
737     def playlist_result(entries, playlist_id=None, playlist_title=None, playlist_description=None):
738         """Returns a playlist"""
739         video_info = {'_type': 'playlist',
740                       'entries': entries}
741         if playlist_id:
742             video_info['id'] = playlist_id
743         if playlist_title:
744             video_info['title'] = playlist_title
745         if playlist_description:
746             video_info['description'] = playlist_description
747         return video_info
748
749     def _search_regex(self, pattern, string, name, default=NO_DEFAULT, fatal=True, flags=0, group=None):
750         """
751         Perform a regex search on the given string, using a single or a list of
752         patterns returning the first matching group.
753         In case of failure return a default value or raise a WARNING or a
754         RegexNotFoundError, depending on fatal, specifying the field name.
755         """
756         if isinstance(pattern, (str, compat_str, compiled_regex_type)):
757             mobj = re.search(pattern, string, flags)
758         else:
759             for p in pattern:
760                 mobj = re.search(p, string, flags)
761                 if mobj:
762                     break
763
764         if not self._downloader.params.get('no_color') and compat_os_name != 'nt' and sys.stderr.isatty():
765             _name = '\033[0;34m%s\033[0m' % name
766         else:
767             _name = name
768
769         if mobj:
770             if group is None:
771                 # return the first matching group
772                 return next(g for g in mobj.groups() if g is not None)
773             else:
774                 return mobj.group(group)
775         elif default is not NO_DEFAULT:
776             return default
777         elif fatal:
778             raise RegexNotFoundError('Unable to extract %s' % _name)
779         else:
780             self._downloader.report_warning('unable to extract %s' % _name + bug_reports_message())
781             return None
782
783     def _html_search_regex(self, pattern, string, name, default=NO_DEFAULT, fatal=True, flags=0, group=None):
784         """
785         Like _search_regex, but strips HTML tags and unescapes entities.
786         """
787         res = self._search_regex(pattern, string, name, default, fatal, flags, group)
788         if res:
789             return clean_html(res).strip()
790         else:
791             return res
792
793     def _get_netrc_login_info(self, netrc_machine=None):
794         username = None
795         password = None
796         netrc_machine = netrc_machine or self._NETRC_MACHINE
797
798         if self._downloader.params.get('usenetrc', False):
799             try:
800                 info = netrc.netrc().authenticators(netrc_machine)
801                 if info is not None:
802                     username = info[0]
803                     password = info[2]
804                 else:
805                     raise netrc.NetrcParseError(
806                         'No authenticators for %s' % netrc_machine)
807             except (IOError, netrc.NetrcParseError) as err:
808                 self._downloader.report_warning(
809                     'parsing .netrc: %s' % error_to_compat_str(err))
810
811         return username, password
812
813     def _get_login_info(self, username_option='username', password_option='password', netrc_machine=None):
814         """
815         Get the login info as (username, password)
816         First look for the manually specified credentials using username_option
817         and password_option as keys in params dictionary. If no such credentials
818         available look in the netrc file using the netrc_machine or _NETRC_MACHINE
819         value.
820         If there's no info available, return (None, None)
821         """
822         if self._downloader is None:
823             return (None, None)
824
825         downloader_params = self._downloader.params
826
827         # Attempt to use provided username and password or .netrc data
828         if downloader_params.get(username_option) is not None:
829             username = downloader_params[username_option]
830             password = downloader_params[password_option]
831         else:
832             username, password = self._get_netrc_login_info(netrc_machine)
833
834         return username, password
835
836     def _get_tfa_info(self, note='two-factor verification code'):
837         """
838         Get the two-factor authentication info
839         TODO - asking the user will be required for sms/phone verify
840         currently just uses the command line option
841         If there's no info available, return None
842         """
843         if self._downloader is None:
844             return None
845         downloader_params = self._downloader.params
846
847         if downloader_params.get('twofactor') is not None:
848             return downloader_params['twofactor']
849
850         return compat_getpass('Type %s and press [Return]: ' % note)
851
852     # Helper functions for extracting OpenGraph info
853     @staticmethod
854     def _og_regexes(prop):
855         content_re = r'content=(?:"([^"]+?)"|\'([^\']+?)\'|\s*([^\s"\'=<>`]+?))'
856         property_re = (r'(?:name|property)=(?:\'og:%(prop)s\'|"og:%(prop)s"|\s*og:%(prop)s\b)'
857                        % {'prop': re.escape(prop)})
858         template = r'<meta[^>]+?%s[^>]+?%s'
859         return [
860             template % (property_re, content_re),
861             template % (content_re, property_re),
862         ]
863
864     @staticmethod
865     def _meta_regex(prop):
866         return r'''(?isx)<meta
867                     (?=[^>]+(?:itemprop|name|property|id|http-equiv)=(["\']?)%s\1)
868                     [^>]+?content=(["\'])(?P<content>.*?)\2''' % re.escape(prop)
869
870     def _og_search_property(self, prop, html, name=None, **kargs):
871         if not isinstance(prop, (list, tuple)):
872             prop = [prop]
873         if name is None:
874             name = 'OpenGraph %s' % prop[0]
875         og_regexes = []
876         for p in prop:
877             og_regexes.extend(self._og_regexes(p))
878         escaped = self._search_regex(og_regexes, html, name, flags=re.DOTALL, **kargs)
879         if escaped is None:
880             return None
881         return unescapeHTML(escaped)
882
883     def _og_search_thumbnail(self, html, **kargs):
884         return self._og_search_property('image', html, 'thumbnail URL', fatal=False, **kargs)
885
886     def _og_search_description(self, html, **kargs):
887         return self._og_search_property('description', html, fatal=False, **kargs)
888
889     def _og_search_title(self, html, **kargs):
890         return self._og_search_property('title', html, **kargs)
891
892     def _og_search_video_url(self, html, name='video url', secure=True, **kargs):
893         regexes = self._og_regexes('video') + self._og_regexes('video:url')
894         if secure:
895             regexes = self._og_regexes('video:secure_url') + regexes
896         return self._html_search_regex(regexes, html, name, **kargs)
897
898     def _og_search_url(self, html, **kargs):
899         return self._og_search_property('url', html, **kargs)
900
901     def _html_search_meta(self, name, html, display_name=None, fatal=False, **kwargs):
902         if not isinstance(name, (list, tuple)):
903             name = [name]
904         if display_name is None:
905             display_name = name[0]
906         return self._html_search_regex(
907             [self._meta_regex(n) for n in name],
908             html, display_name, fatal=fatal, group='content', **kwargs)
909
910     def _dc_search_uploader(self, html):
911         return self._html_search_meta('dc.creator', html, 'uploader')
912
913     def _rta_search(self, html):
914         # See http://www.rtalabel.org/index.php?content=howtofaq#single
915         if re.search(r'(?ix)<meta\s+name="rating"\s+'
916                      r'     content="RTA-5042-1996-1400-1577-RTA"',
917                      html):
918             return 18
919         return 0
920
921     def _media_rating_search(self, html):
922         # See http://www.tjg-designs.com/WP/metadata-code-examples-adding-metadata-to-your-web-pages/
923         rating = self._html_search_meta('rating', html)
924
925         if not rating:
926             return None
927
928         RATING_TABLE = {
929             'safe for kids': 0,
930             'general': 8,
931             '14 years': 14,
932             'mature': 17,
933             'restricted': 19,
934         }
935         return RATING_TABLE.get(rating.lower())
936
937     def _family_friendly_search(self, html):
938         # See http://schema.org/VideoObject
939         family_friendly = self._html_search_meta('isFamilyFriendly', html)
940
941         if not family_friendly:
942             return None
943
944         RATING_TABLE = {
945             '1': 0,
946             'true': 0,
947             '0': 18,
948             'false': 18,
949         }
950         return RATING_TABLE.get(family_friendly.lower())
951
952     def _twitter_search_player(self, html):
953         return self._html_search_meta('twitter:player', html,
954                                       'twitter card player')
955
956     def _search_json_ld(self, html, video_id, expected_type=None, **kwargs):
957         json_ld = self._search_regex(
958             r'(?s)<script[^>]+type=(["\'])application/ld\+json\1[^>]*>(?P<json_ld>.+?)</script>',
959             html, 'JSON-LD', group='json_ld', **kwargs)
960         default = kwargs.get('default', NO_DEFAULT)
961         if not json_ld:
962             return default if default is not NO_DEFAULT else {}
963         # JSON-LD may be malformed and thus `fatal` should be respected.
964         # At the same time `default` may be passed that assumes `fatal=False`
965         # for _search_regex. Let's simulate the same behavior here as well.
966         fatal = kwargs.get('fatal', True) if default == NO_DEFAULT else False
967         return self._json_ld(json_ld, video_id, fatal=fatal, expected_type=expected_type)
968
969     def _json_ld(self, json_ld, video_id, fatal=True, expected_type=None):
970         if isinstance(json_ld, compat_str):
971             json_ld = self._parse_json(json_ld, video_id, fatal=fatal)
972         if not json_ld:
973             return {}
974         info = {}
975         if not isinstance(json_ld, (list, tuple, dict)):
976             return info
977         if isinstance(json_ld, dict):
978             json_ld = [json_ld]
979
980         def extract_video_object(e):
981             assert e['@type'] == 'VideoObject'
982             info.update({
983                 'url': e.get('contentUrl'),
984                 'title': unescapeHTML(e.get('name')),
985                 'description': unescapeHTML(e.get('description')),
986                 'thumbnail': e.get('thumbnailUrl') or e.get('thumbnailURL'),
987                 'duration': parse_duration(e.get('duration')),
988                 'timestamp': unified_timestamp(e.get('uploadDate')),
989                 'filesize': float_or_none(e.get('contentSize')),
990                 'tbr': int_or_none(e.get('bitrate')),
991                 'width': int_or_none(e.get('width')),
992                 'height': int_or_none(e.get('height')),
993             })
994
995         for e in json_ld:
996             if e.get('@context') == 'http://schema.org':
997                 item_type = e.get('@type')
998                 if expected_type is not None and expected_type != item_type:
999                     return info
1000                 if item_type == 'TVEpisode':
1001                     info.update({
1002                         'episode': unescapeHTML(e.get('name')),
1003                         'episode_number': int_or_none(e.get('episodeNumber')),
1004                         'description': unescapeHTML(e.get('description')),
1005                     })
1006                     part_of_season = e.get('partOfSeason')
1007                     if isinstance(part_of_season, dict) and part_of_season.get('@type') == 'TVSeason':
1008                         info['season_number'] = int_or_none(part_of_season.get('seasonNumber'))
1009                     part_of_series = e.get('partOfSeries') or e.get('partOfTVSeries')
1010                     if isinstance(part_of_series, dict) and part_of_series.get('@type') == 'TVSeries':
1011                         info['series'] = unescapeHTML(part_of_series.get('name'))
1012                 elif item_type == 'Article':
1013                     info.update({
1014                         'timestamp': parse_iso8601(e.get('datePublished')),
1015                         'title': unescapeHTML(e.get('headline')),
1016                         'description': unescapeHTML(e.get('articleBody')),
1017                     })
1018                 elif item_type == 'VideoObject':
1019                     extract_video_object(e)
1020                 elif item_type == 'WebPage':
1021                     video = e.get('video')
1022                     if isinstance(video, dict) and video.get('@type') == 'VideoObject':
1023                         extract_video_object(video)
1024                 break
1025         return dict((k, v) for k, v in info.items() if v is not None)
1026
1027     @staticmethod
1028     def _hidden_inputs(html):
1029         html = re.sub(r'<!--(?:(?!<!--).)*-->', '', html)
1030         hidden_inputs = {}
1031         for input in re.findall(r'(?i)(<input[^>]+>)', html):
1032             attrs = extract_attributes(input)
1033             if not input:
1034                 continue
1035             if attrs.get('type') not in ('hidden', 'submit'):
1036                 continue
1037             name = attrs.get('name') or attrs.get('id')
1038             value = attrs.get('value')
1039             if name and value is not None:
1040                 hidden_inputs[name] = value
1041         return hidden_inputs
1042
1043     def _form_hidden_inputs(self, form_id, html):
1044         form = self._search_regex(
1045             r'(?is)<form[^>]+?id=(["\'])%s\1[^>]*>(?P<form>.+?)</form>' % form_id,
1046             html, '%s form' % form_id, group='form')
1047         return self._hidden_inputs(form)
1048
1049     def _sort_formats(self, formats, field_preference=None):
1050         if not formats:
1051             raise ExtractorError('No video formats found')
1052
1053         for f in formats:
1054             # Automatically determine tbr when missing based on abr and vbr (improves
1055             # formats sorting in some cases)
1056             if 'tbr' not in f and f.get('abr') is not None and f.get('vbr') is not None:
1057                 f['tbr'] = f['abr'] + f['vbr']
1058
1059         def _formats_key(f):
1060             # TODO remove the following workaround
1061             from ..utils import determine_ext
1062             if not f.get('ext') and 'url' in f:
1063                 f['ext'] = determine_ext(f['url'])
1064
1065             if isinstance(field_preference, (list, tuple)):
1066                 return tuple(
1067                     f.get(field)
1068                     if f.get(field) is not None
1069                     else ('' if field == 'format_id' else -1)
1070                     for field in field_preference)
1071
1072             preference = f.get('preference')
1073             if preference is None:
1074                 preference = 0
1075                 if f.get('ext') in ['f4f', 'f4m']:  # Not yet supported
1076                     preference -= 0.5
1077
1078             protocol = f.get('protocol') or determine_protocol(f)
1079             proto_preference = 0 if protocol in ['http', 'https'] else (-0.5 if protocol == 'rtsp' else -0.1)
1080
1081             if f.get('vcodec') == 'none':  # audio only
1082                 preference -= 50
1083                 if self._downloader.params.get('prefer_free_formats'):
1084                     ORDER = ['aac', 'mp3', 'm4a', 'webm', 'ogg', 'opus']
1085                 else:
1086                     ORDER = ['webm', 'opus', 'ogg', 'mp3', 'aac', 'm4a']
1087                 ext_preference = 0
1088                 try:
1089                     audio_ext_preference = ORDER.index(f['ext'])
1090                 except ValueError:
1091                     audio_ext_preference = -1
1092             else:
1093                 if f.get('acodec') == 'none':  # video only
1094                     preference -= 40
1095                 if self._downloader.params.get('prefer_free_formats'):
1096                     ORDER = ['flv', 'mp4', 'webm']
1097                 else:
1098                     ORDER = ['webm', 'flv', 'mp4']
1099                 try:
1100                     ext_preference = ORDER.index(f['ext'])
1101                 except ValueError:
1102                     ext_preference = -1
1103                 audio_ext_preference = 0
1104
1105             return (
1106                 preference,
1107                 f.get('language_preference') if f.get('language_preference') is not None else -1,
1108                 f.get('quality') if f.get('quality') is not None else -1,
1109                 f.get('tbr') if f.get('tbr') is not None else -1,
1110                 f.get('filesize') if f.get('filesize') is not None else -1,
1111                 f.get('vbr') if f.get('vbr') is not None else -1,
1112                 f.get('height') if f.get('height') is not None else -1,
1113                 f.get('width') if f.get('width') is not None else -1,
1114                 proto_preference,
1115                 ext_preference,
1116                 f.get('abr') if f.get('abr') is not None else -1,
1117                 audio_ext_preference,
1118                 f.get('fps') if f.get('fps') is not None else -1,
1119                 f.get('filesize_approx') if f.get('filesize_approx') is not None else -1,
1120                 f.get('source_preference') if f.get('source_preference') is not None else -1,
1121                 f.get('format_id') if f.get('format_id') is not None else '',
1122             )
1123         formats.sort(key=_formats_key)
1124
1125     def _check_formats(self, formats, video_id):
1126         if formats:
1127             formats[:] = filter(
1128                 lambda f: self._is_valid_url(
1129                     f['url'], video_id,
1130                     item='%s video format' % f.get('format_id') if f.get('format_id') else 'video'),
1131                 formats)
1132
1133     @staticmethod
1134     def _remove_duplicate_formats(formats):
1135         format_urls = set()
1136         unique_formats = []
1137         for f in formats:
1138             if f['url'] not in format_urls:
1139                 format_urls.add(f['url'])
1140                 unique_formats.append(f)
1141         formats[:] = unique_formats
1142
1143     def _is_valid_url(self, url, video_id, item='video', headers={}):
1144         url = self._proto_relative_url(url, scheme='http:')
1145         # For now assume non HTTP(S) URLs always valid
1146         if not (url.startswith('http://') or url.startswith('https://')):
1147             return True
1148         try:
1149             self._request_webpage(url, video_id, 'Checking %s URL' % item, headers=headers)
1150             return True
1151         except ExtractorError as e:
1152             if isinstance(e.cause, compat_urllib_error.URLError):
1153                 self.to_screen(
1154                     '%s: %s URL is invalid, skipping' % (video_id, item))
1155                 return False
1156             raise
1157
1158     def http_scheme(self):
1159         """ Either "http:" or "https:", depending on the user's preferences """
1160         return (
1161             'http:'
1162             if self._downloader.params.get('prefer_insecure', False)
1163             else 'https:')
1164
1165     def _proto_relative_url(self, url, scheme=None):
1166         if url is None:
1167             return url
1168         if url.startswith('//'):
1169             if scheme is None:
1170                 scheme = self.http_scheme()
1171             return scheme + url
1172         else:
1173             return url
1174
1175     def _sleep(self, timeout, video_id, msg_template=None):
1176         if msg_template is None:
1177             msg_template = '%(video_id)s: Waiting for %(timeout)s seconds'
1178         msg = msg_template % {'video_id': video_id, 'timeout': timeout}
1179         self.to_screen(msg)
1180         time.sleep(timeout)
1181
1182     def _extract_f4m_formats(self, manifest_url, video_id, preference=None, f4m_id=None,
1183                              transform_source=lambda s: fix_xml_ampersands(s).strip(),
1184                              fatal=True, m3u8_id=None):
1185         manifest = self._download_xml(
1186             manifest_url, video_id, 'Downloading f4m manifest',
1187             'Unable to download f4m manifest',
1188             # Some manifests may be malformed, e.g. prosiebensat1 generated manifests
1189             # (see https://github.com/rg3/youtube-dl/issues/6215#issuecomment-121704244)
1190             transform_source=transform_source,
1191             fatal=fatal)
1192
1193         if manifest is False:
1194             return []
1195
1196         return self._parse_f4m_formats(
1197             manifest, manifest_url, video_id, preference=preference, f4m_id=f4m_id,
1198             transform_source=transform_source, fatal=fatal, m3u8_id=m3u8_id)
1199
1200     def _parse_f4m_formats(self, manifest, manifest_url, video_id, preference=None, f4m_id=None,
1201                            transform_source=lambda s: fix_xml_ampersands(s).strip(),
1202                            fatal=True, m3u8_id=None):
1203         # currently youtube-dl cannot decode the playerVerificationChallenge as Akamai uses Adobe Alchemy
1204         akamai_pv = manifest.find('{http://ns.adobe.com/f4m/1.0}pv-2.0')
1205         if akamai_pv is not None and ';' in akamai_pv.text:
1206             playerVerificationChallenge = akamai_pv.text.split(';')[0]
1207             if playerVerificationChallenge.strip() != '':
1208                 return []
1209
1210         formats = []
1211         manifest_version = '1.0'
1212         media_nodes = manifest.findall('{http://ns.adobe.com/f4m/1.0}media')
1213         if not media_nodes:
1214             manifest_version = '2.0'
1215             media_nodes = manifest.findall('{http://ns.adobe.com/f4m/2.0}media')
1216         # Remove unsupported DRM protected media from final formats
1217         # rendition (see https://github.com/rg3/youtube-dl/issues/8573).
1218         media_nodes = remove_encrypted_media(media_nodes)
1219         if not media_nodes:
1220             return formats
1221         base_url = xpath_text(
1222             manifest, ['{http://ns.adobe.com/f4m/1.0}baseURL', '{http://ns.adobe.com/f4m/2.0}baseURL'],
1223             'base URL', default=None)
1224         if base_url:
1225             base_url = base_url.strip()
1226
1227         bootstrap_info = xpath_element(
1228             manifest, ['{http://ns.adobe.com/f4m/1.0}bootstrapInfo', '{http://ns.adobe.com/f4m/2.0}bootstrapInfo'],
1229             'bootstrap info', default=None)
1230
1231         vcodec = None
1232         mime_type = xpath_text(
1233             manifest, ['{http://ns.adobe.com/f4m/1.0}mimeType', '{http://ns.adobe.com/f4m/2.0}mimeType'],
1234             'base URL', default=None)
1235         if mime_type and mime_type.startswith('audio/'):
1236             vcodec = 'none'
1237
1238         for i, media_el in enumerate(media_nodes):
1239             tbr = int_or_none(media_el.attrib.get('bitrate'))
1240             width = int_or_none(media_el.attrib.get('width'))
1241             height = int_or_none(media_el.attrib.get('height'))
1242             format_id = '-'.join(filter(None, [f4m_id, compat_str(i if tbr is None else tbr)]))
1243             # If <bootstrapInfo> is present, the specified f4m is a
1244             # stream-level manifest, and only set-level manifests may refer to
1245             # external resources.  See section 11.4 and section 4 of F4M spec
1246             if bootstrap_info is None:
1247                 media_url = None
1248                 # @href is introduced in 2.0, see section 11.6 of F4M spec
1249                 if manifest_version == '2.0':
1250                     media_url = media_el.attrib.get('href')
1251                 if media_url is None:
1252                     media_url = media_el.attrib.get('url')
1253                 if not media_url:
1254                     continue
1255                 manifest_url = (
1256                     media_url if media_url.startswith('http://') or media_url.startswith('https://')
1257                     else ((base_url or '/'.join(manifest_url.split('/')[:-1])) + '/' + media_url))
1258                 # If media_url is itself a f4m manifest do the recursive extraction
1259                 # since bitrates in parent manifest (this one) and media_url manifest
1260                 # may differ leading to inability to resolve the format by requested
1261                 # bitrate in f4m downloader
1262                 ext = determine_ext(manifest_url)
1263                 if ext == 'f4m':
1264                     f4m_formats = self._extract_f4m_formats(
1265                         manifest_url, video_id, preference=preference, f4m_id=f4m_id,
1266                         transform_source=transform_source, fatal=fatal)
1267                     # Sometimes stream-level manifest contains single media entry that
1268                     # does not contain any quality metadata (e.g. http://matchtv.ru/#live-player).
1269                     # At the same time parent's media entry in set-level manifest may
1270                     # contain it. We will copy it from parent in such cases.
1271                     if len(f4m_formats) == 1:
1272                         f = f4m_formats[0]
1273                         f.update({
1274                             'tbr': f.get('tbr') or tbr,
1275                             'width': f.get('width') or width,
1276                             'height': f.get('height') or height,
1277                             'format_id': f.get('format_id') if not tbr else format_id,
1278                             'vcodec': vcodec,
1279                         })
1280                     formats.extend(f4m_formats)
1281                     continue
1282                 elif ext == 'm3u8':
1283                     formats.extend(self._extract_m3u8_formats(
1284                         manifest_url, video_id, 'mp4', preference=preference,
1285                         m3u8_id=m3u8_id, fatal=fatal))
1286                     continue
1287             formats.append({
1288                 'format_id': format_id,
1289                 'url': manifest_url,
1290                 'manifest_url': manifest_url,
1291                 'ext': 'flv' if bootstrap_info is not None else None,
1292                 'tbr': tbr,
1293                 'width': width,
1294                 'height': height,
1295                 'vcodec': vcodec,
1296                 'preference': preference,
1297             })
1298         return formats
1299
1300     def _m3u8_meta_format(self, m3u8_url, ext=None, preference=None, m3u8_id=None):
1301         return {
1302             'format_id': '-'.join(filter(None, [m3u8_id, 'meta'])),
1303             'url': m3u8_url,
1304             'ext': ext,
1305             'protocol': 'm3u8',
1306             'preference': preference - 100 if preference else -100,
1307             'resolution': 'multiple',
1308             'format_note': 'Quality selection URL',
1309         }
1310
1311     def _extract_m3u8_formats(self, m3u8_url, video_id, ext=None,
1312                               entry_protocol='m3u8', preference=None,
1313                               m3u8_id=None, note=None, errnote=None,
1314                               fatal=True, live=False):
1315         res = self._download_webpage_handle(
1316             m3u8_url, video_id,
1317             note=note or 'Downloading m3u8 information',
1318             errnote=errnote or 'Failed to download m3u8 information',
1319             fatal=fatal)
1320
1321         if res is False:
1322             return []
1323
1324         m3u8_doc, urlh = res
1325         m3u8_url = urlh.geturl()
1326
1327         return self._parse_m3u8_formats(
1328             m3u8_doc, m3u8_url, ext=ext, entry_protocol=entry_protocol,
1329             preference=preference, m3u8_id=m3u8_id, live=live)
1330
1331     def _parse_m3u8_formats(self, m3u8_doc, m3u8_url, ext=None,
1332                             entry_protocol='m3u8', preference=None,
1333                             m3u8_id=None, live=False):
1334         if '#EXT-X-FAXS-CM:' in m3u8_doc:  # Adobe Flash Access
1335             return []
1336
1337         formats = [self._m3u8_meta_format(m3u8_url, ext, preference, m3u8_id)]
1338
1339         format_url = lambda u: (
1340             u
1341             if re.match(r'^https?://', u)
1342             else compat_urlparse.urljoin(m3u8_url, u))
1343
1344         # References:
1345         # 1. https://tools.ietf.org/html/draft-pantos-http-live-streaming-21
1346         # 2. https://github.com/rg3/youtube-dl/issues/12211
1347
1348         # We should try extracting formats only from master playlists [1, 4.3.4],
1349         # i.e. playlists that describe available qualities. On the other hand
1350         # media playlists [1, 4.3.3] should be returned as is since they contain
1351         # just the media without qualities renditions.
1352         # Fortunately, master playlist can be easily distinguished from media
1353         # playlist based on particular tags availability. As of [1, 4.3.3, 4.3.4]
1354         # master playlist tags MUST NOT appear in a media playist and vice versa.
1355         # As of [1, 4.3.3.1] #EXT-X-TARGETDURATION tag is REQUIRED for every
1356         # media playlist and MUST NOT appear in master playlist thus we can
1357         # clearly detect media playlist with this criterion.
1358
1359         if '#EXT-X-TARGETDURATION' in m3u8_doc:  # media playlist, return as is
1360             return [{
1361                 'url': m3u8_url,
1362                 'format_id': m3u8_id,
1363                 'ext': ext,
1364                 'protocol': entry_protocol,
1365                 'preference': preference,
1366             }]
1367
1368         groups = {}
1369         last_stream_inf = {}
1370
1371         def extract_media(x_media_line):
1372             media = parse_m3u8_attributes(x_media_line)
1373             # As per [1, 4.3.4.1] TYPE, GROUP-ID and NAME are REQUIRED
1374             media_type, group_id, name = media.get('TYPE'), media.get('GROUP-ID'), media.get('NAME')
1375             if not (media_type and group_id and name):
1376                 return
1377             groups.setdefault(group_id, []).append(media)
1378             if media_type not in ('VIDEO', 'AUDIO'):
1379                 return
1380             media_url = media.get('URI')
1381             if media_url:
1382                 format_id = []
1383                 for v in (group_id, name):
1384                     if v:
1385                         format_id.append(v)
1386                 f = {
1387                     'format_id': '-'.join(format_id),
1388                     'url': format_url(media_url),
1389                     'language': media.get('LANGUAGE'),
1390                     'ext': ext,
1391                     'protocol': entry_protocol,
1392                     'preference': preference,
1393                 }
1394                 if media_type == 'AUDIO':
1395                     f['vcodec'] = 'none'
1396                 formats.append(f)
1397
1398         def build_stream_name():
1399             # Despite specification does not mention NAME attribute for
1400             # EXT-X-STREAM-INF it still sometimes may be present
1401             stream_name = last_stream_inf.get('NAME')
1402             if stream_name:
1403                 return stream_name
1404             # If there is no NAME in EXT-X-STREAM-INF it will be obtained
1405             # from corresponding rendition group
1406             stream_group_id = last_stream_inf.get('VIDEO')
1407             if not stream_group_id:
1408                 return
1409             stream_group = groups.get(stream_group_id)
1410             if not stream_group:
1411                 return stream_group_id
1412             rendition = stream_group[0]
1413             return rendition.get('NAME') or stream_group_id
1414
1415         for line in m3u8_doc.splitlines():
1416             if line.startswith('#EXT-X-STREAM-INF:'):
1417                 last_stream_inf = parse_m3u8_attributes(line)
1418             elif line.startswith('#EXT-X-MEDIA:'):
1419                 extract_media(line)
1420             elif line.startswith('#') or not line.strip():
1421                 continue
1422             else:
1423                 tbr = float_or_none(
1424                     last_stream_inf.get('AVERAGE-BANDWIDTH') or
1425                     last_stream_inf.get('BANDWIDTH'), scale=1000)
1426                 format_id = []
1427                 if m3u8_id:
1428                     format_id.append(m3u8_id)
1429                 stream_name = build_stream_name()
1430                 # Bandwidth of live streams may differ over time thus making
1431                 # format_id unpredictable. So it's better to keep provided
1432                 # format_id intact.
1433                 if not live:
1434                     format_id.append(stream_name if stream_name else '%d' % (tbr if tbr else len(formats)))
1435                 manifest_url = format_url(line.strip())
1436                 f = {
1437                     'format_id': '-'.join(format_id),
1438                     'url': manifest_url,
1439                     'manifest_url': manifest_url,
1440                     'tbr': tbr,
1441                     'ext': ext,
1442                     'fps': float_or_none(last_stream_inf.get('FRAME-RATE')),
1443                     'protocol': entry_protocol,
1444                     'preference': preference,
1445                 }
1446                 resolution = last_stream_inf.get('RESOLUTION')
1447                 if resolution:
1448                     mobj = re.search(r'(?P<width>\d+)[xX](?P<height>\d+)', resolution)
1449                     if mobj:
1450                         f['width'] = int(mobj.group('width'))
1451                         f['height'] = int(mobj.group('height'))
1452                 # Unified Streaming Platform
1453                 mobj = re.search(
1454                     r'audio.*?(?:%3D|=)(\d+)(?:-video.*?(?:%3D|=)(\d+))?', f['url'])
1455                 if mobj:
1456                     abr, vbr = mobj.groups()
1457                     abr, vbr = float_or_none(abr, 1000), float_or_none(vbr, 1000)
1458                     f.update({
1459                         'vbr': vbr,
1460                         'abr': abr,
1461                     })
1462                 codecs = parse_codecs(last_stream_inf.get('CODECS'))
1463                 f.update(codecs)
1464                 audio_group_id = last_stream_inf.get('AUDIO')
1465                 # As per [1, 4.3.4.1.1] any EXT-X-STREAM-INF tag which
1466                 # references a rendition group MUST have a CODECS attribute.
1467                 # However, this is not always respected, for example, [2]
1468                 # contains EXT-X-STREAM-INF tag which references AUDIO
1469                 # rendition group but does not have CODECS and despite
1470                 # referencing audio group an audio group, it represents
1471                 # a complete (with audio and video) format. So, for such cases
1472                 # we will ignore references to rendition groups and treat them
1473                 # as complete formats.
1474                 if audio_group_id and codecs and f.get('vcodec') != 'none':
1475                     audio_group = groups.get(audio_group_id)
1476                     if audio_group and audio_group[0].get('URI'):
1477                         # TODO: update acodec for audio only formats with
1478                         # the same GROUP-ID
1479                         f['acodec'] = 'none'
1480                 formats.append(f)
1481                 last_stream_inf = {}
1482         return formats
1483
1484     @staticmethod
1485     def _xpath_ns(path, namespace=None):
1486         if not namespace:
1487             return path
1488         out = []
1489         for c in path.split('/'):
1490             if not c or c == '.':
1491                 out.append(c)
1492             else:
1493                 out.append('{%s}%s' % (namespace, c))
1494         return '/'.join(out)
1495
1496     def _extract_smil_formats(self, smil_url, video_id, fatal=True, f4m_params=None, transform_source=None):
1497         smil = self._download_smil(smil_url, video_id, fatal=fatal, transform_source=transform_source)
1498
1499         if smil is False:
1500             assert not fatal
1501             return []
1502
1503         namespace = self._parse_smil_namespace(smil)
1504
1505         return self._parse_smil_formats(
1506             smil, smil_url, video_id, namespace=namespace, f4m_params=f4m_params)
1507
1508     def _extract_smil_info(self, smil_url, video_id, fatal=True, f4m_params=None):
1509         smil = self._download_smil(smil_url, video_id, fatal=fatal)
1510         if smil is False:
1511             return {}
1512         return self._parse_smil(smil, smil_url, video_id, f4m_params=f4m_params)
1513
1514     def _download_smil(self, smil_url, video_id, fatal=True, transform_source=None):
1515         return self._download_xml(
1516             smil_url, video_id, 'Downloading SMIL file',
1517             'Unable to download SMIL file', fatal=fatal, transform_source=transform_source)
1518
1519     def _parse_smil(self, smil, smil_url, video_id, f4m_params=None):
1520         namespace = self._parse_smil_namespace(smil)
1521
1522         formats = self._parse_smil_formats(
1523             smil, smil_url, video_id, namespace=namespace, f4m_params=f4m_params)
1524         subtitles = self._parse_smil_subtitles(smil, namespace=namespace)
1525
1526         video_id = os.path.splitext(url_basename(smil_url))[0]
1527         title = None
1528         description = None
1529         upload_date = None
1530         for meta in smil.findall(self._xpath_ns('./head/meta', namespace)):
1531             name = meta.attrib.get('name')
1532             content = meta.attrib.get('content')
1533             if not name or not content:
1534                 continue
1535             if not title and name == 'title':
1536                 title = content
1537             elif not description and name in ('description', 'abstract'):
1538                 description = content
1539             elif not upload_date and name == 'date':
1540                 upload_date = unified_strdate(content)
1541
1542         thumbnails = [{
1543             'id': image.get('type'),
1544             'url': image.get('src'),
1545             'width': int_or_none(image.get('width')),
1546             'height': int_or_none(image.get('height')),
1547         } for image in smil.findall(self._xpath_ns('.//image', namespace)) if image.get('src')]
1548
1549         return {
1550             'id': video_id,
1551             'title': title or video_id,
1552             'description': description,
1553             'upload_date': upload_date,
1554             'thumbnails': thumbnails,
1555             'formats': formats,
1556             'subtitles': subtitles,
1557         }
1558
1559     def _parse_smil_namespace(self, smil):
1560         return self._search_regex(
1561             r'(?i)^{([^}]+)?}smil$', smil.tag, 'namespace', default=None)
1562
1563     def _parse_smil_formats(self, smil, smil_url, video_id, namespace=None, f4m_params=None, transform_rtmp_url=None):
1564         base = smil_url
1565         for meta in smil.findall(self._xpath_ns('./head/meta', namespace)):
1566             b = meta.get('base') or meta.get('httpBase')
1567             if b:
1568                 base = b
1569                 break
1570
1571         formats = []
1572         rtmp_count = 0
1573         http_count = 0
1574         m3u8_count = 0
1575
1576         srcs = []
1577         media = smil.findall(self._xpath_ns('.//video', namespace)) + smil.findall(self._xpath_ns('.//audio', namespace))
1578         for medium in media:
1579             src = medium.get('src')
1580             if not src or src in srcs:
1581                 continue
1582             srcs.append(src)
1583
1584             bitrate = float_or_none(medium.get('system-bitrate') or medium.get('systemBitrate'), 1000)
1585             filesize = int_or_none(medium.get('size') or medium.get('fileSize'))
1586             width = int_or_none(medium.get('width'))
1587             height = int_or_none(medium.get('height'))
1588             proto = medium.get('proto')
1589             ext = medium.get('ext')
1590             src_ext = determine_ext(src)
1591             streamer = medium.get('streamer') or base
1592
1593             if proto == 'rtmp' or streamer.startswith('rtmp'):
1594                 rtmp_count += 1
1595                 formats.append({
1596                     'url': streamer,
1597                     'play_path': src,
1598                     'ext': 'flv',
1599                     'format_id': 'rtmp-%d' % (rtmp_count if bitrate is None else bitrate),
1600                     'tbr': bitrate,
1601                     'filesize': filesize,
1602                     'width': width,
1603                     'height': height,
1604                 })
1605                 if transform_rtmp_url:
1606                     streamer, src = transform_rtmp_url(streamer, src)
1607                     formats[-1].update({
1608                         'url': streamer,
1609                         'play_path': src,
1610                     })
1611                 continue
1612
1613             src_url = src if src.startswith('http') else compat_urlparse.urljoin(base, src)
1614             src_url = src_url.strip()
1615
1616             if proto == 'm3u8' or src_ext == 'm3u8':
1617                 m3u8_formats = self._extract_m3u8_formats(
1618                     src_url, video_id, ext or 'mp4', m3u8_id='hls', fatal=False)
1619                 if len(m3u8_formats) == 1:
1620                     m3u8_count += 1
1621                     m3u8_formats[0].update({
1622                         'format_id': 'hls-%d' % (m3u8_count if bitrate is None else bitrate),
1623                         'tbr': bitrate,
1624                         'width': width,
1625                         'height': height,
1626                     })
1627                 formats.extend(m3u8_formats)
1628                 continue
1629
1630             if src_ext == 'f4m':
1631                 f4m_url = src_url
1632                 if not f4m_params:
1633                     f4m_params = {
1634                         'hdcore': '3.2.0',
1635                         'plugin': 'flowplayer-3.2.0.1',
1636                     }
1637                 f4m_url += '&' if '?' in f4m_url else '?'
1638                 f4m_url += compat_urllib_parse_urlencode(f4m_params)
1639                 formats.extend(self._extract_f4m_formats(f4m_url, video_id, f4m_id='hds', fatal=False))
1640                 continue
1641
1642             if src_url.startswith('http') and self._is_valid_url(src, video_id):
1643                 http_count += 1
1644                 formats.append({
1645                     'url': src_url,
1646                     'ext': ext or src_ext or 'flv',
1647                     'format_id': 'http-%d' % (bitrate or http_count),
1648                     'tbr': bitrate,
1649                     'filesize': filesize,
1650                     'width': width,
1651                     'height': height,
1652                 })
1653                 continue
1654
1655         return formats
1656
1657     def _parse_smil_subtitles(self, smil, namespace=None, subtitles_lang='en'):
1658         urls = []
1659         subtitles = {}
1660         for num, textstream in enumerate(smil.findall(self._xpath_ns('.//textstream', namespace))):
1661             src = textstream.get('src')
1662             if not src or src in urls:
1663                 continue
1664             urls.append(src)
1665             ext = textstream.get('ext') or mimetype2ext(textstream.get('type')) or determine_ext(src)
1666             lang = textstream.get('systemLanguage') or textstream.get('systemLanguageName') or textstream.get('lang') or subtitles_lang
1667             subtitles.setdefault(lang, []).append({
1668                 'url': src,
1669                 'ext': ext,
1670             })
1671         return subtitles
1672
1673     def _extract_xspf_playlist(self, playlist_url, playlist_id, fatal=True):
1674         xspf = self._download_xml(
1675             playlist_url, playlist_id, 'Downloading xpsf playlist',
1676             'Unable to download xspf manifest', fatal=fatal)
1677         if xspf is False:
1678             return []
1679         return self._parse_xspf(xspf, playlist_id)
1680
1681     def _parse_xspf(self, playlist, playlist_id):
1682         NS_MAP = {
1683             'xspf': 'http://xspf.org/ns/0/',
1684             's1': 'http://static.streamone.nl/player/ns/0',
1685         }
1686
1687         entries = []
1688         for track in playlist.findall(xpath_with_ns('./xspf:trackList/xspf:track', NS_MAP)):
1689             title = xpath_text(
1690                 track, xpath_with_ns('./xspf:title', NS_MAP), 'title', default=playlist_id)
1691             description = xpath_text(
1692                 track, xpath_with_ns('./xspf:annotation', NS_MAP), 'description')
1693             thumbnail = xpath_text(
1694                 track, xpath_with_ns('./xspf:image', NS_MAP), 'thumbnail')
1695             duration = float_or_none(
1696                 xpath_text(track, xpath_with_ns('./xspf:duration', NS_MAP), 'duration'), 1000)
1697
1698             formats = [{
1699                 'url': location.text,
1700                 'format_id': location.get(xpath_with_ns('s1:label', NS_MAP)),
1701                 'width': int_or_none(location.get(xpath_with_ns('s1:width', NS_MAP))),
1702                 'height': int_or_none(location.get(xpath_with_ns('s1:height', NS_MAP))),
1703             } for location in track.findall(xpath_with_ns('./xspf:location', NS_MAP))]
1704             self._sort_formats(formats)
1705
1706             entries.append({
1707                 'id': playlist_id,
1708                 'title': title,
1709                 'description': description,
1710                 'thumbnail': thumbnail,
1711                 'duration': duration,
1712                 'formats': formats,
1713             })
1714         return entries
1715
1716     def _extract_mpd_formats(self, mpd_url, video_id, mpd_id=None, note=None, errnote=None, fatal=True, formats_dict={}):
1717         res = self._download_webpage_handle(
1718             mpd_url, video_id,
1719             note=note or 'Downloading MPD manifest',
1720             errnote=errnote or 'Failed to download MPD manifest',
1721             fatal=fatal)
1722         if res is False:
1723             return []
1724         mpd, urlh = res
1725         mpd_base_url = base_url(urlh.geturl())
1726
1727         return self._parse_mpd_formats(
1728             compat_etree_fromstring(mpd.encode('utf-8')), mpd_id, mpd_base_url,
1729             formats_dict=formats_dict, mpd_url=mpd_url)
1730
1731     def _parse_mpd_formats(self, mpd_doc, mpd_id=None, mpd_base_url='', formats_dict={}, mpd_url=None):
1732         """
1733         Parse formats from MPD manifest.
1734         References:
1735          1. MPEG-DASH Standard, ISO/IEC 23009-1:2014(E),
1736             http://standards.iso.org/ittf/PubliclyAvailableStandards/c065274_ISO_IEC_23009-1_2014.zip
1737          2. https://en.wikipedia.org/wiki/Dynamic_Adaptive_Streaming_over_HTTP
1738         """
1739         if mpd_doc.get('type') == 'dynamic':
1740             return []
1741
1742         namespace = self._search_regex(r'(?i)^{([^}]+)?}MPD$', mpd_doc.tag, 'namespace', default=None)
1743
1744         def _add_ns(path):
1745             return self._xpath_ns(path, namespace)
1746
1747         def is_drm_protected(element):
1748             return element.find(_add_ns('ContentProtection')) is not None
1749
1750         def extract_multisegment_info(element, ms_parent_info):
1751             ms_info = ms_parent_info.copy()
1752
1753             # As per [1, 5.3.9.2.2] SegmentList and SegmentTemplate share some
1754             # common attributes and elements.  We will only extract relevant
1755             # for us.
1756             def extract_common(source):
1757                 segment_timeline = source.find(_add_ns('SegmentTimeline'))
1758                 if segment_timeline is not None:
1759                     s_e = segment_timeline.findall(_add_ns('S'))
1760                     if s_e:
1761                         ms_info['total_number'] = 0
1762                         ms_info['s'] = []
1763                         for s in s_e:
1764                             r = int(s.get('r', 0))
1765                             ms_info['total_number'] += 1 + r
1766                             ms_info['s'].append({
1767                                 't': int(s.get('t', 0)),
1768                                 # @d is mandatory (see [1, 5.3.9.6.2, Table 17, page 60])
1769                                 'd': int(s.attrib['d']),
1770                                 'r': r,
1771                             })
1772                 start_number = source.get('startNumber')
1773                 if start_number:
1774                     ms_info['start_number'] = int(start_number)
1775                 timescale = source.get('timescale')
1776                 if timescale:
1777                     ms_info['timescale'] = int(timescale)
1778                 segment_duration = source.get('duration')
1779                 if segment_duration:
1780                     ms_info['segment_duration'] = int(segment_duration)
1781
1782             def extract_Initialization(source):
1783                 initialization = source.find(_add_ns('Initialization'))
1784                 if initialization is not None:
1785                     ms_info['initialization_url'] = initialization.attrib['sourceURL']
1786
1787             segment_list = element.find(_add_ns('SegmentList'))
1788             if segment_list is not None:
1789                 extract_common(segment_list)
1790                 extract_Initialization(segment_list)
1791                 segment_urls_e = segment_list.findall(_add_ns('SegmentURL'))
1792                 if segment_urls_e:
1793                     ms_info['segment_urls'] = [segment.attrib['media'] for segment in segment_urls_e]
1794             else:
1795                 segment_template = element.find(_add_ns('SegmentTemplate'))
1796                 if segment_template is not None:
1797                     extract_common(segment_template)
1798                     media = segment_template.get('media')
1799                     if media:
1800                         ms_info['media'] = media
1801                     initialization = segment_template.get('initialization')
1802                     if initialization:
1803                         ms_info['initialization'] = initialization
1804                     else:
1805                         extract_Initialization(segment_template)
1806             return ms_info
1807
1808         mpd_duration = parse_duration(mpd_doc.get('mediaPresentationDuration'))
1809         formats = []
1810         for period in mpd_doc.findall(_add_ns('Period')):
1811             period_duration = parse_duration(period.get('duration')) or mpd_duration
1812             period_ms_info = extract_multisegment_info(period, {
1813                 'start_number': 1,
1814                 'timescale': 1,
1815             })
1816             for adaptation_set in period.findall(_add_ns('AdaptationSet')):
1817                 if is_drm_protected(adaptation_set):
1818                     continue
1819                 adaption_set_ms_info = extract_multisegment_info(adaptation_set, period_ms_info)
1820                 for representation in adaptation_set.findall(_add_ns('Representation')):
1821                     if is_drm_protected(representation):
1822                         continue
1823                     representation_attrib = adaptation_set.attrib.copy()
1824                     representation_attrib.update(representation.attrib)
1825                     # According to [1, 5.3.7.2, Table 9, page 41], @mimeType is mandatory
1826                     mime_type = representation_attrib['mimeType']
1827                     content_type = mime_type.split('/')[0]
1828                     if content_type == 'text':
1829                         # TODO implement WebVTT downloading
1830                         pass
1831                     elif content_type in ('video', 'audio'):
1832                         base_url = ''
1833                         for element in (representation, adaptation_set, period, mpd_doc):
1834                             base_url_e = element.find(_add_ns('BaseURL'))
1835                             if base_url_e is not None:
1836                                 base_url = base_url_e.text + base_url
1837                                 if re.match(r'^https?://', base_url):
1838                                     break
1839                         if mpd_base_url and not re.match(r'^https?://', base_url):
1840                             if not mpd_base_url.endswith('/') and not base_url.startswith('/'):
1841                                 mpd_base_url += '/'
1842                             base_url = mpd_base_url + base_url
1843                         representation_id = representation_attrib.get('id')
1844                         lang = representation_attrib.get('lang')
1845                         url_el = representation.find(_add_ns('BaseURL'))
1846                         filesize = int_or_none(url_el.attrib.get('{http://youtube.com/yt/2012/10/10}contentLength') if url_el is not None else None)
1847                         bandwidth = int_or_none(representation_attrib.get('bandwidth'))
1848                         f = {
1849                             'format_id': '%s-%s' % (mpd_id, representation_id) if mpd_id else representation_id,
1850                             'url': base_url,
1851                             'manifest_url': mpd_url,
1852                             'ext': mimetype2ext(mime_type),
1853                             'width': int_or_none(representation_attrib.get('width')),
1854                             'height': int_or_none(representation_attrib.get('height')),
1855                             'tbr': float_or_none(bandwidth, 1000),
1856                             'asr': int_or_none(representation_attrib.get('audioSamplingRate')),
1857                             'fps': int_or_none(representation_attrib.get('frameRate')),
1858                             'language': lang if lang not in ('mul', 'und', 'zxx', 'mis') else None,
1859                             'format_note': 'DASH %s' % content_type,
1860                             'filesize': filesize,
1861                         }
1862                         f.update(parse_codecs(representation_attrib.get('codecs')))
1863                         representation_ms_info = extract_multisegment_info(representation, adaption_set_ms_info)
1864
1865                         def prepare_template(template_name, identifiers):
1866                             t = representation_ms_info[template_name]
1867                             t = t.replace('$RepresentationID$', representation_id)
1868                             t = re.sub(r'\$(%s)\$' % '|'.join(identifiers), r'%(\1)d', t)
1869                             t = re.sub(r'\$(%s)%%([^$]+)\$' % '|'.join(identifiers), r'%(\1)\2', t)
1870                             t.replace('$$', '$')
1871                             return t
1872
1873                         # @initialization is a regular template like @media one
1874                         # so it should be handled just the same way (see
1875                         # https://github.com/rg3/youtube-dl/issues/11605)
1876                         if 'initialization' in representation_ms_info:
1877                             initialization_template = prepare_template(
1878                                 'initialization',
1879                                 # As per [1, 5.3.9.4.2, Table 15, page 54] $Number$ and
1880                                 # $Time$ shall not be included for @initialization thus
1881                                 # only $Bandwidth$ remains
1882                                 ('Bandwidth', ))
1883                             representation_ms_info['initialization_url'] = initialization_template % {
1884                                 'Bandwidth': bandwidth,
1885                             }
1886
1887                         if 'segment_urls' not in representation_ms_info and 'media' in representation_ms_info:
1888
1889                             media_template = prepare_template('media', ('Number', 'Bandwidth', 'Time'))
1890
1891                             # As per [1, 5.3.9.4.4, Table 16, page 55] $Number$ and $Time$
1892                             # can't be used at the same time
1893                             if '%(Number' in media_template and 's' not in representation_ms_info:
1894                                 segment_duration = None
1895                                 if 'total_number' not in representation_ms_info and 'segment_duration':
1896                                     segment_duration = float_or_none(representation_ms_info['segment_duration'], representation_ms_info['timescale'])
1897                                     representation_ms_info['total_number'] = int(math.ceil(float(period_duration) / segment_duration))
1898                                 representation_ms_info['fragments'] = [{
1899                                     'url': media_template % {
1900                                         'Number': segment_number,
1901                                         'Bandwidth': bandwidth,
1902                                     },
1903                                     'duration': segment_duration,
1904                                 } for segment_number in range(
1905                                     representation_ms_info['start_number'],
1906                                     representation_ms_info['total_number'] + representation_ms_info['start_number'])]
1907                             else:
1908                                 # $Number*$ or $Time$ in media template with S list available
1909                                 # Example $Number*$: http://www.svtplay.se/klipp/9023742/stopptid-om-bjorn-borg
1910                                 # Example $Time$: https://play.arkena.com/embed/avp/v2/player/media/b41dda37-d8e7-4d3f-b1b5-9a9db578bdfe/1/129411
1911                                 representation_ms_info['fragments'] = []
1912                                 segment_time = 0
1913                                 segment_d = None
1914                                 segment_number = representation_ms_info['start_number']
1915
1916                                 def add_segment_url():
1917                                     segment_url = media_template % {
1918                                         'Time': segment_time,
1919                                         'Bandwidth': bandwidth,
1920                                         'Number': segment_number,
1921                                     }
1922                                     representation_ms_info['fragments'].append({
1923                                         'url': segment_url,
1924                                         'duration': float_or_none(segment_d, representation_ms_info['timescale']),
1925                                     })
1926
1927                                 for num, s in enumerate(representation_ms_info['s']):
1928                                     segment_time = s.get('t') or segment_time
1929                                     segment_d = s['d']
1930                                     add_segment_url()
1931                                     segment_number += 1
1932                                     for r in range(s.get('r', 0)):
1933                                         segment_time += segment_d
1934                                         add_segment_url()
1935                                         segment_number += 1
1936                                     segment_time += segment_d
1937                         elif 'segment_urls' in representation_ms_info and 's' in representation_ms_info:
1938                             # No media template
1939                             # Example: https://www.youtube.com/watch?v=iXZV5uAYMJI
1940                             # or any YouTube dashsegments video
1941                             fragments = []
1942                             segment_index = 0
1943                             timescale = representation_ms_info['timescale']
1944                             for s in representation_ms_info['s']:
1945                                 duration = float_or_none(s['d'], timescale)
1946                                 for r in range(s.get('r', 0) + 1):
1947                                     fragments.append({
1948                                         'url': representation_ms_info['segment_urls'][segment_index],
1949                                         'duration': duration,
1950                                     })
1951                                     segment_index += 1
1952                             representation_ms_info['fragments'] = fragments
1953                         # NB: MPD manifest may contain direct URLs to unfragmented media.
1954                         # No fragments key is present in this case.
1955                         if 'fragments' in representation_ms_info:
1956                             f.update({
1957                                 'fragments': [],
1958                                 'protocol': 'http_dash_segments',
1959                             })
1960                             if 'initialization_url' in representation_ms_info:
1961                                 initialization_url = representation_ms_info['initialization_url']
1962                                 if not f.get('url'):
1963                                     f['url'] = initialization_url
1964                                 f['fragments'].append({'url': initialization_url})
1965                             f['fragments'].extend(representation_ms_info['fragments'])
1966                             for fragment in f['fragments']:
1967                                 fragment['url'] = urljoin(base_url, fragment['url'])
1968                         try:
1969                             existing_format = next(
1970                                 fo for fo in formats
1971                                 if fo['format_id'] == representation_id)
1972                         except StopIteration:
1973                             full_info = formats_dict.get(representation_id, {}).copy()
1974                             full_info.update(f)
1975                             formats.append(full_info)
1976                         else:
1977                             existing_format.update(f)
1978                     else:
1979                         self.report_warning('Unknown MIME type %s in DASH manifest' % mime_type)
1980         return formats
1981
1982     def _extract_ism_formats(self, ism_url, video_id, ism_id=None, note=None, errnote=None, fatal=True):
1983         res = self._download_webpage_handle(
1984             ism_url, video_id,
1985             note=note or 'Downloading ISM manifest',
1986             errnote=errnote or 'Failed to download ISM manifest',
1987             fatal=fatal)
1988         if res is False:
1989             return []
1990         ism, urlh = res
1991
1992         return self._parse_ism_formats(
1993             compat_etree_fromstring(ism.encode('utf-8')), urlh.geturl(), ism_id)
1994
1995     def _parse_ism_formats(self, ism_doc, ism_url, ism_id=None):
1996         if ism_doc.get('IsLive') == 'TRUE' or ism_doc.find('Protection') is not None:
1997             return []
1998
1999         duration = int(ism_doc.attrib['Duration'])
2000         timescale = int_or_none(ism_doc.get('TimeScale')) or 10000000
2001
2002         formats = []
2003         for stream in ism_doc.findall('StreamIndex'):
2004             stream_type = stream.get('Type')
2005             if stream_type not in ('video', 'audio'):
2006                 continue
2007             url_pattern = stream.attrib['Url']
2008             stream_timescale = int_or_none(stream.get('TimeScale')) or timescale
2009             stream_name = stream.get('Name')
2010             for track in stream.findall('QualityLevel'):
2011                 fourcc = track.get('FourCC')
2012                 # TODO: add support for WVC1 and WMAP
2013                 if fourcc not in ('H264', 'AVC1', 'AACL'):
2014                     self.report_warning('%s is not a supported codec' % fourcc)
2015                     continue
2016                 tbr = int(track.attrib['Bitrate']) // 1000
2017                 width = int_or_none(track.get('MaxWidth'))
2018                 height = int_or_none(track.get('MaxHeight'))
2019                 sampling_rate = int_or_none(track.get('SamplingRate'))
2020
2021                 track_url_pattern = re.sub(r'{[Bb]itrate}', track.attrib['Bitrate'], url_pattern)
2022                 track_url_pattern = compat_urlparse.urljoin(ism_url, track_url_pattern)
2023
2024                 fragments = []
2025                 fragment_ctx = {
2026                     'time': 0,
2027                 }
2028                 stream_fragments = stream.findall('c')
2029                 for stream_fragment_index, stream_fragment in enumerate(stream_fragments):
2030                     fragment_ctx['time'] = int_or_none(stream_fragment.get('t')) or fragment_ctx['time']
2031                     fragment_repeat = int_or_none(stream_fragment.get('r')) or 1
2032                     fragment_ctx['duration'] = int_or_none(stream_fragment.get('d'))
2033                     if not fragment_ctx['duration']:
2034                         try:
2035                             next_fragment_time = int(stream_fragment[stream_fragment_index + 1].attrib['t'])
2036                         except IndexError:
2037                             next_fragment_time = duration
2038                         fragment_ctx['duration'] = (next_fragment_time - fragment_ctx['time']) / fragment_repeat
2039                     for _ in range(fragment_repeat):
2040                         fragments.append({
2041                             'url': re.sub(r'{start[ _]time}', compat_str(fragment_ctx['time']), track_url_pattern),
2042                             'duration': fragment_ctx['duration'] / stream_timescale,
2043                         })
2044                         fragment_ctx['time'] += fragment_ctx['duration']
2045
2046                 format_id = []
2047                 if ism_id:
2048                     format_id.append(ism_id)
2049                 if stream_name:
2050                     format_id.append(stream_name)
2051                 format_id.append(compat_str(tbr))
2052
2053                 formats.append({
2054                     'format_id': '-'.join(format_id),
2055                     'url': ism_url,
2056                     'manifest_url': ism_url,
2057                     'ext': 'ismv' if stream_type == 'video' else 'isma',
2058                     'width': width,
2059                     'height': height,
2060                     'tbr': tbr,
2061                     'asr': sampling_rate,
2062                     'vcodec': 'none' if stream_type == 'audio' else fourcc,
2063                     'acodec': 'none' if stream_type == 'video' else fourcc,
2064                     'protocol': 'ism',
2065                     'fragments': fragments,
2066                     '_download_params': {
2067                         'duration': duration,
2068                         'timescale': stream_timescale,
2069                         'width': width or 0,
2070                         'height': height or 0,
2071                         'fourcc': fourcc,
2072                         'codec_private_data': track.get('CodecPrivateData'),
2073                         'sampling_rate': sampling_rate,
2074                         'channels': int_or_none(track.get('Channels', 2)),
2075                         'bits_per_sample': int_or_none(track.get('BitsPerSample', 16)),
2076                         'nal_unit_length_field': int_or_none(track.get('NALUnitLengthField', 4)),
2077                     },
2078                 })
2079         return formats
2080
2081     def _parse_html5_media_entries(self, base_url, webpage, video_id, m3u8_id=None, m3u8_entry_protocol='m3u8', mpd_id=None, preference=None):
2082         def absolute_url(video_url):
2083             return compat_urlparse.urljoin(base_url, video_url)
2084
2085         def parse_content_type(content_type):
2086             if not content_type:
2087                 return {}
2088             ctr = re.search(r'(?P<mimetype>[^/]+/[^;]+)(?:;\s*codecs="?(?P<codecs>[^"]+))?', content_type)
2089             if ctr:
2090                 mimetype, codecs = ctr.groups()
2091                 f = parse_codecs(codecs)
2092                 f['ext'] = mimetype2ext(mimetype)
2093                 return f
2094             return {}
2095
2096         def _media_formats(src, cur_media_type):
2097             full_url = absolute_url(src)
2098             ext = determine_ext(full_url)
2099             if ext == 'm3u8':
2100                 is_plain_url = False
2101                 formats = self._extract_m3u8_formats(
2102                     full_url, video_id, ext='mp4',
2103                     entry_protocol=m3u8_entry_protocol, m3u8_id=m3u8_id,
2104                     preference=preference)
2105             elif ext == 'mpd':
2106                 is_plain_url = False
2107                 formats = self._extract_mpd_formats(
2108                     full_url, video_id, mpd_id=mpd_id)
2109             else:
2110                 is_plain_url = True
2111                 formats = [{
2112                     'url': full_url,
2113                     'vcodec': 'none' if cur_media_type == 'audio' else None,
2114                 }]
2115             return is_plain_url, formats
2116
2117         entries = []
2118         media_tags = [(media_tag, media_type, '')
2119                       for media_tag, media_type
2120                       in re.findall(r'(?s)(<(video|audio)[^>]*/>)', webpage)]
2121         media_tags.extend(re.findall(
2122             # We only allow video|audio followed by a whitespace or '>'.
2123             # Allowing more characters may end up in significant slow down (see
2124             # https://github.com/rg3/youtube-dl/issues/11979, example URL:
2125             # http://www.porntrex.com/maps/videositemap.xml).
2126             r'(?s)(<(?P<tag>video|audio)(?:\s+[^>]*)?>)(.*?)</(?P=tag)>', webpage))
2127         for media_tag, media_type, media_content in media_tags:
2128             media_info = {
2129                 'formats': [],
2130                 'subtitles': {},
2131             }
2132             media_attributes = extract_attributes(media_tag)
2133             src = media_attributes.get('src')
2134             if src:
2135                 _, formats = _media_formats(src, media_type)
2136                 media_info['formats'].extend(formats)
2137             media_info['thumbnail'] = media_attributes.get('poster')
2138             if media_content:
2139                 for source_tag in re.findall(r'<source[^>]+>', media_content):
2140                     source_attributes = extract_attributes(source_tag)
2141                     src = source_attributes.get('src')
2142                     if not src:
2143                         continue
2144                     is_plain_url, formats = _media_formats(src, media_type)
2145                     if is_plain_url:
2146                         f = parse_content_type(source_attributes.get('type'))
2147                         f.update(formats[0])
2148                         media_info['formats'].append(f)
2149                     else:
2150                         media_info['formats'].extend(formats)
2151                 for track_tag in re.findall(r'<track[^>]+>', media_content):
2152                     track_attributes = extract_attributes(track_tag)
2153                     kind = track_attributes.get('kind')
2154                     if not kind or kind in ('subtitles', 'captions'):
2155                         src = track_attributes.get('src')
2156                         if not src:
2157                             continue
2158                         lang = track_attributes.get('srclang') or track_attributes.get('lang') or track_attributes.get('label')
2159                         media_info['subtitles'].setdefault(lang, []).append({
2160                             'url': absolute_url(src),
2161                         })
2162             if media_info['formats'] or media_info['subtitles']:
2163                 entries.append(media_info)
2164         return entries
2165
2166     def _extract_akamai_formats(self, manifest_url, video_id, hosts={}):
2167         formats = []
2168         hdcore_sign = 'hdcore=3.7.0'
2169         f4m_url = re.sub(r'(https?://[^/+])/i/', r'\1/z/', manifest_url).replace('/master.m3u8', '/manifest.f4m')
2170         hds_host = hosts.get('hds')
2171         if hds_host:
2172             f4m_url = re.sub(r'(https?://)[^/]+', r'\1' + hds_host, f4m_url)
2173         if 'hdcore=' not in f4m_url:
2174             f4m_url += ('&' if '?' in f4m_url else '?') + hdcore_sign
2175         f4m_formats = self._extract_f4m_formats(
2176             f4m_url, video_id, f4m_id='hds', fatal=False)
2177         for entry in f4m_formats:
2178             entry.update({'extra_param_to_segment_url': hdcore_sign})
2179         formats.extend(f4m_formats)
2180         m3u8_url = re.sub(r'(https?://[^/]+)/z/', r'\1/i/', manifest_url).replace('/manifest.f4m', '/master.m3u8')
2181         hls_host = hosts.get('hls')
2182         if hls_host:
2183             m3u8_url = re.sub(r'(https?://)[^/]+', r'\1' + hls_host, m3u8_url)
2184         formats.extend(self._extract_m3u8_formats(
2185             m3u8_url, video_id, 'mp4', 'm3u8_native',
2186             m3u8_id='hls', fatal=False))
2187         return formats
2188
2189     def _extract_wowza_formats(self, url, video_id, m3u8_entry_protocol='m3u8_native', skip_protocols=[]):
2190         url = re.sub(r'/(?:manifest|playlist|jwplayer)\.(?:m3u8|f4m|mpd|smil)', '', url)
2191         url_base = self._search_regex(r'(?:https?|rtmp|rtsp)(://[^?]+)', url, 'format url')
2192         http_base_url = 'http' + url_base
2193         formats = []
2194         if 'm3u8' not in skip_protocols:
2195             formats.extend(self._extract_m3u8_formats(
2196                 http_base_url + '/playlist.m3u8', video_id, 'mp4',
2197                 m3u8_entry_protocol, m3u8_id='hls', fatal=False))
2198         if 'f4m' not in skip_protocols:
2199             formats.extend(self._extract_f4m_formats(
2200                 http_base_url + '/manifest.f4m',
2201                 video_id, f4m_id='hds', fatal=False))
2202         if 'dash' not in skip_protocols:
2203             formats.extend(self._extract_mpd_formats(
2204                 http_base_url + '/manifest.mpd',
2205                 video_id, mpd_id='dash', fatal=False))
2206         if re.search(r'(?:/smil:|\.smil)', url_base):
2207             if 'smil' not in skip_protocols:
2208                 rtmp_formats = self._extract_smil_formats(
2209                     http_base_url + '/jwplayer.smil',
2210                     video_id, fatal=False)
2211                 for rtmp_format in rtmp_formats:
2212                     rtsp_format = rtmp_format.copy()
2213                     rtsp_format['url'] = '%s/%s' % (rtmp_format['url'], rtmp_format['play_path'])
2214                     del rtsp_format['play_path']
2215                     del rtsp_format['ext']
2216                     rtsp_format.update({
2217                         'url': rtsp_format['url'].replace('rtmp://', 'rtsp://'),
2218                         'format_id': rtmp_format['format_id'].replace('rtmp', 'rtsp'),
2219                         'protocol': 'rtsp',
2220                     })
2221                     formats.extend([rtmp_format, rtsp_format])
2222         else:
2223             for protocol in ('rtmp', 'rtsp'):
2224                 if protocol not in skip_protocols:
2225                     formats.append({
2226                         'url': protocol + url_base,
2227                         'format_id': protocol,
2228                         'protocol': protocol,
2229                     })
2230         return formats
2231
2232     def _find_jwplayer_data(self, webpage, video_id=None, transform_source=js_to_json):
2233         mobj = re.search(
2234             r'(?s)jwplayer\((?P<quote>[\'"])[^\'" ]+(?P=quote)\).*?\.setup\s*\((?P<options>[^)]+)\)',
2235             webpage)
2236         if mobj:
2237             try:
2238                 jwplayer_data = self._parse_json(mobj.group('options'),
2239                                                  video_id=video_id,
2240                                                  transform_source=transform_source)
2241             except ExtractorError:
2242                 pass
2243             else:
2244                 if isinstance(jwplayer_data, dict):
2245                     return jwplayer_data
2246
2247     def _extract_jwplayer_data(self, webpage, video_id, *args, **kwargs):
2248         jwplayer_data = self._find_jwplayer_data(
2249             webpage, video_id, transform_source=js_to_json)
2250         return self._parse_jwplayer_data(
2251             jwplayer_data, video_id, *args, **kwargs)
2252
2253     def _parse_jwplayer_data(self, jwplayer_data, video_id=None, require_title=True,
2254                              m3u8_id=None, mpd_id=None, rtmp_params=None, base_url=None):
2255         # JWPlayer backward compatibility: flattened playlists
2256         # https://github.com/jwplayer/jwplayer/blob/v7.4.3/src/js/api/config.js#L81-L96
2257         if 'playlist' not in jwplayer_data:
2258             jwplayer_data = {'playlist': [jwplayer_data]}
2259
2260         entries = []
2261
2262         # JWPlayer backward compatibility: single playlist item
2263         # https://github.com/jwplayer/jwplayer/blob/v7.7.0/src/js/playlist/playlist.js#L10
2264         if not isinstance(jwplayer_data['playlist'], list):
2265             jwplayer_data['playlist'] = [jwplayer_data['playlist']]
2266
2267         for video_data in jwplayer_data['playlist']:
2268             # JWPlayer backward compatibility: flattened sources
2269             # https://github.com/jwplayer/jwplayer/blob/v7.4.3/src/js/playlist/item.js#L29-L35
2270             if 'sources' not in video_data:
2271                 video_data['sources'] = [video_data]
2272
2273             this_video_id = video_id or video_data['mediaid']
2274
2275             formats = self._parse_jwplayer_formats(
2276                 video_data['sources'], video_id=this_video_id, m3u8_id=m3u8_id,
2277                 mpd_id=mpd_id, rtmp_params=rtmp_params, base_url=base_url)
2278             self._sort_formats(formats)
2279
2280             subtitles = {}
2281             tracks = video_data.get('tracks')
2282             if tracks and isinstance(tracks, list):
2283                 for track in tracks:
2284                     if track.get('kind') != 'captions':
2285                         continue
2286                     track_url = urljoin(base_url, track.get('file'))
2287                     if not track_url:
2288                         continue
2289                     subtitles.setdefault(track.get('label') or 'en', []).append({
2290                         'url': self._proto_relative_url(track_url)
2291                     })
2292
2293             entries.append({
2294                 'id': this_video_id,
2295                 'title': video_data['title'] if require_title else video_data.get('title'),
2296                 'description': video_data.get('description'),
2297                 'thumbnail': self._proto_relative_url(video_data.get('image')),
2298                 'timestamp': int_or_none(video_data.get('pubdate')),
2299                 'duration': float_or_none(jwplayer_data.get('duration') or video_data.get('duration')),
2300                 'subtitles': subtitles,
2301                 'formats': formats,
2302             })
2303         if len(entries) == 1:
2304             return entries[0]
2305         else:
2306             return self.playlist_result(entries)
2307
2308     def _parse_jwplayer_formats(self, jwplayer_sources_data, video_id=None,
2309                                 m3u8_id=None, mpd_id=None, rtmp_params=None, base_url=None):
2310         urls = []
2311         formats = []
2312         for source in jwplayer_sources_data:
2313             source_url = self._proto_relative_url(source.get('file'))
2314             if not source_url:
2315                 continue
2316             if base_url:
2317                 source_url = compat_urlparse.urljoin(base_url, source_url)
2318             if source_url in urls:
2319                 continue
2320             urls.append(source_url)
2321             source_type = source.get('type') or ''
2322             ext = mimetype2ext(source_type) or determine_ext(source_url)
2323             if source_type == 'hls' or ext == 'm3u8':
2324                 formats.extend(self._extract_m3u8_formats(
2325                     source_url, video_id, 'mp4', entry_protocol='m3u8_native',
2326                     m3u8_id=m3u8_id, fatal=False))
2327             elif ext == 'mpd':
2328                 formats.extend(self._extract_mpd_formats(
2329                     source_url, video_id, mpd_id=mpd_id, fatal=False))
2330             elif ext == 'smil':
2331                 formats.extend(self._extract_smil_formats(
2332                     source_url, video_id, fatal=False))
2333             # https://github.com/jwplayer/jwplayer/blob/master/src/js/providers/default.js#L67
2334             elif source_type.startswith('audio') or ext in (
2335                     'oga', 'aac', 'mp3', 'mpeg', 'vorbis'):
2336                 formats.append({
2337                     'url': source_url,
2338                     'vcodec': 'none',
2339                     'ext': ext,
2340                 })
2341             else:
2342                 height = int_or_none(source.get('height'))
2343                 if height is None:
2344                     # Often no height is provided but there is a label in
2345                     # format like "1080p", "720p SD", or 1080.
2346                     height = int_or_none(self._search_regex(
2347                         r'^(\d{3,4})[pP]?(?:\b|$)', compat_str(source.get('label') or ''),
2348                         'height', default=None))
2349                 a_format = {
2350                     'url': source_url,
2351                     'width': int_or_none(source.get('width')),
2352                     'height': height,
2353                     'tbr': int_or_none(source.get('bitrate')),
2354                     'ext': ext,
2355                 }
2356                 if source_url.startswith('rtmp'):
2357                     a_format['ext'] = 'flv'
2358                     # See com/longtailvideo/jwplayer/media/RTMPMediaProvider.as
2359                     # of jwplayer.flash.swf
2360                     rtmp_url_parts = re.split(
2361                         r'((?:mp4|mp3|flv):)', source_url, 1)
2362                     if len(rtmp_url_parts) == 3:
2363                         rtmp_url, prefix, play_path = rtmp_url_parts
2364                         a_format.update({
2365                             'url': rtmp_url,
2366                             'play_path': prefix + play_path,
2367                         })
2368                     if rtmp_params:
2369                         a_format.update(rtmp_params)
2370                 formats.append(a_format)
2371         return formats
2372
2373     def _live_title(self, name):
2374         """ Generate the title for a live video """
2375         now = datetime.datetime.now()
2376         now_str = now.strftime('%Y-%m-%d %H:%M')
2377         return name + ' ' + now_str
2378
2379     def _int(self, v, name, fatal=False, **kwargs):
2380         res = int_or_none(v, **kwargs)
2381         if 'get_attr' in kwargs:
2382             print(getattr(v, kwargs['get_attr']))
2383         if res is None:
2384             msg = 'Failed to extract %s: Could not parse value %r' % (name, v)
2385             if fatal:
2386                 raise ExtractorError(msg)
2387             else:
2388                 self._downloader.report_warning(msg)
2389         return res
2390
2391     def _float(self, v, name, fatal=False, **kwargs):
2392         res = float_or_none(v, **kwargs)
2393         if res is None:
2394             msg = 'Failed to extract %s: Could not parse value %r' % (name, v)
2395             if fatal:
2396                 raise ExtractorError(msg)
2397             else:
2398                 self._downloader.report_warning(msg)
2399         return res
2400
2401     def _set_cookie(self, domain, name, value, expire_time=None):
2402         cookie = compat_cookiejar.Cookie(
2403             0, name, value, None, None, domain, None,
2404             None, '/', True, False, expire_time, '', None, None, None)
2405         self._downloader.cookiejar.set_cookie(cookie)
2406
2407     def _get_cookies(self, url):
2408         """ Return a compat_cookies.SimpleCookie with the cookies for the url """
2409         req = sanitized_Request(url)
2410         self._downloader.cookiejar.add_cookie_header(req)
2411         return compat_cookies.SimpleCookie(req.get_header('Cookie'))
2412
2413     def get_testcases(self, include_onlymatching=False):
2414         t = getattr(self, '_TEST', None)
2415         if t:
2416             assert not hasattr(self, '_TESTS'), \
2417                 '%s has _TEST and _TESTS' % type(self).__name__
2418             tests = [t]
2419         else:
2420             tests = getattr(self, '_TESTS', [])
2421         for t in tests:
2422             if not include_onlymatching and t.get('only_matching', False):
2423                 continue
2424             t['name'] = type(self).__name__[:-len('IE')]
2425             yield t
2426
2427     def is_suitable(self, age_limit):
2428         """ Test whether the extractor is generally suitable for the given
2429         age limit (i.e. pornographic sites are not, all others usually are) """
2430
2431         any_restricted = False
2432         for tc in self.get_testcases(include_onlymatching=False):
2433             if tc.get('playlist', []):
2434                 tc = tc['playlist'][0]
2435             is_restricted = age_restricted(
2436                 tc.get('info_dict', {}).get('age_limit'), age_limit)
2437             if not is_restricted:
2438                 return True
2439             any_restricted = any_restricted or is_restricted
2440         return not any_restricted
2441
2442     def extract_subtitles(self, *args, **kwargs):
2443         if (self._downloader.params.get('writesubtitles', False) or
2444                 self._downloader.params.get('listsubtitles')):
2445             return self._get_subtitles(*args, **kwargs)
2446         return {}
2447
2448     def _get_subtitles(self, *args, **kwargs):
2449         raise NotImplementedError('This method must be implemented by subclasses')
2450
2451     @staticmethod
2452     def _merge_subtitle_items(subtitle_list1, subtitle_list2):
2453         """ Merge subtitle items for one language. Items with duplicated URLs
2454         will be dropped. """
2455         list1_urls = set([item['url'] for item in subtitle_list1])
2456         ret = list(subtitle_list1)
2457         ret.extend([item for item in subtitle_list2 if item['url'] not in list1_urls])
2458         return ret
2459
2460     @classmethod
2461     def _merge_subtitles(cls, subtitle_dict1, subtitle_dict2):
2462         """ Merge two subtitle dictionaries, language by language. """
2463         ret = dict(subtitle_dict1)
2464         for lang in subtitle_dict2:
2465             ret[lang] = cls._merge_subtitle_items(subtitle_dict1.get(lang, []), subtitle_dict2[lang])
2466         return ret
2467
2468     def extract_automatic_captions(self, *args, **kwargs):
2469         if (self._downloader.params.get('writeautomaticsub', False) or
2470                 self._downloader.params.get('listsubtitles')):
2471             return self._get_automatic_captions(*args, **kwargs)
2472         return {}
2473
2474     def _get_automatic_captions(self, *args, **kwargs):
2475         raise NotImplementedError('This method must be implemented by subclasses')
2476
2477     def mark_watched(self, *args, **kwargs):
2478         if (self._downloader.params.get('mark_watched', False) and
2479                 (self._get_login_info()[0] is not None or
2480                     self._downloader.params.get('cookiefile') is not None)):
2481             self._mark_watched(*args, **kwargs)
2482
2483     def _mark_watched(self, *args, **kwargs):
2484         raise NotImplementedError('This method must be implemented by subclasses')
2485
2486     def geo_verification_headers(self):
2487         headers = {}
2488         geo_verification_proxy = self._downloader.params.get('geo_verification_proxy')
2489         if geo_verification_proxy:
2490             headers['Ytdl-request-proxy'] = geo_verification_proxy
2491         return headers
2492
2493     def _generic_id(self, url):
2494         return compat_urllib_parse_unquote(os.path.splitext(url.rstrip('/').split('/')[-1])[0])
2495
2496     def _generic_title(self, url):
2497         return compat_urllib_parse_unquote(os.path.splitext(url_basename(url))[0])
2498
2499
2500 class SearchInfoExtractor(InfoExtractor):
2501     """
2502     Base class for paged search queries extractors.
2503     They accept URLs in the format _SEARCH_KEY(|all|[0-9]):{query}
2504     Instances should define _SEARCH_KEY and _MAX_RESULTS.
2505     """
2506
2507     @classmethod
2508     def _make_valid_url(cls):
2509         return r'%s(?P<prefix>|[1-9][0-9]*|all):(?P<query>[\s\S]+)' % cls._SEARCH_KEY
2510
2511     @classmethod
2512     def suitable(cls, url):
2513         return re.match(cls._make_valid_url(), url) is not None
2514
2515     def _real_extract(self, query):
2516         mobj = re.match(self._make_valid_url(), query)
2517         if mobj is None:
2518             raise ExtractorError('Invalid search query "%s"' % query)
2519
2520         prefix = mobj.group('prefix')
2521         query = mobj.group('query')
2522         if prefix == '':
2523             return self._get_n_results(query, 1)
2524         elif prefix == 'all':
2525             return self._get_n_results(query, self._MAX_RESULTS)
2526         else:
2527             n = int(prefix)
2528             if n <= 0:
2529                 raise ExtractorError('invalid download number %s for query "%s"' % (n, query))
2530             elif n > self._MAX_RESULTS:
2531                 self._downloader.report_warning('%s returns max %i results (you requested %i)' % (self._SEARCH_KEY, self._MAX_RESULTS, n))
2532                 n = self._MAX_RESULTS
2533             return self._get_n_results(query, n)
2534
2535     def _get_n_results(self, query, n):
2536         """Get a specified number of results for a query"""
2537         raise NotImplementedError('This method must be implemented by subclasses')
2538
2539     @property
2540     def SEARCH_KEY(self):
2541         return self._SEARCH_KEY