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

780 lines
34 KiB

11 years ago
11 years ago
11 years ago
  1. #!/usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. from __future__ import absolute_import
  4. import errno
  5. import io
  6. import os
  7. import re
  8. import shutil
  9. import socket
  10. import sys
  11. import time
  12. import traceback
  13. from .utils import *
  14. from .extractor import get_info_extractor, gen_extractors
  15. from .FileDownloader import FileDownloader
  16. class YoutubeDL(object):
  17. """YoutubeDL class.
  18. YoutubeDL objects are the ones responsible of downloading the
  19. actual video file and writing it to disk if the user has requested
  20. it, among some other tasks. In most cases there should be one per
  21. program. As, given a video URL, the downloader doesn't know how to
  22. extract all the needed information, task that InfoExtractors do, it
  23. has to pass the URL to one of them.
  24. For this, YoutubeDL objects have a method that allows
  25. InfoExtractors to be registered in a given order. When it is passed
  26. a URL, the YoutubeDL object handles it to the first InfoExtractor it
  27. finds that reports being able to handle it. The InfoExtractor extracts
  28. all the information about the video or videos the URL refers to, and
  29. YoutubeDL process the extracted information, possibly using a File
  30. Downloader to download the video.
  31. YoutubeDL objects accept a lot of parameters. In order not to saturate
  32. the object constructor with arguments, it receives a dictionary of
  33. options instead. These options are available through the params
  34. attribute for the InfoExtractors to use. The YoutubeDL also
  35. registers itself as the downloader in charge for the InfoExtractors
  36. that are added to it, so this is a "mutual registration".
  37. Available options:
  38. username: Username for authentication purposes.
  39. password: Password for authentication purposes.
  40. videopassword: Password for acces a video.
  41. usenetrc: Use netrc for authentication instead.
  42. verbose: Print additional info to stdout.
  43. quiet: Do not print messages to stdout.
  44. forceurl: Force printing final URL.
  45. forcetitle: Force printing title.
  46. forceid: Force printing ID.
  47. forcethumbnail: Force printing thumbnail URL.
  48. forcedescription: Force printing description.
  49. forcefilename: Force printing final filename.
  50. simulate: Do not download the video files.
  51. format: Video format code.
  52. format_limit: Highest quality format to try.
  53. outtmpl: Template for output names.
  54. restrictfilenames: Do not allow "&" and spaces in file names
  55. ignoreerrors: Do not stop on download errors.
  56. nooverwrites: Prevent overwriting files.
  57. playliststart: Playlist item to start at.
  58. playlistend: Playlist item to end at.
  59. matchtitle: Download only matching titles.
  60. rejecttitle: Reject downloads for matching titles.
  61. logtostderr: Log messages to stderr instead of stdout.
  62. writedescription: Write the video description to a .description file
  63. writeinfojson: Write the video description to a .info.json file
  64. writeannotations: Write the video annotations to a .annotations.xml file
  65. writethumbnail: Write the thumbnail image to a file
  66. writesubtitles: Write the video subtitles to a file
  67. writeautomaticsub: Write the automatic subtitles to a file
  68. allsubtitles: Downloads all the subtitles of the video
  69. (requires writesubtitles or writeautomaticsub)
  70. listsubtitles: Lists all available subtitles for the video
  71. subtitlesformat: Subtitle format [srt/sbv/vtt] (default=srt)
  72. subtitleslangs: List of languages of the subtitles to download
  73. keepvideo: Keep the video file after post-processing
  74. daterange: A DateRange object, download only if the upload_date is in the range.
  75. skip_download: Skip the actual download of the video file
  76. cachedir: Location of the cache files in the filesystem.
  77. None to disable filesystem cache.
  78. noplaylist: Download single video instead of a playlist if in doubt.
  79. age_limit: An integer representing the user's age in years.
  80. Unsuitable videos for the given age are skipped.
  81. downloadarchive: File name of a file where all downloads are recorded.
  82. Videos already present in the file are not downloaded
  83. again.
  84. The following parameters are not used by YoutubeDL itself, they are used by
  85. the FileDownloader:
  86. nopart, updatetime, buffersize, ratelimit, min_filesize, max_filesize, test,
  87. noresizebuffer, retries, continuedl, noprogress, consoletitle
  88. """
  89. params = None
  90. _ies = []
  91. _pps = []
  92. _download_retcode = None
  93. _num_downloads = None
  94. _screen_file = None
  95. def __init__(self, params):
  96. """Create a FileDownloader object with the given options."""
  97. self._ies = []
  98. self._ies_instances = {}
  99. self._pps = []
  100. self._progress_hooks = []
  101. self._download_retcode = 0
  102. self._num_downloads = 0
  103. self._screen_file = [sys.stdout, sys.stderr][params.get('logtostderr', False)]
  104. if (sys.version_info >= (3,) and sys.platform != 'win32' and
  105. sys.getfilesystemencoding() in ['ascii', 'ANSI_X3.4-1968']
  106. and not params['restrictfilenames']):
  107. # On Python 3, the Unicode filesystem API will throw errors (#1474)
  108. self.report_warning(
  109. u'Assuming --restrict-filenames since file system encoding '
  110. u'cannot encode all charactes. '
  111. u'Set the LC_ALL environment variable to fix this.')
  112. params['restrictfilenames'] = True
  113. self.params = params
  114. self.fd = FileDownloader(self, self.params)
  115. if '%(stitle)s' in self.params['outtmpl']:
  116. self.report_warning(u'%(stitle)s is deprecated. Use the %(title)s and the --restrict-filenames flag(which also secures %(uploader)s et al) instead.')
  117. def add_info_extractor(self, ie):
  118. """Add an InfoExtractor object to the end of the list."""
  119. self._ies.append(ie)
  120. self._ies_instances[ie.ie_key()] = ie
  121. ie.set_downloader(self)
  122. def get_info_extractor(self, ie_key):
  123. """
  124. Get an instance of an IE with name ie_key, it will try to get one from
  125. the _ies list, if there's no instance it will create a new one and add
  126. it to the extractor list.
  127. """
  128. ie = self._ies_instances.get(ie_key)
  129. if ie is None:
  130. ie = get_info_extractor(ie_key)()
  131. self.add_info_extractor(ie)
  132. return ie
  133. def add_default_info_extractors(self):
  134. """
  135. Add the InfoExtractors returned by gen_extractors to the end of the list
  136. """
  137. for ie in gen_extractors():
  138. self.add_info_extractor(ie)
  139. def add_post_processor(self, pp):
  140. """Add a PostProcessor object to the end of the chain."""
  141. self._pps.append(pp)
  142. pp.set_downloader(self)
  143. def to_screen(self, message, skip_eol=False):
  144. """Print message to stdout if not in quiet mode."""
  145. if not self.params.get('quiet', False):
  146. terminator = [u'\n', u''][skip_eol]
  147. output = message + terminator
  148. write_string(output, self._screen_file)
  149. def to_stderr(self, message):
  150. """Print message to stderr."""
  151. assert type(message) == type(u'')
  152. output = message + u'\n'
  153. if 'b' in getattr(self._screen_file, 'mode', '') or sys.version_info[0] < 3: # Python 2 lies about the mode of sys.stdout/sys.stderr
  154. output = output.encode(preferredencoding())
  155. sys.stderr.write(output)
  156. def fixed_template(self):
  157. """Checks if the output template is fixed."""
  158. return (re.search(u'(?u)%\\(.+?\\)s', self.params['outtmpl']) is None)
  159. def trouble(self, message=None, tb=None):
  160. """Determine action to take when a download problem appears.
  161. Depending on if the downloader has been configured to ignore
  162. download errors or not, this method may throw an exception or
  163. not when errors are found, after printing the message.
  164. tb, if given, is additional traceback information.
  165. """
  166. if message is not None:
  167. self.to_stderr(message)
  168. if self.params.get('verbose'):
  169. if tb is None:
  170. if sys.exc_info()[0]: # if .trouble has been called from an except block
  171. tb = u''
  172. if hasattr(sys.exc_info()[1], 'exc_info') and sys.exc_info()[1].exc_info[0]:
  173. tb += u''.join(traceback.format_exception(*sys.exc_info()[1].exc_info))
  174. tb += compat_str(traceback.format_exc())
  175. else:
  176. tb_data = traceback.format_list(traceback.extract_stack())
  177. tb = u''.join(tb_data)
  178. self.to_stderr(tb)
  179. if not self.params.get('ignoreerrors', False):
  180. if sys.exc_info()[0] and hasattr(sys.exc_info()[1], 'exc_info') and sys.exc_info()[1].exc_info[0]:
  181. exc_info = sys.exc_info()[1].exc_info
  182. else:
  183. exc_info = sys.exc_info()
  184. raise DownloadError(message, exc_info)
  185. self._download_retcode = 1
  186. def report_warning(self, message):
  187. '''
  188. Print the message to stderr, it will be prefixed with 'WARNING:'
  189. If stderr is a tty file the 'WARNING:' will be colored
  190. '''
  191. if sys.stderr.isatty() and os.name != 'nt':
  192. _msg_header=u'\033[0;33mWARNING:\033[0m'
  193. else:
  194. _msg_header=u'WARNING:'
  195. warning_message=u'%s %s' % (_msg_header,message)
  196. self.to_stderr(warning_message)
  197. def report_error(self, message, tb=None):
  198. '''
  199. Do the same as trouble, but prefixes the message with 'ERROR:', colored
  200. in red if stderr is a tty file.
  201. '''
  202. if sys.stderr.isatty() and os.name != 'nt':
  203. _msg_header = u'\033[0;31mERROR:\033[0m'
  204. else:
  205. _msg_header = u'ERROR:'
  206. error_message = u'%s %s' % (_msg_header, message)
  207. self.trouble(error_message, tb)
  208. def report_writedescription(self, descfn):
  209. """ Report that the description file is being written """
  210. self.to_screen(u'[info] Writing video description to: ' + descfn)
  211. def report_writesubtitles(self, sub_filename):
  212. """ Report that the subtitles file is being written """
  213. self.to_screen(u'[info] Writing video subtitles to: ' + sub_filename)
  214. def report_writeinfojson(self, infofn):
  215. """ Report that the metadata file has been written """
  216. self.to_screen(u'[info] Video description metadata as JSON to: ' + infofn)
  217. def report_writeannotations(self, annofn):
  218. """ Report that the annotations file has been written. """
  219. self.to_screen(u'[info] Writing video annotations to: ' + annofn)
  220. def report_file_already_downloaded(self, file_name):
  221. """Report file has already been fully downloaded."""
  222. try:
  223. self.to_screen(u'[download] %s has already been downloaded' % file_name)
  224. except (UnicodeEncodeError) as err:
  225. self.to_screen(u'[download] The file has already been downloaded')
  226. def increment_downloads(self):
  227. """Increment the ordinal that assigns a number to each file."""
  228. self._num_downloads += 1
  229. def prepare_filename(self, info_dict):
  230. """Generate the output filename."""
  231. try:
  232. template_dict = dict(info_dict)
  233. template_dict['epoch'] = int(time.time())
  234. autonumber_size = self.params.get('autonumber_size')
  235. if autonumber_size is None:
  236. autonumber_size = 5
  237. autonumber_templ = u'%0' + str(autonumber_size) + u'd'
  238. template_dict['autonumber'] = autonumber_templ % self._num_downloads
  239. if template_dict['playlist_index'] is not None:
  240. template_dict['playlist_index'] = u'%05d' % template_dict['playlist_index']
  241. sanitize = lambda k,v: sanitize_filename(
  242. u'NA' if v is None else compat_str(v),
  243. restricted=self.params.get('restrictfilenames'),
  244. is_id=(k==u'id'))
  245. template_dict = dict((k, sanitize(k, v)) for k,v in template_dict.items())
  246. filename = self.params['outtmpl'] % template_dict
  247. return filename
  248. except KeyError as err:
  249. self.report_error(u'Erroneous output template')
  250. return None
  251. except ValueError as err:
  252. self.report_error(u'Error in output template: ' + str(err) + u' (encoding: ' + repr(preferredencoding()) + ')')
  253. return None
  254. def _match_entry(self, info_dict):
  255. """ Returns None iff the file should be downloaded """
  256. title = info_dict['title']
  257. matchtitle = self.params.get('matchtitle', False)
  258. if matchtitle:
  259. if not re.search(matchtitle, title, re.IGNORECASE):
  260. return u'[download] "' + title + '" title did not match pattern "' + matchtitle + '"'
  261. rejecttitle = self.params.get('rejecttitle', False)
  262. if rejecttitle:
  263. if re.search(rejecttitle, title, re.IGNORECASE):
  264. return u'"' + title + '" title matched reject pattern "' + rejecttitle + '"'
  265. date = info_dict.get('upload_date', None)
  266. if date is not None:
  267. dateRange = self.params.get('daterange', DateRange())
  268. if date not in dateRange:
  269. return u'[download] %s upload date is not in range %s' % (date_from_str(date).isoformat(), dateRange)
  270. age_limit = self.params.get('age_limit')
  271. if age_limit is not None:
  272. if age_limit < info_dict.get('age_limit', 0):
  273. return u'Skipping "' + title + '" because it is age restricted'
  274. if self.in_download_archive(info_dict):
  275. return (u'%(title)s has already been recorded in archive'
  276. % info_dict)
  277. return None
  278. def extract_info(self, url, download=True, ie_key=None, extra_info={}):
  279. '''
  280. Returns a list with a dictionary for each video we find.
  281. If 'download', also downloads the videos.
  282. extra_info is a dict containing the extra values to add to each result
  283. '''
  284. if ie_key:
  285. ies = [self.get_info_extractor(ie_key)]
  286. else:
  287. ies = self._ies
  288. for ie in ies:
  289. if not ie.suitable(url):
  290. continue
  291. if not ie.working():
  292. self.report_warning(u'The program functionality for this site has been marked as broken, '
  293. u'and will probably not work.')
  294. try:
  295. ie_result = ie.extract(url)
  296. if ie_result is None: # Finished already (backwards compatibility; listformats and friends should be moved here)
  297. break
  298. if isinstance(ie_result, list):
  299. # Backwards compatibility: old IE result format
  300. for result in ie_result:
  301. result.update(extra_info)
  302. ie_result = {
  303. '_type': 'compat_list',
  304. 'entries': ie_result,
  305. }
  306. else:
  307. ie_result.update(extra_info)
  308. if 'extractor' not in ie_result:
  309. ie_result['extractor'] = ie.IE_NAME
  310. return self.process_ie_result(ie_result, download=download)
  311. except ExtractorError as de: # An error we somewhat expected
  312. self.report_error(compat_str(de), de.format_traceback())
  313. break
  314. except Exception as e:
  315. if self.params.get('ignoreerrors', False):
  316. self.report_error(compat_str(e), tb=compat_str(traceback.format_exc()))
  317. break
  318. else:
  319. raise
  320. else:
  321. self.report_error(u'no suitable InfoExtractor: %s' % url)
  322. def process_ie_result(self, ie_result, download=True, extra_info={}):
  323. """
  324. Take the result of the ie(may be modified) and resolve all unresolved
  325. references (URLs, playlist items).
  326. It will also download the videos if 'download'.
  327. Returns the resolved ie_result.
  328. """
  329. result_type = ie_result.get('_type', 'video') # If not given we suppose it's a video, support the default old system
  330. if result_type == 'video':
  331. ie_result.update(extra_info)
  332. return self.process_video_result(ie_result)
  333. elif result_type == 'url':
  334. # We have to add extra_info to the results because it may be
  335. # contained in a playlist
  336. return self.extract_info(ie_result['url'],
  337. download,
  338. ie_key=ie_result.get('ie_key'),
  339. extra_info=extra_info)
  340. elif result_type == 'playlist':
  341. # We process each entry in the playlist
  342. playlist = ie_result.get('title', None) or ie_result.get('id', None)
  343. self.to_screen(u'[download] Downloading playlist: %s' % playlist)
  344. playlist_results = []
  345. n_all_entries = len(ie_result['entries'])
  346. playliststart = self.params.get('playliststart', 1) - 1
  347. playlistend = self.params.get('playlistend', -1)
  348. if playlistend == -1:
  349. entries = ie_result['entries'][playliststart:]
  350. else:
  351. entries = ie_result['entries'][playliststart:playlistend]
  352. n_entries = len(entries)
  353. self.to_screen(u"[%s] playlist '%s': Collected %d video ids (downloading %d of them)" %
  354. (ie_result['extractor'], playlist, n_all_entries, n_entries))
  355. for i,entry in enumerate(entries,1):
  356. self.to_screen(u'[download] Downloading video #%s of %s' %(i, n_entries))
  357. extra = {
  358. 'playlist': playlist,
  359. 'playlist_index': i + playliststart,
  360. }
  361. if not 'extractor' in entry:
  362. # We set the extractor, if it's an url it will be set then to
  363. # the new extractor, but if it's already a video we must make
  364. # sure it's present: see issue #877
  365. entry['extractor'] = ie_result['extractor']
  366. entry_result = self.process_ie_result(entry,
  367. download=download,
  368. extra_info=extra)
  369. playlist_results.append(entry_result)
  370. ie_result['entries'] = playlist_results
  371. return ie_result
  372. elif result_type == 'compat_list':
  373. def _fixup(r):
  374. r.setdefault('extractor', ie_result['extractor'])
  375. return r
  376. ie_result['entries'] = [
  377. self.process_ie_result(_fixup(r), download=download)
  378. for r in ie_result['entries']
  379. ]
  380. return ie_result
  381. else:
  382. raise Exception('Invalid result type: %s' % result_type)
  383. def select_format(self, format_spec, available_formats):
  384. if format_spec == 'best' or format_spec is None:
  385. return available_formats[-1]
  386. elif format_spec == 'worst':
  387. return available_formats[0]
  388. else:
  389. extensions = [u'mp4', u'flv', u'webm', u'3gp']
  390. if format_spec in extensions:
  391. filter_f = lambda f: f['ext'] == format_spec
  392. else:
  393. filter_f = lambda f: f['format_id'] == format_spec
  394. matches = list(filter(filter_f ,available_formats))
  395. if matches:
  396. return matches[-1]
  397. return None
  398. def process_video_result(self, info_dict, download=True):
  399. assert info_dict.get('_type', 'video') == 'video'
  400. if 'playlist' not in info_dict:
  401. # It isn't part of a playlist
  402. info_dict['playlist'] = None
  403. info_dict['playlist_index'] = None
  404. # This extractors handle format selection themselves
  405. if info_dict['extractor'] in [u'youtube', u'Youku', u'YouPorn', u'mixcloud']:
  406. self.process_info(info_dict)
  407. return info_dict
  408. # We now pick which formats have to be downloaded
  409. if info_dict.get('formats') is None:
  410. # There's only one format available
  411. formats = [info_dict]
  412. else:
  413. formats = info_dict['formats']
  414. # We check that all the formats have the format and format_id fields
  415. for (i, format) in enumerate(formats):
  416. if format.get('format_id') is None:
  417. format['format_id'] = compat_str(i)
  418. if format.get('format') is None:
  419. format['format'] = u'{id} - {res}{note}'.format(
  420. id=format['format_id'],
  421. res=self.format_resolution(format),
  422. note = u' ({})'.format(format['format_note']) if format.get('format_note') is not None else '',
  423. )
  424. if self.params.get('listformats', None):
  425. self.list_formats(info_dict)
  426. return
  427. format_limit = self.params.get('format_limit', None)
  428. if format_limit:
  429. formats = list(takewhile_inclusive(
  430. lambda f: f['format_id'] != format_limit, formats
  431. ))
  432. if self.params.get('prefer_free_formats'):
  433. def _free_formats_key(f):
  434. try:
  435. ext_ord = [u'flv', u'mp4', u'webm'].index(f['ext'])
  436. except ValueError:
  437. ext_ord = -1
  438. # We only compare the extension if they have the same height and width
  439. return (f.get('height'), f.get('width'), ext_ord)
  440. formats = sorted(formats, key=_free_formats_key)
  441. req_format = self.params.get('format', 'best')
  442. if req_format is None:
  443. req_format = 'best'
  444. formats_to_download = []
  445. # The -1 is for supporting YoutubeIE
  446. if req_format in ('-1', 'all'):
  447. formats_to_download = formats
  448. else:
  449. # We can accept formats requestd in the format: 34/5/best, we pick
  450. # the first that is available, starting from left
  451. req_formats = req_format.split('/')
  452. for rf in req_formats:
  453. selected_format = self.select_format(rf, formats)
  454. if selected_format is not None:
  455. formats_to_download = [selected_format]
  456. break
  457. if not formats_to_download:
  458. raise ExtractorError(u'requested format not available')
  459. if download:
  460. if len(formats_to_download) > 1:
  461. self.to_screen(u'[info] %s: downloading video in %s formats' % (info_dict['id'], len(formats_to_download)))
  462. for format in formats_to_download:
  463. new_info = dict(info_dict)
  464. new_info.update(format)
  465. self.process_info(new_info)
  466. # We update the info dict with the best quality format (backwards compatibility)
  467. info_dict.update(formats_to_download[-1])
  468. return info_dict
  469. def process_info(self, info_dict):
  470. """Process a single resolved IE result."""
  471. assert info_dict.get('_type', 'video') == 'video'
  472. #We increment the download the download count here to match the previous behaviour.
  473. self.increment_downloads()
  474. info_dict['fulltitle'] = info_dict['title']
  475. if len(info_dict['title']) > 200:
  476. info_dict['title'] = info_dict['title'][:197] + u'...'
  477. # Keep for backwards compatibility
  478. info_dict['stitle'] = info_dict['title']
  479. if not 'format' in info_dict:
  480. info_dict['format'] = info_dict['ext']
  481. reason = self._match_entry(info_dict)
  482. if reason is not None:
  483. self.to_screen(u'[download] ' + reason)
  484. return
  485. max_downloads = self.params.get('max_downloads')
  486. if max_downloads is not None:
  487. if self._num_downloads > int(max_downloads):
  488. raise MaxDownloadsReached()
  489. filename = self.prepare_filename(info_dict)
  490. # Forced printings
  491. if self.params.get('forcetitle', False):
  492. compat_print(info_dict['title'])
  493. if self.params.get('forceid', False):
  494. compat_print(info_dict['id'])
  495. if self.params.get('forceurl', False):
  496. # For RTMP URLs, also include the playpath
  497. compat_print(info_dict['url'] + info_dict.get('play_path', u''))
  498. if self.params.get('forcethumbnail', False) and 'thumbnail' in info_dict:
  499. compat_print(info_dict['thumbnail'])
  500. if self.params.get('forcedescription', False) and 'description' in info_dict:
  501. compat_print(info_dict['description'])
  502. if self.params.get('forcefilename', False) and filename is not None:
  503. compat_print(filename)
  504. if self.params.get('forceformat', False):
  505. compat_print(info_dict['format'])
  506. # Do nothing else if in simulate mode
  507. if self.params.get('simulate', False):
  508. return
  509. if filename is None:
  510. return
  511. try:
  512. dn = os.path.dirname(encodeFilename(filename))
  513. if dn != '' and not os.path.exists(dn):
  514. os.makedirs(dn)
  515. except (OSError, IOError) as err:
  516. self.report_error(u'unable to create directory ' + compat_str(err))
  517. return
  518. if self.params.get('writedescription', False):
  519. try:
  520. descfn = filename + u'.description'
  521. self.report_writedescription(descfn)
  522. with io.open(encodeFilename(descfn), 'w', encoding='utf-8') as descfile:
  523. descfile.write(info_dict['description'])
  524. except (KeyError, TypeError):
  525. self.report_warning(u'There\'s no description to write.')
  526. except (OSError, IOError):
  527. self.report_error(u'Cannot write description file ' + descfn)
  528. return
  529. if self.params.get('writeannotations', False):
  530. try:
  531. annofn = filename + u'.annotations.xml'
  532. self.report_writeannotations(annofn)
  533. with io.open(encodeFilename(annofn), 'w', encoding='utf-8') as annofile:
  534. annofile.write(info_dict['annotations'])
  535. except (KeyError, TypeError):
  536. self.report_warning(u'There are no annotations to write.')
  537. except (OSError, IOError):
  538. self.report_error(u'Cannot write annotations file: ' + annofn)
  539. return
  540. subtitles_are_requested = any([self.params.get('writesubtitles', False),
  541. self.params.get('writeautomaticsub')])
  542. if subtitles_are_requested and 'subtitles' in info_dict and info_dict['subtitles']:
  543. # subtitles download errors are already managed as troubles in relevant IE
  544. # that way it will silently go on when used with unsupporting IE
  545. subtitles = info_dict['subtitles']
  546. sub_format = self.params.get('subtitlesformat')
  547. for sub_lang in subtitles.keys():
  548. sub = subtitles[sub_lang]
  549. if sub is None:
  550. continue
  551. try:
  552. sub_filename = subtitles_filename(filename, sub_lang, sub_format)
  553. self.report_writesubtitles(sub_filename)
  554. with io.open(encodeFilename(sub_filename), 'w', encoding='utf-8') as subfile:
  555. subfile.write(sub)
  556. except (OSError, IOError):
  557. self.report_error(u'Cannot write subtitles file ' + descfn)
  558. return
  559. if self.params.get('writeinfojson', False):
  560. infofn = filename + u'.info.json'
  561. self.report_writeinfojson(infofn)
  562. try:
  563. json_info_dict = dict((k, v) for k,v in info_dict.items() if not k in ['urlhandle'])
  564. write_json_file(json_info_dict, encodeFilename(infofn))
  565. except (OSError, IOError):
  566. self.report_error(u'Cannot write metadata to JSON file ' + infofn)
  567. return
  568. if self.params.get('writethumbnail', False):
  569. if info_dict.get('thumbnail') is not None:
  570. thumb_format = determine_ext(info_dict['thumbnail'], u'jpg')
  571. thumb_filename = filename.rpartition('.')[0] + u'.' + thumb_format
  572. self.to_screen(u'[%s] %s: Downloading thumbnail ...' %
  573. (info_dict['extractor'], info_dict['id']))
  574. try:
  575. uf = compat_urllib_request.urlopen(info_dict['thumbnail'])
  576. with open(thumb_filename, 'wb') as thumbf:
  577. shutil.copyfileobj(uf, thumbf)
  578. self.to_screen(u'[%s] %s: Writing thumbnail to: %s' %
  579. (info_dict['extractor'], info_dict['id'], thumb_filename))
  580. except (compat_urllib_error.URLError, compat_http_client.HTTPException, socket.error) as err:
  581. self.report_warning(u'Unable to download thumbnail "%s": %s' %
  582. (info_dict['thumbnail'], compat_str(err)))
  583. if not self.params.get('skip_download', False):
  584. if self.params.get('nooverwrites', False) and os.path.exists(encodeFilename(filename)):
  585. success = True
  586. else:
  587. try:
  588. success = self.fd._do_download(filename, info_dict)
  589. except (compat_urllib_error.URLError, compat_http_client.HTTPException, socket.error) as err:
  590. self.report_error(u'unable to download video data: %s' % str(err))
  591. return
  592. except (OSError, IOError) as err:
  593. raise UnavailableVideoError(err)
  594. except (ContentTooShortError, ) as err:
  595. self.report_error(u'content too short (expected %s bytes and served %s)' % (err.expected, err.downloaded))
  596. return
  597. if success:
  598. try:
  599. self.post_process(filename, info_dict)
  600. except (PostProcessingError) as err:
  601. self.report_error(u'postprocessing: %s' % str(err))
  602. return
  603. self.record_download_archive(info_dict)
  604. def download(self, url_list):
  605. """Download a given list of URLs."""
  606. if len(url_list) > 1 and self.fixed_template():
  607. raise SameFileError(self.params['outtmpl'])
  608. for url in url_list:
  609. try:
  610. #It also downloads the videos
  611. videos = self.extract_info(url)
  612. except UnavailableVideoError:
  613. self.report_error(u'unable to download video')
  614. except MaxDownloadsReached:
  615. self.to_screen(u'[info] Maximum number of downloaded files reached.')
  616. raise
  617. return self._download_retcode
  618. def post_process(self, filename, ie_info):
  619. """Run all the postprocessors on the given file."""
  620. info = dict(ie_info)
  621. info['filepath'] = filename
  622. keep_video = None
  623. for pp in self._pps:
  624. try:
  625. keep_video_wish,new_info = pp.run(info)
  626. if keep_video_wish is not None:
  627. if keep_video_wish:
  628. keep_video = keep_video_wish
  629. elif keep_video is None:
  630. # No clear decision yet, let IE decide
  631. keep_video = keep_video_wish
  632. except PostProcessingError as e:
  633. self.report_error(e.msg)
  634. if keep_video is False and not self.params.get('keepvideo', False):
  635. try:
  636. self.to_screen(u'Deleting original file %s (pass -k to keep)' % filename)
  637. os.remove(encodeFilename(filename))
  638. except (IOError, OSError):
  639. self.report_warning(u'Unable to remove downloaded video file')
  640. def in_download_archive(self, info_dict):
  641. fn = self.params.get('download_archive')
  642. if fn is None:
  643. return False
  644. vid_id = info_dict['extractor'] + u' ' + info_dict['id']
  645. try:
  646. with locked_file(fn, 'r', encoding='utf-8') as archive_file:
  647. for line in archive_file:
  648. if line.strip() == vid_id:
  649. return True
  650. except IOError as ioe:
  651. if ioe.errno != errno.ENOENT:
  652. raise
  653. return False
  654. def record_download_archive(self, info_dict):
  655. fn = self.params.get('download_archive')
  656. if fn is None:
  657. return
  658. vid_id = info_dict['extractor'] + u' ' + info_dict['id']
  659. with locked_file(fn, 'a', encoding='utf-8') as archive_file:
  660. archive_file.write(vid_id + u'\n')
  661. @staticmethod
  662. def format_resolution(format):
  663. if format.get('height') is not None:
  664. if format.get('width') is not None:
  665. res = u'%sx%s' % (format['width'], format['height'])
  666. else:
  667. res = u'%sp' % format['height']
  668. else:
  669. res = '???'
  670. return res
  671. def list_formats(self, info_dict):
  672. formats_s = []
  673. for format in info_dict.get('formats', [info_dict]):
  674. formats_s.append(u'%-15s: %-5s %-15s[%s]' % (
  675. format['format_id'],
  676. format['ext'],
  677. format.get('format_note') or '-',
  678. self.format_resolution(format),
  679. )
  680. )
  681. if len(formats_s) != 1:
  682. formats_s[0] += ' (worst)'
  683. formats_s[-1] += ' (best)'
  684. formats_s = "\n".join(formats_s)
  685. self.to_screen(u'[info] Available formats for %s:\n'
  686. u'format code extension note resolution\n%s' % (
  687. info_dict['id'], formats_s))