[extractor/common] Rephrase comment
[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 tag it still sometimes may be present (see [1]
1401             # or vidio test in TestInfoExtractor.test_parse_m3u8_formats)
1402             # 1. http://www.vidio.com/watch/165683-dj_ambred-booyah-live-2015
1403             stream_name = last_stream_inf.get('NAME')
1404             if stream_name:
1405                 return stream_name
1406             # If there is no NAME in EXT-X-STREAM-INF it will be obtained
1407             # from corresponding rendition group
1408             stream_group_id = last_stream_inf.get('VIDEO')
1409             if not stream_group_id:
1410                 return
1411             stream_group = groups.get(stream_group_id)
1412             if not stream_group:
1413                 return stream_group_id
1414             rendition = stream_group[0]
1415             return rendition.get('NAME') or stream_group_id
1416
1417         for line in m3u8_doc.splitlines():
1418             if line.startswith('#EXT-X-STREAM-INF:'):
1419                 last_stream_inf = parse_m3u8_attributes(line)
1420             elif line.startswith('#EXT-X-MEDIA:'):
1421                 extract_media(line)
1422             elif line.startswith('#') or not line.strip():
1423                 continue
1424             else:
1425                 tbr = float_or_none(
1426                     last_stream_inf.get('AVERAGE-BANDWIDTH') or
1427                     last_stream_inf.get('BANDWIDTH'), scale=1000)
1428                 format_id = []
1429                 if m3u8_id:
1430                     format_id.append(m3u8_id)
1431                 stream_name = build_stream_name()
1432                 # Bandwidth of live streams may differ over time thus making
1433                 # format_id unpredictable. So it's better to keep provided
1434                 # format_id intact.
1435                 if not live:
1436                     format_id.append(stream_name if stream_name else '%d' % (tbr if tbr else len(formats)))
1437                 manifest_url = format_url(line.strip())
1438                 f = {
1439                     'format_id': '-'.join(format_id),
1440                     'url': manifest_url,
1441                     'manifest_url': manifest_url,
1442                     'tbr': tbr,
1443                     'ext': ext,
1444                     'fps': float_or_none(last_stream_inf.get('FRAME-RATE')),
1445                     'protocol': entry_protocol,
1446                     'preference': preference,
1447                 }
1448                 resolution = last_stream_inf.get('RESOLUTION')
1449                 if resolution:
1450                     mobj = re.search(r'(?P<width>\d+)[xX](?P<height>\d+)', resolution)
1451                     if mobj:
1452                         f['width'] = int(mobj.group('width'))
1453                         f['height'] = int(mobj.group('height'))
1454                 # Unified Streaming Platform
1455                 mobj = re.search(
1456                     r'audio.*?(?:%3D|=)(\d+)(?:-video.*?(?:%3D|=)(\d+))?', f['url'])
1457                 if mobj:
1458                     abr, vbr = mobj.groups()
1459                     abr, vbr = float_or_none(abr, 1000), float_or_none(vbr, 1000)
1460                     f.update({
1461                         'vbr': vbr,
1462                         'abr': abr,
1463                     })
1464                 codecs = parse_codecs(last_stream_inf.get('CODECS'))
1465                 f.update(codecs)
1466                 audio_group_id = last_stream_inf.get('AUDIO')
1467                 # As per [1, 4.3.4.1.1] any EXT-X-STREAM-INF tag which
1468                 # references a rendition group MUST have a CODECS attribute.
1469                 # However, this is not always respected, for example, [2]
1470                 # contains EXT-X-STREAM-INF tag which references AUDIO
1471                 # rendition group but does not have CODECS and despite
1472                 # referencing audio group an audio group, it represents
1473                 # a complete (with audio and video) format. So, for such cases
1474                 # we will ignore references to rendition groups and treat them
1475                 # as complete formats.
1476                 if audio_group_id and codecs and f.get('vcodec') != 'none':
1477                     audio_group = groups.get(audio_group_id)
1478                     if audio_group and audio_group[0].get('URI'):
1479                         # TODO: update acodec for audio only formats with
1480                         # the same GROUP-ID
1481                         f['acodec'] = 'none'
1482                 formats.append(f)
1483                 last_stream_inf = {}
1484         return formats
1485
1486     @staticmethod
1487     def _xpath_ns(path, namespace=None):
1488         if not namespace:
1489             return path
1490         out = []
1491         for c in path.split('/'):
1492             if not c or c == '.':
1493                 out.append(c)
1494             else:
1495                 out.append('{%s}%s' % (namespace, c))
1496         return '/'.join(out)
1497
1498     def _extract_smil_formats(self, smil_url, video_id, fatal=True, f4m_params=None, transform_source=None):
1499         smil = self._download_smil(smil_url, video_id, fatal=fatal, transform_source=transform_source)
1500
1501         if smil is False:
1502             assert not fatal
1503             return []
1504
1505         namespace = self._parse_smil_namespace(smil)
1506
1507         return self._parse_smil_formats(
1508             smil, smil_url, video_id, namespace=namespace, f4m_params=f4m_params)
1509
1510     def _extract_smil_info(self, smil_url, video_id, fatal=True, f4m_params=None):
1511         smil = self._download_smil(smil_url, video_id, fatal=fatal)
1512         if smil is False:
1513             return {}
1514         return self._parse_smil(smil, smil_url, video_id, f4m_params=f4m_params)
1515
1516     def _download_smil(self, smil_url, video_id, fatal=True, transform_source=None):
1517         return self._download_xml(
1518             smil_url, video_id, 'Downloading SMIL file',
1519             'Unable to download SMIL file', fatal=fatal, transform_source=transform_source)
1520
1521     def _parse_smil(self, smil, smil_url, video_id, f4m_params=None):
1522         namespace = self._parse_smil_namespace(smil)
1523
1524         formats = self._parse_smil_formats(
1525             smil, smil_url, video_id, namespace=namespace, f4m_params=f4m_params)
1526         subtitles = self._parse_smil_subtitles(smil, namespace=namespace)
1527
1528         video_id = os.path.splitext(url_basename(smil_url))[0]
1529         title = None
1530         description = None
1531         upload_date = None
1532         for meta in smil.findall(self._xpath_ns('./head/meta', namespace)):
1533             name = meta.attrib.get('name')
1534             content = meta.attrib.get('content')
1535             if not name or not content:
1536                 continue
1537             if not title and name == 'title':
1538                 title = content
1539             elif not description and name in ('description', 'abstract'):
1540                 description = content
1541             elif not upload_date and name == 'date':
1542                 upload_date = unified_strdate(content)
1543
1544         thumbnails = [{
1545             'id': image.get('type'),
1546             'url': image.get('src'),
1547             'width': int_or_none(image.get('width')),
1548             'height': int_or_none(image.get('height')),
1549         } for image in smil.findall(self._xpath_ns('.//image', namespace)) if image.get('src')]
1550
1551         return {
1552             'id': video_id,
1553             'title': title or video_id,
1554             'description': description,
1555             'upload_date': upload_date,
1556             'thumbnails': thumbnails,
1557             'formats': formats,
1558             'subtitles': subtitles,
1559         }
1560
1561     def _parse_smil_namespace(self, smil):
1562         return self._search_regex(
1563             r'(?i)^{([^}]+)?}smil$', smil.tag, 'namespace', default=None)
1564
1565     def _parse_smil_formats(self, smil, smil_url, video_id, namespace=None, f4m_params=None, transform_rtmp_url=None):
1566         base = smil_url
1567         for meta in smil.findall(self._xpath_ns('./head/meta', namespace)):
1568             b = meta.get('base') or meta.get('httpBase')
1569             if b:
1570                 base = b
1571                 break
1572
1573         formats = []
1574         rtmp_count = 0
1575         http_count = 0
1576         m3u8_count = 0
1577
1578         srcs = []
1579         media = smil.findall(self._xpath_ns('.//video', namespace)) + smil.findall(self._xpath_ns('.//audio', namespace))
1580         for medium in media:
1581             src = medium.get('src')
1582             if not src or src in srcs:
1583                 continue
1584             srcs.append(src)
1585
1586             bitrate = float_or_none(medium.get('system-bitrate') or medium.get('systemBitrate'), 1000)
1587             filesize = int_or_none(medium.get('size') or medium.get('fileSize'))
1588             width = int_or_none(medium.get('width'))
1589             height = int_or_none(medium.get('height'))
1590             proto = medium.get('proto')
1591             ext = medium.get('ext')
1592             src_ext = determine_ext(src)
1593             streamer = medium.get('streamer') or base
1594
1595             if proto == 'rtmp' or streamer.startswith('rtmp'):
1596                 rtmp_count += 1
1597                 formats.append({
1598                     'url': streamer,
1599                     'play_path': src,
1600                     'ext': 'flv',
1601                     'format_id': 'rtmp-%d' % (rtmp_count if bitrate is None else bitrate),
1602                     'tbr': bitrate,
1603                     'filesize': filesize,
1604                     'width': width,
1605                     'height': height,
1606                 })
1607                 if transform_rtmp_url:
1608                     streamer, src = transform_rtmp_url(streamer, src)
1609                     formats[-1].update({
1610                         'url': streamer,
1611                         'play_path': src,
1612                     })
1613                 continue
1614
1615             src_url = src if src.startswith('http') else compat_urlparse.urljoin(base, src)
1616             src_url = src_url.strip()
1617
1618             if proto == 'm3u8' or src_ext == 'm3u8':
1619                 m3u8_formats = self._extract_m3u8_formats(
1620                     src_url, video_id, ext or 'mp4', m3u8_id='hls', fatal=False)
1621                 if len(m3u8_formats) == 1:
1622                     m3u8_count += 1
1623                     m3u8_formats[0].update({
1624                         'format_id': 'hls-%d' % (m3u8_count if bitrate is None else bitrate),
1625                         'tbr': bitrate,
1626                         'width': width,
1627                         'height': height,
1628                     })
1629                 formats.extend(m3u8_formats)
1630                 continue
1631
1632             if src_ext == 'f4m':
1633                 f4m_url = src_url
1634                 if not f4m_params:
1635                     f4m_params = {
1636                         'hdcore': '3.2.0',
1637                         'plugin': 'flowplayer-3.2.0.1',
1638                     }
1639                 f4m_url += '&' if '?' in f4m_url else '?'
1640                 f4m_url += compat_urllib_parse_urlencode(f4m_params)
1641                 formats.extend(self._extract_f4m_formats(f4m_url, video_id, f4m_id='hds', fatal=False))
1642                 continue
1643
1644             if src_url.startswith('http') and self._is_valid_url(src, video_id):
1645                 http_count += 1
1646                 formats.append({
1647                     'url': src_url,
1648                     'ext': ext or src_ext or 'flv',
1649                     'format_id': 'http-%d' % (bitrate or http_count),
1650                     'tbr': bitrate,
1651                     'filesize': filesize,
1652                     'width': width,
1653                     'height': height,
1654                 })
1655                 continue
1656
1657         return formats
1658
1659     def _parse_smil_subtitles(self, smil, namespace=None, subtitles_lang='en'):
1660         urls = []
1661         subtitles = {}
1662         for num, textstream in enumerate(smil.findall(self._xpath_ns('.//textstream', namespace))):
1663             src = textstream.get('src')
1664             if not src or src in urls:
1665                 continue
1666             urls.append(src)
1667             ext = textstream.get('ext') or mimetype2ext(textstream.get('type')) or determine_ext(src)
1668             lang = textstream.get('systemLanguage') or textstream.get('systemLanguageName') or textstream.get('lang') or subtitles_lang
1669             subtitles.setdefault(lang, []).append({
1670                 'url': src,
1671                 'ext': ext,
1672             })
1673         return subtitles
1674
1675     def _extract_xspf_playlist(self, playlist_url, playlist_id, fatal=True):
1676         xspf = self._download_xml(
1677             playlist_url, playlist_id, 'Downloading xpsf playlist',
1678             'Unable to download xspf manifest', fatal=fatal)
1679         if xspf is False:
1680             return []
1681         return self._parse_xspf(xspf, playlist_id)
1682
1683     def _parse_xspf(self, playlist, playlist_id):
1684         NS_MAP = {
1685             'xspf': 'http://xspf.org/ns/0/',
1686             's1': 'http://static.streamone.nl/player/ns/0',
1687         }
1688
1689         entries = []
1690         for track in playlist.findall(xpath_with_ns('./xspf:trackList/xspf:track', NS_MAP)):
1691             title = xpath_text(
1692                 track, xpath_with_ns('./xspf:title', NS_MAP), 'title', default=playlist_id)
1693             description = xpath_text(
1694                 track, xpath_with_ns('./xspf:annotation', NS_MAP), 'description')
1695             thumbnail = xpath_text(
1696                 track, xpath_with_ns('./xspf:image', NS_MAP), 'thumbnail')
1697             duration = float_or_none(
1698                 xpath_text(track, xpath_with_ns('./xspf:duration', NS_MAP), 'duration'), 1000)
1699
1700             formats = [{
1701                 'url': location.text,
1702                 'format_id': location.get(xpath_with_ns('s1:label', NS_MAP)),
1703                 'width': int_or_none(location.get(xpath_with_ns('s1:width', NS_MAP))),
1704                 'height': int_or_none(location.get(xpath_with_ns('s1:height', NS_MAP))),
1705             } for location in track.findall(xpath_with_ns('./xspf:location', NS_MAP))]
1706             self._sort_formats(formats)
1707
1708             entries.append({
1709                 'id': playlist_id,
1710                 'title': title,
1711                 'description': description,
1712                 'thumbnail': thumbnail,
1713                 'duration': duration,
1714                 'formats': formats,
1715             })
1716         return entries
1717
1718     def _extract_mpd_formats(self, mpd_url, video_id, mpd_id=None, note=None, errnote=None, fatal=True, formats_dict={}):
1719         res = self._download_webpage_handle(
1720             mpd_url, video_id,
1721             note=note or 'Downloading MPD manifest',
1722             errnote=errnote or 'Failed to download MPD manifest',
1723             fatal=fatal)
1724         if res is False:
1725             return []
1726         mpd, urlh = res
1727         mpd_base_url = base_url(urlh.geturl())
1728
1729         return self._parse_mpd_formats(
1730             compat_etree_fromstring(mpd.encode('utf-8')), mpd_id, mpd_base_url,
1731             formats_dict=formats_dict, mpd_url=mpd_url)
1732
1733     def _parse_mpd_formats(self, mpd_doc, mpd_id=None, mpd_base_url='', formats_dict={}, mpd_url=None):
1734         """
1735         Parse formats from MPD manifest.
1736         References:
1737          1. MPEG-DASH Standard, ISO/IEC 23009-1:2014(E),
1738             http://standards.iso.org/ittf/PubliclyAvailableStandards/c065274_ISO_IEC_23009-1_2014.zip
1739          2. https://en.wikipedia.org/wiki/Dynamic_Adaptive_Streaming_over_HTTP
1740         """
1741         if mpd_doc.get('type') == 'dynamic':
1742             return []
1743
1744         namespace = self._search_regex(r'(?i)^{([^}]+)?}MPD$', mpd_doc.tag, 'namespace', default=None)
1745
1746         def _add_ns(path):
1747             return self._xpath_ns(path, namespace)
1748
1749         def is_drm_protected(element):
1750             return element.find(_add_ns('ContentProtection')) is not None
1751
1752         def extract_multisegment_info(element, ms_parent_info):
1753             ms_info = ms_parent_info.copy()
1754
1755             # As per [1, 5.3.9.2.2] SegmentList and SegmentTemplate share some
1756             # common attributes and elements.  We will only extract relevant
1757             # for us.
1758             def extract_common(source):
1759                 segment_timeline = source.find(_add_ns('SegmentTimeline'))
1760                 if segment_timeline is not None:
1761                     s_e = segment_timeline.findall(_add_ns('S'))
1762                     if s_e:
1763                         ms_info['total_number'] = 0
1764                         ms_info['s'] = []
1765                         for s in s_e:
1766                             r = int(s.get('r', 0))
1767                             ms_info['total_number'] += 1 + r
1768                             ms_info['s'].append({
1769                                 't': int(s.get('t', 0)),
1770                                 # @d is mandatory (see [1, 5.3.9.6.2, Table 17, page 60])
1771                                 'd': int(s.attrib['d']),
1772                                 'r': r,
1773                             })
1774                 start_number = source.get('startNumber')
1775                 if start_number:
1776                     ms_info['start_number'] = int(start_number)
1777                 timescale = source.get('timescale')
1778                 if timescale:
1779                     ms_info['timescale'] = int(timescale)
1780                 segment_duration = source.get('duration')
1781                 if segment_duration:
1782                     ms_info['segment_duration'] = int(segment_duration)
1783
1784             def extract_Initialization(source):
1785                 initialization = source.find(_add_ns('Initialization'))
1786                 if initialization is not None:
1787                     ms_info['initialization_url'] = initialization.attrib['sourceURL']
1788
1789             segment_list = element.find(_add_ns('SegmentList'))
1790             if segment_list is not None:
1791                 extract_common(segment_list)
1792                 extract_Initialization(segment_list)
1793                 segment_urls_e = segment_list.findall(_add_ns('SegmentURL'))
1794                 if segment_urls_e:
1795                     ms_info['segment_urls'] = [segment.attrib['media'] for segment in segment_urls_e]
1796             else:
1797                 segment_template = element.find(_add_ns('SegmentTemplate'))
1798                 if segment_template is not None:
1799                     extract_common(segment_template)
1800                     media = segment_template.get('media')
1801                     if media:
1802                         ms_info['media'] = media
1803                     initialization = segment_template.get('initialization')
1804                     if initialization:
1805                         ms_info['initialization'] = initialization
1806                     else:
1807                         extract_Initialization(segment_template)
1808             return ms_info
1809
1810         mpd_duration = parse_duration(mpd_doc.get('mediaPresentationDuration'))
1811         formats = []
1812         for period in mpd_doc.findall(_add_ns('Period')):
1813             period_duration = parse_duration(period.get('duration')) or mpd_duration
1814             period_ms_info = extract_multisegment_info(period, {
1815                 'start_number': 1,
1816                 'timescale': 1,
1817             })
1818             for adaptation_set in period.findall(_add_ns('AdaptationSet')):
1819                 if is_drm_protected(adaptation_set):
1820                     continue
1821                 adaption_set_ms_info = extract_multisegment_info(adaptation_set, period_ms_info)
1822                 for representation in adaptation_set.findall(_add_ns('Representation')):
1823                     if is_drm_protected(representation):
1824                         continue
1825                     representation_attrib = adaptation_set.attrib.copy()
1826                     representation_attrib.update(representation.attrib)
1827                     # According to [1, 5.3.7.2, Table 9, page 41], @mimeType is mandatory
1828                     mime_type = representation_attrib['mimeType']
1829                     content_type = mime_type.split('/')[0]
1830                     if content_type == 'text':
1831                         # TODO implement WebVTT downloading
1832                         pass
1833                     elif content_type in ('video', 'audio'):
1834                         base_url = ''
1835                         for element in (representation, adaptation_set, period, mpd_doc):
1836                             base_url_e = element.find(_add_ns('BaseURL'))
1837                             if base_url_e is not None:
1838                                 base_url = base_url_e.text + base_url
1839                                 if re.match(r'^https?://', base_url):
1840                                     break
1841                         if mpd_base_url and not re.match(r'^https?://', base_url):
1842                             if not mpd_base_url.endswith('/') and not base_url.startswith('/'):
1843                                 mpd_base_url += '/'
1844                             base_url = mpd_base_url + base_url
1845                         representation_id = representation_attrib.get('id')
1846                         lang = representation_attrib.get('lang')
1847                         url_el = representation.find(_add_ns('BaseURL'))
1848                         filesize = int_or_none(url_el.attrib.get('{http://youtube.com/yt/2012/10/10}contentLength') if url_el is not None else None)
1849                         bandwidth = int_or_none(representation_attrib.get('bandwidth'))
1850                         f = {
1851                             'format_id': '%s-%s' % (mpd_id, representation_id) if mpd_id else representation_id,
1852                             'url': base_url,
1853                             'manifest_url': mpd_url,
1854                             'ext': mimetype2ext(mime_type),
1855                             'width': int_or_none(representation_attrib.get('width')),
1856                             'height': int_or_none(representation_attrib.get('height')),
1857                             'tbr': float_or_none(bandwidth, 1000),
1858                             'asr': int_or_none(representation_attrib.get('audioSamplingRate')),
1859                             'fps': int_or_none(representation_attrib.get('frameRate')),
1860                             'language': lang if lang not in ('mul', 'und', 'zxx', 'mis') else None,
1861                             'format_note': 'DASH %s' % content_type,
1862                             'filesize': filesize,
1863                         }
1864                         f.update(parse_codecs(representation_attrib.get('codecs')))
1865                         representation_ms_info = extract_multisegment_info(representation, adaption_set_ms_info)
1866
1867                         def prepare_template(template_name, identifiers):
1868                             t = representation_ms_info[template_name]
1869                             t = t.replace('$RepresentationID$', representation_id)
1870                             t = re.sub(r'\$(%s)\$' % '|'.join(identifiers), r'%(\1)d', t)
1871                             t = re.sub(r'\$(%s)%%([^$]+)\$' % '|'.join(identifiers), r'%(\1)\2', t)
1872                             t.replace('$$', '$')
1873                             return t
1874
1875                         # @initialization is a regular template like @media one
1876                         # so it should be handled just the same way (see
1877                         # https://github.com/rg3/youtube-dl/issues/11605)
1878                         if 'initialization' in representation_ms_info:
1879                             initialization_template = prepare_template(
1880                                 'initialization',
1881                                 # As per [1, 5.3.9.4.2, Table 15, page 54] $Number$ and
1882                                 # $Time$ shall not be included for @initialization thus
1883                                 # only $Bandwidth$ remains
1884                                 ('Bandwidth', ))
1885                             representation_ms_info['initialization_url'] = initialization_template % {
1886                                 'Bandwidth': bandwidth,
1887                             }
1888
1889                         if 'segment_urls' not in representation_ms_info and 'media' in representation_ms_info:
1890
1891                             media_template = prepare_template('media', ('Number', 'Bandwidth', 'Time'))
1892
1893                             # As per [1, 5.3.9.4.4, Table 16, page 55] $Number$ and $Time$
1894                             # can't be used at the same time
1895                             if '%(Number' in media_template and 's' not in representation_ms_info:
1896                                 segment_duration = None
1897                                 if 'total_number' not in representation_ms_info and 'segment_duration':
1898                                     segment_duration = float_or_none(representation_ms_info['segment_duration'], representation_ms_info['timescale'])
1899                                     representation_ms_info['total_number'] = int(math.ceil(float(period_duration) / segment_duration))
1900                                 representation_ms_info['fragments'] = [{
1901                                     'url': media_template % {
1902                                         'Number': segment_number,
1903                                         'Bandwidth': bandwidth,
1904                                     },
1905                                     'duration': segment_duration,
1906                                 } for segment_number in range(
1907                                     representation_ms_info['start_number'],
1908                                     representation_ms_info['total_number'] + representation_ms_info['start_number'])]
1909                             else:
1910                                 # $Number*$ or $Time$ in media template with S list available
1911                                 # Example $Number*$: http://www.svtplay.se/klipp/9023742/stopptid-om-bjorn-borg
1912                                 # Example $Time$: https://play.arkena.com/embed/avp/v2/player/media/b41dda37-d8e7-4d3f-b1b5-9a9db578bdfe/1/129411
1913                                 representation_ms_info['fragments'] = []
1914                                 segment_time = 0
1915                                 segment_d = None
1916                                 segment_number = representation_ms_info['start_number']
1917
1918                                 def add_segment_url():
1919                                     segment_url = media_template % {
1920                                         'Time': segment_time,
1921                                         'Bandwidth': bandwidth,
1922                                         'Number': segment_number,
1923                                     }
1924                                     representation_ms_info['fragments'].append({
1925                                         'url': segment_url,
1926                                         'duration': float_or_none(segment_d, representation_ms_info['timescale']),
1927                                     })
1928
1929                                 for num, s in enumerate(representation_ms_info['s']):
1930                                     segment_time = s.get('t') or segment_time
1931                                     segment_d = s['d']
1932                                     add_segment_url()
1933                                     segment_number += 1
1934                                     for r in range(s.get('r', 0)):
1935                                         segment_time += segment_d
1936                                         add_segment_url()
1937                                         segment_number += 1
1938                                     segment_time += segment_d
1939                         elif 'segment_urls' in representation_ms_info and 's' in representation_ms_info:
1940                             # No media template
1941                             # Example: https://www.youtube.com/watch?v=iXZV5uAYMJI
1942                             # or any YouTube dashsegments video
1943                             fragments = []
1944                             segment_index = 0
1945                             timescale = representation_ms_info['timescale']
1946                             for s in representation_ms_info['s']:
1947                                 duration = float_or_none(s['d'], timescale)
1948                                 for r in range(s.get('r', 0) + 1):
1949                                     fragments.append({
1950                                         'url': representation_ms_info['segment_urls'][segment_index],
1951                                         'duration': duration,
1952                                     })
1953                                     segment_index += 1
1954                             representation_ms_info['fragments'] = fragments
1955                         # NB: MPD manifest may contain direct URLs to unfragmented media.
1956                         # No fragments key is present in this case.
1957                         if 'fragments' in representation_ms_info:
1958                             f.update({
1959                                 'fragments': [],
1960                                 'protocol': 'http_dash_segments',
1961                             })
1962                             if 'initialization_url' in representation_ms_info:
1963                                 initialization_url = representation_ms_info['initialization_url']
1964                                 if not f.get('url'):
1965                                     f['url'] = initialization_url
1966                                 f['fragments'].append({'url': initialization_url})
1967                             f['fragments'].extend(representation_ms_info['fragments'])
1968                             for fragment in f['fragments']:
1969                                 fragment['url'] = urljoin(base_url, fragment['url'])
1970                         try:
1971                             existing_format = next(
1972                                 fo for fo in formats
1973                                 if fo['format_id'] == representation_id)
1974                         except StopIteration:
1975                             full_info = formats_dict.get(representation_id, {}).copy()
1976                             full_info.update(f)
1977                             formats.append(full_info)
1978                         else:
1979                             existing_format.update(f)
1980                     else:
1981                         self.report_warning('Unknown MIME type %s in DASH manifest' % mime_type)
1982         return formats
1983
1984     def _extract_ism_formats(self, ism_url, video_id, ism_id=None, note=None, errnote=None, fatal=True):
1985         res = self._download_webpage_handle(
1986             ism_url, video_id,
1987             note=note or 'Downloading ISM manifest',
1988             errnote=errnote or 'Failed to download ISM manifest',
1989             fatal=fatal)
1990         if res is False:
1991             return []
1992         ism, urlh = res
1993
1994         return self._parse_ism_formats(
1995             compat_etree_fromstring(ism.encode('utf-8')), urlh.geturl(), ism_id)
1996
1997     def _parse_ism_formats(self, ism_doc, ism_url, ism_id=None):
1998         if ism_doc.get('IsLive') == 'TRUE' or ism_doc.find('Protection') is not None:
1999             return []
2000
2001         duration = int(ism_doc.attrib['Duration'])
2002         timescale = int_or_none(ism_doc.get('TimeScale')) or 10000000
2003
2004         formats = []
2005         for stream in ism_doc.findall('StreamIndex'):
2006             stream_type = stream.get('Type')
2007             if stream_type not in ('video', 'audio'):
2008                 continue
2009             url_pattern = stream.attrib['Url']
2010             stream_timescale = int_or_none(stream.get('TimeScale')) or timescale
2011             stream_name = stream.get('Name')
2012             for track in stream.findall('QualityLevel'):
2013                 fourcc = track.get('FourCC')
2014                 # TODO: add support for WVC1 and WMAP
2015                 if fourcc not in ('H264', 'AVC1', 'AACL'):
2016                     self.report_warning('%s is not a supported codec' % fourcc)
2017                     continue
2018                 tbr = int(track.attrib['Bitrate']) // 1000
2019                 width = int_or_none(track.get('MaxWidth'))
2020                 height = int_or_none(track.get('MaxHeight'))
2021                 sampling_rate = int_or_none(track.get('SamplingRate'))
2022
2023                 track_url_pattern = re.sub(r'{[Bb]itrate}', track.attrib['Bitrate'], url_pattern)
2024                 track_url_pattern = compat_urlparse.urljoin(ism_url, track_url_pattern)
2025
2026                 fragments = []
2027                 fragment_ctx = {
2028                     'time': 0,
2029                 }
2030                 stream_fragments = stream.findall('c')
2031                 for stream_fragment_index, stream_fragment in enumerate(stream_fragments):
2032                     fragment_ctx['time'] = int_or_none(stream_fragment.get('t')) or fragment_ctx['time']
2033                     fragment_repeat = int_or_none(stream_fragment.get('r')) or 1
2034                     fragment_ctx['duration'] = int_or_none(stream_fragment.get('d'))
2035                     if not fragment_ctx['duration']:
2036                         try:
2037                             next_fragment_time = int(stream_fragment[stream_fragment_index + 1].attrib['t'])
2038                         except IndexError:
2039                             next_fragment_time = duration
2040                         fragment_ctx['duration'] = (next_fragment_time - fragment_ctx['time']) / fragment_repeat
2041                     for _ in range(fragment_repeat):
2042                         fragments.append({
2043                             'url': re.sub(r'{start[ _]time}', compat_str(fragment_ctx['time']), track_url_pattern),
2044                             'duration': fragment_ctx['duration'] / stream_timescale,
2045                         })
2046                         fragment_ctx['time'] += fragment_ctx['duration']
2047
2048                 format_id = []
2049                 if ism_id:
2050                     format_id.append(ism_id)
2051                 if stream_name:
2052                     format_id.append(stream_name)
2053                 format_id.append(compat_str(tbr))
2054
2055                 formats.append({
2056                     'format_id': '-'.join(format_id),
2057                     'url': ism_url,
2058                     'manifest_url': ism_url,
2059                     'ext': 'ismv' if stream_type == 'video' else 'isma',
2060                     'width': width,
2061                     'height': height,
2062                     'tbr': tbr,
2063                     'asr': sampling_rate,
2064                     'vcodec': 'none' if stream_type == 'audio' else fourcc,
2065                     'acodec': 'none' if stream_type == 'video' else fourcc,
2066                     'protocol': 'ism',
2067                     'fragments': fragments,
2068                     '_download_params': {
2069                         'duration': duration,
2070                         'timescale': stream_timescale,
2071                         'width': width or 0,
2072                         'height': height or 0,
2073                         'fourcc': fourcc,
2074                         'codec_private_data': track.get('CodecPrivateData'),
2075                         'sampling_rate': sampling_rate,
2076                         'channels': int_or_none(track.get('Channels', 2)),
2077                         'bits_per_sample': int_or_none(track.get('BitsPerSample', 16)),
2078                         'nal_unit_length_field': int_or_none(track.get('NALUnitLengthField', 4)),
2079                     },
2080                 })
2081         return formats
2082
2083     def _parse_html5_media_entries(self, base_url, webpage, video_id, m3u8_id=None, m3u8_entry_protocol='m3u8', mpd_id=None, preference=None):
2084         def absolute_url(video_url):
2085             return compat_urlparse.urljoin(base_url, video_url)
2086
2087         def parse_content_type(content_type):
2088             if not content_type:
2089                 return {}
2090             ctr = re.search(r'(?P<mimetype>[^/]+/[^;]+)(?:;\s*codecs="?(?P<codecs>[^"]+))?', content_type)
2091             if ctr:
2092                 mimetype, codecs = ctr.groups()
2093                 f = parse_codecs(codecs)
2094                 f['ext'] = mimetype2ext(mimetype)
2095                 return f
2096             return {}
2097
2098         def _media_formats(src, cur_media_type):
2099             full_url = absolute_url(src)
2100             ext = determine_ext(full_url)
2101             if ext == 'm3u8':
2102                 is_plain_url = False
2103                 formats = self._extract_m3u8_formats(
2104                     full_url, video_id, ext='mp4',
2105                     entry_protocol=m3u8_entry_protocol, m3u8_id=m3u8_id,
2106                     preference=preference)
2107             elif ext == 'mpd':
2108                 is_plain_url = False
2109                 formats = self._extract_mpd_formats(
2110                     full_url, video_id, mpd_id=mpd_id)
2111             else:
2112                 is_plain_url = True
2113                 formats = [{
2114                     'url': full_url,
2115                     'vcodec': 'none' if cur_media_type == 'audio' else None,
2116                 }]
2117             return is_plain_url, formats
2118
2119         entries = []
2120         media_tags = [(media_tag, media_type, '')
2121                       for media_tag, media_type
2122                       in re.findall(r'(?s)(<(video|audio)[^>]*/>)', webpage)]
2123         media_tags.extend(re.findall(
2124             # We only allow video|audio followed by a whitespace or '>'.
2125             # Allowing more characters may end up in significant slow down (see
2126             # https://github.com/rg3/youtube-dl/issues/11979, example URL:
2127             # http://www.porntrex.com/maps/videositemap.xml).
2128             r'(?s)(<(?P<tag>video|audio)(?:\s+[^>]*)?>)(.*?)</(?P=tag)>', webpage))
2129         for media_tag, media_type, media_content in media_tags:
2130             media_info = {
2131                 'formats': [],
2132                 'subtitles': {},
2133             }
2134             media_attributes = extract_attributes(media_tag)
2135             src = media_attributes.get('src')
2136             if src:
2137                 _, formats = _media_formats(src, media_type)
2138                 media_info['formats'].extend(formats)
2139             media_info['thumbnail'] = media_attributes.get('poster')
2140             if media_content:
2141                 for source_tag in re.findall(r'<source[^>]+>', media_content):
2142                     source_attributes = extract_attributes(source_tag)
2143                     src = source_attributes.get('src')
2144                     if not src:
2145                         continue
2146                     is_plain_url, formats = _media_formats(src, media_type)
2147                     if is_plain_url:
2148                         f = parse_content_type(source_attributes.get('type'))
2149                         f.update(formats[0])
2150                         media_info['formats'].append(f)
2151                     else:
2152                         media_info['formats'].extend(formats)
2153                 for track_tag in re.findall(r'<track[^>]+>', media_content):
2154                     track_attributes = extract_attributes(track_tag)
2155                     kind = track_attributes.get('kind')
2156                     if not kind or kind in ('subtitles', 'captions'):
2157                         src = track_attributes.get('src')
2158                         if not src:
2159                             continue
2160                         lang = track_attributes.get('srclang') or track_attributes.get('lang') or track_attributes.get('label')
2161                         media_info['subtitles'].setdefault(lang, []).append({
2162                             'url': absolute_url(src),
2163                         })
2164             if media_info['formats'] or media_info['subtitles']:
2165                 entries.append(media_info)
2166         return entries
2167
2168     def _extract_akamai_formats(self, manifest_url, video_id, hosts={}):
2169         formats = []
2170         hdcore_sign = 'hdcore=3.7.0'
2171         f4m_url = re.sub(r'(https?://[^/+])/i/', r'\1/z/', manifest_url).replace('/master.m3u8', '/manifest.f4m')
2172         hds_host = hosts.get('hds')
2173         if hds_host:
2174             f4m_url = re.sub(r'(https?://)[^/]+', r'\1' + hds_host, f4m_url)
2175         if 'hdcore=' not in f4m_url:
2176             f4m_url += ('&' if '?' in f4m_url else '?') + hdcore_sign
2177         f4m_formats = self._extract_f4m_formats(
2178             f4m_url, video_id, f4m_id='hds', fatal=False)
2179         for entry in f4m_formats:
2180             entry.update({'extra_param_to_segment_url': hdcore_sign})
2181         formats.extend(f4m_formats)
2182         m3u8_url = re.sub(r'(https?://[^/]+)/z/', r'\1/i/', manifest_url).replace('/manifest.f4m', '/master.m3u8')
2183         hls_host = hosts.get('hls')
2184         if hls_host:
2185             m3u8_url = re.sub(r'(https?://)[^/]+', r'\1' + hls_host, m3u8_url)
2186         formats.extend(self._extract_m3u8_formats(
2187             m3u8_url, video_id, 'mp4', 'm3u8_native',
2188             m3u8_id='hls', fatal=False))
2189         return formats
2190
2191     def _extract_wowza_formats(self, url, video_id, m3u8_entry_protocol='m3u8_native', skip_protocols=[]):
2192         url = re.sub(r'/(?:manifest|playlist|jwplayer)\.(?:m3u8|f4m|mpd|smil)', '', url)
2193         url_base = self._search_regex(r'(?:https?|rtmp|rtsp)(://[^?]+)', url, 'format url')
2194         http_base_url = 'http' + url_base
2195         formats = []
2196         if 'm3u8' not in skip_protocols:
2197             formats.extend(self._extract_m3u8_formats(
2198                 http_base_url + '/playlist.m3u8', video_id, 'mp4',
2199                 m3u8_entry_protocol, m3u8_id='hls', fatal=False))
2200         if 'f4m' not in skip_protocols:
2201             formats.extend(self._extract_f4m_formats(
2202                 http_base_url + '/manifest.f4m',
2203                 video_id, f4m_id='hds', fatal=False))
2204         if 'dash' not in skip_protocols:
2205             formats.extend(self._extract_mpd_formats(
2206                 http_base_url + '/manifest.mpd',
2207                 video_id, mpd_id='dash', fatal=False))
2208         if re.search(r'(?:/smil:|\.smil)', url_base):
2209             if 'smil' not in skip_protocols:
2210                 rtmp_formats = self._extract_smil_formats(
2211                     http_base_url + '/jwplayer.smil',
2212                     video_id, fatal=False)
2213                 for rtmp_format in rtmp_formats:
2214                     rtsp_format = rtmp_format.copy()
2215                     rtsp_format['url'] = '%s/%s' % (rtmp_format['url'], rtmp_format['play_path'])
2216                     del rtsp_format['play_path']
2217                     del rtsp_format['ext']
2218                     rtsp_format.update({
2219                         'url': rtsp_format['url'].replace('rtmp://', 'rtsp://'),
2220                         'format_id': rtmp_format['format_id'].replace('rtmp', 'rtsp'),
2221                         'protocol': 'rtsp',
2222                     })
2223                     formats.extend([rtmp_format, rtsp_format])
2224         else:
2225             for protocol in ('rtmp', 'rtsp'):
2226                 if protocol not in skip_protocols:
2227                     formats.append({
2228                         'url': protocol + url_base,
2229                         'format_id': protocol,
2230                         'protocol': protocol,
2231                     })
2232         return formats
2233
2234     def _find_jwplayer_data(self, webpage, video_id=None, transform_source=js_to_json):
2235         mobj = re.search(
2236             r'(?s)jwplayer\((?P<quote>[\'"])[^\'" ]+(?P=quote)\).*?\.setup\s*\((?P<options>[^)]+)\)',
2237             webpage)
2238         if mobj:
2239             try:
2240                 jwplayer_data = self._parse_json(mobj.group('options'),
2241                                                  video_id=video_id,
2242                                                  transform_source=transform_source)
2243             except ExtractorError:
2244                 pass
2245             else:
2246                 if isinstance(jwplayer_data, dict):
2247                     return jwplayer_data
2248
2249     def _extract_jwplayer_data(self, webpage, video_id, *args, **kwargs):
2250         jwplayer_data = self._find_jwplayer_data(
2251             webpage, video_id, transform_source=js_to_json)
2252         return self._parse_jwplayer_data(
2253             jwplayer_data, video_id, *args, **kwargs)
2254
2255     def _parse_jwplayer_data(self, jwplayer_data, video_id=None, require_title=True,
2256                              m3u8_id=None, mpd_id=None, rtmp_params=None, base_url=None):
2257         # JWPlayer backward compatibility: flattened playlists
2258         # https://github.com/jwplayer/jwplayer/blob/v7.4.3/src/js/api/config.js#L81-L96
2259         if 'playlist' not in jwplayer_data:
2260             jwplayer_data = {'playlist': [jwplayer_data]}
2261
2262         entries = []
2263
2264         # JWPlayer backward compatibility: single playlist item
2265         # https://github.com/jwplayer/jwplayer/blob/v7.7.0/src/js/playlist/playlist.js#L10
2266         if not isinstance(jwplayer_data['playlist'], list):
2267             jwplayer_data['playlist'] = [jwplayer_data['playlist']]
2268
2269         for video_data in jwplayer_data['playlist']:
2270             # JWPlayer backward compatibility: flattened sources
2271             # https://github.com/jwplayer/jwplayer/blob/v7.4.3/src/js/playlist/item.js#L29-L35
2272             if 'sources' not in video_data:
2273                 video_data['sources'] = [video_data]
2274
2275             this_video_id = video_id or video_data['mediaid']
2276
2277             formats = self._parse_jwplayer_formats(
2278                 video_data['sources'], video_id=this_video_id, m3u8_id=m3u8_id,
2279                 mpd_id=mpd_id, rtmp_params=rtmp_params, base_url=base_url)
2280             self._sort_formats(formats)
2281
2282             subtitles = {}
2283             tracks = video_data.get('tracks')
2284             if tracks and isinstance(tracks, list):
2285                 for track in tracks:
2286                     if track.get('kind') != 'captions':
2287                         continue
2288                     track_url = urljoin(base_url, track.get('file'))
2289                     if not track_url:
2290                         continue
2291                     subtitles.setdefault(track.get('label') or 'en', []).append({
2292                         'url': self._proto_relative_url(track_url)
2293                     })
2294
2295             entries.append({
2296                 'id': this_video_id,
2297                 'title': video_data['title'] if require_title else video_data.get('title'),
2298                 'description': video_data.get('description'),
2299                 'thumbnail': self._proto_relative_url(video_data.get('image')),
2300                 'timestamp': int_or_none(video_data.get('pubdate')),
2301                 'duration': float_or_none(jwplayer_data.get('duration') or video_data.get('duration')),
2302                 'subtitles': subtitles,
2303                 'formats': formats,
2304             })
2305         if len(entries) == 1:
2306             return entries[0]
2307         else:
2308             return self.playlist_result(entries)
2309
2310     def _parse_jwplayer_formats(self, jwplayer_sources_data, video_id=None,
2311                                 m3u8_id=None, mpd_id=None, rtmp_params=None, base_url=None):
2312         urls = []
2313         formats = []
2314         for source in jwplayer_sources_data:
2315             source_url = self._proto_relative_url(source.get('file'))
2316             if not source_url:
2317                 continue
2318             if base_url:
2319                 source_url = compat_urlparse.urljoin(base_url, source_url)
2320             if source_url in urls:
2321                 continue
2322             urls.append(source_url)
2323             source_type = source.get('type') or ''
2324             ext = mimetype2ext(source_type) or determine_ext(source_url)
2325             if source_type == 'hls' or ext == 'm3u8':
2326                 formats.extend(self._extract_m3u8_formats(
2327                     source_url, video_id, 'mp4', entry_protocol='m3u8_native',
2328                     m3u8_id=m3u8_id, fatal=False))
2329             elif ext == 'mpd':
2330                 formats.extend(self._extract_mpd_formats(
2331                     source_url, video_id, mpd_id=mpd_id, fatal=False))
2332             elif ext == 'smil':
2333                 formats.extend(self._extract_smil_formats(
2334                     source_url, video_id, fatal=False))
2335             # https://github.com/jwplayer/jwplayer/blob/master/src/js/providers/default.js#L67
2336             elif source_type.startswith('audio') or ext in (
2337                     'oga', 'aac', 'mp3', 'mpeg', 'vorbis'):
2338                 formats.append({
2339                     'url': source_url,
2340                     'vcodec': 'none',
2341                     'ext': ext,
2342                 })
2343             else:
2344                 height = int_or_none(source.get('height'))
2345                 if height is None:
2346                     # Often no height is provided but there is a label in
2347                     # format like "1080p", "720p SD", or 1080.
2348                     height = int_or_none(self._search_regex(
2349                         r'^(\d{3,4})[pP]?(?:\b|$)', compat_str(source.get('label') or ''),
2350                         'height', default=None))
2351                 a_format = {
2352                     'url': source_url,
2353                     'width': int_or_none(source.get('width')),
2354                     'height': height,
2355                     'tbr': int_or_none(source.get('bitrate')),
2356                     'ext': ext,
2357                 }
2358                 if source_url.startswith('rtmp'):
2359                     a_format['ext'] = 'flv'
2360                     # See com/longtailvideo/jwplayer/media/RTMPMediaProvider.as
2361                     # of jwplayer.flash.swf
2362                     rtmp_url_parts = re.split(
2363                         r'((?:mp4|mp3|flv):)', source_url, 1)
2364                     if len(rtmp_url_parts) == 3:
2365                         rtmp_url, prefix, play_path = rtmp_url_parts
2366                         a_format.update({
2367                             'url': rtmp_url,
2368                             'play_path': prefix + play_path,
2369                         })
2370                     if rtmp_params:
2371                         a_format.update(rtmp_params)
2372                 formats.append(a_format)
2373         return formats
2374
2375     def _live_title(self, name):
2376         """ Generate the title for a live video """
2377         now = datetime.datetime.now()
2378         now_str = now.strftime('%Y-%m-%d %H:%M')
2379         return name + ' ' + now_str
2380
2381     def _int(self, v, name, fatal=False, **kwargs):
2382         res = int_or_none(v, **kwargs)
2383         if 'get_attr' in kwargs:
2384             print(getattr(v, kwargs['get_attr']))
2385         if res is None:
2386             msg = 'Failed to extract %s: Could not parse value %r' % (name, v)
2387             if fatal:
2388                 raise ExtractorError(msg)
2389             else:
2390                 self._downloader.report_warning(msg)
2391         return res
2392
2393     def _float(self, v, name, fatal=False, **kwargs):
2394         res = float_or_none(v, **kwargs)
2395         if res is None:
2396             msg = 'Failed to extract %s: Could not parse value %r' % (name, v)
2397             if fatal:
2398                 raise ExtractorError(msg)
2399             else:
2400                 self._downloader.report_warning(msg)
2401         return res
2402
2403     def _set_cookie(self, domain, name, value, expire_time=None):
2404         cookie = compat_cookiejar.Cookie(
2405             0, name, value, None, None, domain, None,
2406             None, '/', True, False, expire_time, '', None, None, None)
2407         self._downloader.cookiejar.set_cookie(cookie)
2408
2409     def _get_cookies(self, url):
2410         """ Return a compat_cookies.SimpleCookie with the cookies for the url """
2411         req = sanitized_Request(url)
2412         self._downloader.cookiejar.add_cookie_header(req)
2413         return compat_cookies.SimpleCookie(req.get_header('Cookie'))
2414
2415     def get_testcases(self, include_onlymatching=False):
2416         t = getattr(self, '_TEST', None)
2417         if t:
2418             assert not hasattr(self, '_TESTS'), \
2419                 '%s has _TEST and _TESTS' % type(self).__name__
2420             tests = [t]
2421         else:
2422             tests = getattr(self, '_TESTS', [])
2423         for t in tests:
2424             if not include_onlymatching and t.get('only_matching', False):
2425                 continue
2426             t['name'] = type(self).__name__[:-len('IE')]
2427             yield t
2428
2429     def is_suitable(self, age_limit):
2430         """ Test whether the extractor is generally suitable for the given
2431         age limit (i.e. pornographic sites are not, all others usually are) """
2432
2433         any_restricted = False
2434         for tc in self.get_testcases(include_onlymatching=False):
2435             if tc.get('playlist', []):
2436                 tc = tc['playlist'][0]
2437             is_restricted = age_restricted(
2438                 tc.get('info_dict', {}).get('age_limit'), age_limit)
2439             if not is_restricted:
2440                 return True
2441             any_restricted = any_restricted or is_restricted
2442         return not any_restricted
2443
2444     def extract_subtitles(self, *args, **kwargs):
2445         if (self._downloader.params.get('writesubtitles', False) or
2446                 self._downloader.params.get('listsubtitles')):
2447             return self._get_subtitles(*args, **kwargs)
2448         return {}
2449
2450     def _get_subtitles(self, *args, **kwargs):
2451         raise NotImplementedError('This method must be implemented by subclasses')
2452
2453     @staticmethod
2454     def _merge_subtitle_items(subtitle_list1, subtitle_list2):
2455         """ Merge subtitle items for one language. Items with duplicated URLs
2456         will be dropped. """
2457         list1_urls = set([item['url'] for item in subtitle_list1])
2458         ret = list(subtitle_list1)
2459         ret.extend([item for item in subtitle_list2 if item['url'] not in list1_urls])
2460         return ret
2461
2462     @classmethod
2463     def _merge_subtitles(cls, subtitle_dict1, subtitle_dict2):
2464         """ Merge two subtitle dictionaries, language by language. """
2465         ret = dict(subtitle_dict1)
2466         for lang in subtitle_dict2:
2467             ret[lang] = cls._merge_subtitle_items(subtitle_dict1.get(lang, []), subtitle_dict2[lang])
2468         return ret
2469
2470     def extract_automatic_captions(self, *args, **kwargs):
2471         if (self._downloader.params.get('writeautomaticsub', False) or
2472                 self._downloader.params.get('listsubtitles')):
2473             return self._get_automatic_captions(*args, **kwargs)
2474         return {}
2475
2476     def _get_automatic_captions(self, *args, **kwargs):
2477         raise NotImplementedError('This method must be implemented by subclasses')
2478
2479     def mark_watched(self, *args, **kwargs):
2480         if (self._downloader.params.get('mark_watched', False) and
2481                 (self._get_login_info()[0] is not None or
2482                     self._downloader.params.get('cookiefile') is not None)):
2483             self._mark_watched(*args, **kwargs)
2484
2485     def _mark_watched(self, *args, **kwargs):
2486         raise NotImplementedError('This method must be implemented by subclasses')
2487
2488     def geo_verification_headers(self):
2489         headers = {}
2490         geo_verification_proxy = self._downloader.params.get('geo_verification_proxy')
2491         if geo_verification_proxy:
2492             headers['Ytdl-request-proxy'] = geo_verification_proxy
2493         return headers
2494
2495     def _generic_id(self, url):
2496         return compat_urllib_parse_unquote(os.path.splitext(url.rstrip('/').split('/')[-1])[0])
2497
2498     def _generic_title(self, url):
2499         return compat_urllib_parse_unquote(os.path.splitext(url_basename(url))[0])
2500
2501
2502 class SearchInfoExtractor(InfoExtractor):
2503     """
2504     Base class for paged search queries extractors.
2505     They accept URLs in the format _SEARCH_KEY(|all|[0-9]):{query}
2506     Instances should define _SEARCH_KEY and _MAX_RESULTS.
2507     """
2508
2509     @classmethod
2510     def _make_valid_url(cls):
2511         return r'%s(?P<prefix>|[1-9][0-9]*|all):(?P<query>[\s\S]+)' % cls._SEARCH_KEY
2512
2513     @classmethod
2514     def suitable(cls, url):
2515         return re.match(cls._make_valid_url(), url) is not None
2516
2517     def _real_extract(self, query):
2518         mobj = re.match(self._make_valid_url(), query)
2519         if mobj is None:
2520             raise ExtractorError('Invalid search query "%s"' % query)
2521
2522         prefix = mobj.group('prefix')
2523         query = mobj.group('query')
2524         if prefix == '':
2525             return self._get_n_results(query, 1)
2526         elif prefix == 'all':
2527             return self._get_n_results(query, self._MAX_RESULTS)
2528         else:
2529             n = int(prefix)
2530             if n <= 0:
2531                 raise ExtractorError('invalid download number %s for query "%s"' % (n, query))
2532             elif n > self._MAX_RESULTS:
2533                 self._downloader.report_warning('%s returns max %i results (you requested %i)' % (self._SEARCH_KEY, self._MAX_RESULTS, n))
2534                 n = self._MAX_RESULTS
2535             return self._get_n_results(query, n)
2536
2537     def _get_n_results(self, query, n):
2538         """Get a specified number of results for a query"""
2539         raise NotImplementedError('This method must be implemented by subclasses')
2540
2541     @property
2542     def SEARCH_KEY(self):
2543         return self._SEARCH_KEY