2013-06-18 20:14:21 +00:00
#!/usr/bin/env python
# -*- coding: utf-8 -*-
from __future__ import absolute_import
2013-10-06 02:27:09 +00:00
import errno
2013-06-18 20:14:21 +00:00
import io
2013-11-20 05:18:24 +00:00
import json
2013-06-18 20:14:21 +00:00
import os
2013-11-22 18:57:52 +00:00
import platform
2013-06-18 20:14:21 +00:00
import re
import shutil
2013-11-22 18:57:52 +00:00
import subprocess
2013-06-18 20:14:21 +00:00
import socket
import sys
import time
import traceback
2013-11-17 10:39:52 +00:00
if os . name == ' nt ' :
import ctypes
2013-11-17 15:47:52 +00:00
from . utils import (
2013-11-22 18:57:52 +00:00
compat_cookiejar ,
2013-11-17 15:47:52 +00:00
compat_http_client ,
compat_str ,
compat_urllib_error ,
compat_urllib_request ,
ContentTooShortError ,
date_from_str ,
DateRange ,
determine_ext ,
DownloadError ,
encodeFilename ,
ExtractorError ,
2013-11-25 02:12:26 +00:00
format_bytes ,
2013-11-17 15:47:52 +00:00
locked_file ,
2013-11-22 18:57:52 +00:00
make_HTTPS_handler ,
2013-11-17 15:47:52 +00:00
MaxDownloadsReached ,
PostProcessingError ,
2013-11-22 18:57:52 +00:00
platform_name ,
2013-11-17 15:47:52 +00:00
preferredencoding ,
SameFileError ,
sanitize_filename ,
subtitles_filename ,
takewhile_inclusive ,
UnavailableVideoError ,
write_json_file ,
write_string ,
2013-11-22 18:57:52 +00:00
YoutubeDLHandler ,
2013-11-17 15:47:52 +00:00
)
2013-06-27 21:51:06 +00:00
from . extractor import get_info_extractor , gen_extractors
2013-06-18 20:14:21 +00:00
from . FileDownloader import FileDownloader
2013-11-22 18:57:52 +00:00
from . version import __version__
2013-06-18 20:14:21 +00:00
class YoutubeDL ( object ) :
""" YoutubeDL class.
YoutubeDL objects are the ones responsible of downloading the
actual video file and writing it to disk if the user has requested
it , among some other tasks . In most cases there should be one per
program . As , given a video URL , the downloader doesn ' t know how to
extract all the needed information , task that InfoExtractors do , it
has to pass the URL to one of them .
For this , YoutubeDL objects have a method that allows
InfoExtractors to be registered in a given order . When it is passed
a URL , the YoutubeDL object handles it to the first InfoExtractor it
finds that reports being able to handle it . The InfoExtractor extracts
all the information about the video or videos the URL refers to , and
YoutubeDL process the extracted information , possibly using a File
Downloader to download the video .
YoutubeDL objects accept a lot of parameters . In order not to saturate
the object constructor with arguments , it receives a dictionary of
options instead . These options are available through the params
attribute for the InfoExtractors to use . The YoutubeDL also
registers itself as the downloader in charge for the InfoExtractors
that are added to it , so this is a " mutual registration " .
Available options :
username : Username for authentication purposes .
password : Password for authentication purposes .
2013-06-25 20:22:32 +00:00
videopassword : Password for acces a video .
2013-06-18 20:14:21 +00:00
usenetrc : Use netrc for authentication instead .
verbose : Print additional info to stdout .
quiet : Do not print messages to stdout .
forceurl : Force printing final URL .
forcetitle : Force printing title .
forceid : Force printing ID .
forcethumbnail : Force printing thumbnail URL .
forcedescription : Force printing description .
forcefilename : Force printing final filename .
2013-11-20 05:18:24 +00:00
forcejson : Force printing info_dict as JSON .
2013-06-18 20:14:21 +00:00
simulate : Do not download the video files .
format : Video format code .
format_limit : Highest quality format to try .
outtmpl : Template for output names .
restrictfilenames : Do not allow " & " and spaces in file names
ignoreerrors : Do not stop on download errors .
nooverwrites : Prevent overwriting files .
playliststart : Playlist item to start at .
playlistend : Playlist item to end at .
matchtitle : Download only matching titles .
rejecttitle : Reject downloads for matching titles .
2013-11-24 05:08:11 +00:00
logger : Log messages to a logging . Logger instance .
2013-06-18 20:14:21 +00:00
logtostderr : Log messages to stderr instead of stdout .
writedescription : Write the video description to a . description file
writeinfojson : Write the video description to a . info . json file
2013-10-14 05:18:58 +00:00
writeannotations : Write the video annotations to a . annotations . xml file
2013-06-18 20:14:21 +00:00
writethumbnail : Write the thumbnail image to a file
writesubtitles : Write the video subtitles to a file
2013-06-25 21:45:16 +00:00
writeautomaticsub : Write the automatic subtitles to a file
2013-06-18 20:14:21 +00:00
allsubtitles : Downloads all the subtitles of the video
2013-09-14 09:14:40 +00:00
( requires writesubtitles or writeautomaticsub )
2013-06-18 20:14:21 +00:00
listsubtitles : Lists all available subtitles for the video
2013-06-26 09:59:29 +00:00
subtitlesformat : Subtitle format [ srt / sbv / vtt ] ( default = srt )
2013-08-23 16:34:57 +00:00
subtitleslangs : List of languages of the subtitles to download
2013-06-18 20:14:21 +00:00
keepvideo : Keep the video file after post - processing
daterange : A DateRange object , download only if the upload_date is in the range .
skip_download : Skip the actual download of the video file
2013-09-22 09:09:25 +00:00
cachedir : Location of the cache files in the filesystem .
2013-09-24 19:04:43 +00:00
None to disable filesystem cache .
2013-09-30 20:26:25 +00:00
noplaylist : Download single video instead of a playlist if in doubt .
2013-10-06 04:06:30 +00:00
age_limit : An integer representing the user ' s age in years.
Unsuitable videos for the given age are skipped .
2013-11-25 21:52:09 +00:00
download_archive : File name of a file where all downloads are recorded .
2013-10-06 02:27:09 +00:00
Videos already present in the file are not downloaded
again .
2013-11-22 18:57:52 +00:00
cookiefile : File name where cookies should be read from and dumped to .
2013-11-24 14:03:25 +00:00
nocheckcertificate : Do not verify SSL certificates
proxy : URL of the proxy server to use
2013-12-01 10:42:02 +00:00
socket_timeout : Time to wait for unresponsive hosts , in seconds
2013-12-09 03:08:51 +00:00
bidi_workaround : Work around buggy terminals without bidirectional text
support , using fridibi
2013-10-22 12:49:34 +00:00
2013-06-18 20:14:21 +00:00
The following parameters are not used by YoutubeDL itself , they are used by
the FileDownloader :
nopart , updatetime , buffersize , ratelimit , min_filesize , max_filesize , test ,
noresizebuffer , retries , continuedl , noprogress , consoletitle
"""
params = None
_ies = [ ]
_pps = [ ]
_download_retcode = None
_num_downloads = None
_screen_file = None
2013-11-29 14:25:09 +00:00
def __init__ ( self , params = None ) :
2013-06-18 20:14:21 +00:00
""" Create a FileDownloader object with the given options. """
self . _ies = [ ]
2013-07-08 13:14:27 +00:00
self . _ies_instances = { }
2013-06-18 20:14:21 +00:00
self . _pps = [ ]
self . _progress_hooks = [ ]
self . _download_retcode = 0
self . _num_downloads = 0
self . _screen_file = [ sys . stdout , sys . stderr ] [ params . get ( ' logtostderr ' , False ) ]
2013-12-09 03:08:51 +00:00
self . _err_file = sys . stderr
2013-11-29 14:25:09 +00:00
self . params = { } if params is None else params
2013-09-21 09:48:07 +00:00
2013-12-09 03:08:51 +00:00
# Pipe messsages through fribidi
if params . get ( ' bidi_workaround ' , False ) :
# fribidi does not support ungetting, so force newlines
params [ ' progress_with_newline ' ] = True
for fid in [ ' _screen_file ' , ' _err_file ' ] :
class FribidiOut ( object ) :
def __init__ ( self , outfile , errfile ) :
self . outfile = outfile
self . process = subprocess . Popen (
[ ' fribidi ' ] ,
stdin = subprocess . PIPE ,
stdout = outfile ,
stderr = errfile )
def write ( self , s ) :
res = self . process . stdin . write ( s )
self . flush ( )
return res
def flush ( self ) :
return self . process . stdin . flush ( )
def isatty ( self ) :
return self . outfile . isatty ( )
try :
vout = FribidiOut ( getattr ( self , fid ) , self . _err_file )
setattr ( self , fid , vout )
except OSError as ose :
if ose . errno == 2 :
self . report_warning ( u ' Could not find fribidi executable, ignoring --bidi-workaround . Make sure that fribidi is an executable file in one of the directories in your $PATH. ' )
break
else :
raise
2013-09-21 09:48:07 +00:00
if ( sys . version_info > = ( 3 , ) and sys . platform != ' win32 ' and
sys . getfilesystemencoding ( ) in [ ' ascii ' , ' ANSI_X3.4-1968 ' ]
and not params [ ' restrictfilenames ' ] ) :
# On Python 3, the Unicode filesystem API will throw errors (#1474)
self . report_warning (
2013-10-09 13:56:09 +00:00
u ' Assuming --restrict-filenames since file system encoding '
2013-09-21 09:48:07 +00:00
u ' cannot encode all charactes. '
u ' Set the LC_ALL environment variable to fix this. ' )
2013-11-26 17:53:36 +00:00
self . params [ ' restrictfilenames ' ] = True
2013-09-21 09:48:07 +00:00
2013-06-18 20:14:21 +00:00
self . fd = FileDownloader ( self , self . params )
2013-11-25 20:55:20 +00:00
if ' %(stitle)s ' in self . params . get ( ' outtmpl ' , ' ' ) :
2013-06-18 20:14:21 +00:00
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. ' )
2013-11-22 18:57:52 +00:00
self . _setup_opener ( )
2013-06-18 20:14:21 +00:00
def add_info_extractor ( self , ie ) :
""" Add an InfoExtractor object to the end of the list. """
self . _ies . append ( ie )
2013-07-08 13:14:27 +00:00
self . _ies_instances [ ie . ie_key ( ) ] = ie
2013-06-18 20:14:21 +00:00
ie . set_downloader ( self )
2013-07-08 13:14:27 +00:00
def get_info_extractor ( self , ie_key ) :
"""
Get an instance of an IE with name ie_key , it will try to get one from
the _ies list , if there ' s no instance it will create a new one and add
it to the extractor list .
"""
ie = self . _ies_instances . get ( ie_key )
if ie is None :
ie = get_info_extractor ( ie_key ) ( )
self . add_info_extractor ( ie )
return ie
2013-06-27 21:51:06 +00:00
def add_default_info_extractors ( self ) :
"""
Add the InfoExtractors returned by gen_extractors to the end of the list
"""
for ie in gen_extractors ( ) :
self . add_info_extractor ( ie )
2013-06-18 20:14:21 +00:00
def add_post_processor ( self , pp ) :
""" Add a PostProcessor object to the end of the chain. """
self . _pps . append ( pp )
pp . set_downloader ( self )
def to_screen ( self , message , skip_eol = False ) :
2013-12-09 03:08:51 +00:00
""" Print message to stdout if not in quiet mode. """
return self . to_stdout ( message , skip_eol , check_quiet = True )
def to_stdout ( self , message , skip_eol = False , check_quiet = False ) :
2013-06-18 20:14:21 +00:00
""" Print message to stdout if not in quiet mode. """
2013-11-24 05:08:11 +00:00
if self . params . get ( ' logger ' ) :
2013-11-23 08:22:18 +00:00
self . params [ ' logger ' ] . debug ( message )
2013-12-09 03:08:51 +00:00
elif not check_quiet or not self . params . get ( ' quiet ' , False ) :
2013-06-18 20:14:21 +00:00
terminator = [ u ' \n ' , u ' ' ] [ skip_eol ]
output = message + terminator
2013-09-16 04:55:33 +00:00
write_string ( output , self . _screen_file )
2013-06-18 20:14:21 +00:00
def to_stderr ( self , message ) :
""" Print message to stderr. """
assert type ( message ) == type ( u ' ' )
2013-11-24 05:08:11 +00:00
if self . params . get ( ' logger ' ) :
2013-11-23 08:22:18 +00:00
self . params [ ' logger ' ] . error ( message )
else :
output = message + u ' \n '
2013-12-09 03:08:51 +00:00
write_string ( output , self . _err_file )
2013-06-18 20:14:21 +00:00
2013-11-17 10:39:52 +00:00
def to_console_title ( self , message ) :
if not self . params . get ( ' consoletitle ' , False ) :
return
if os . name == ' nt ' and ctypes . windll . kernel32 . GetConsoleWindow ( ) :
# c_wchar_p() might not be necessary if `message` is
# already of type unicode()
ctypes . windll . kernel32 . SetConsoleTitleW ( ctypes . c_wchar_p ( message ) )
elif ' TERM ' in os . environ :
2013-11-17 20:12:50 +00:00
write_string ( u ' \033 ]0; %s \007 ' % message , self . _screen_file )
2013-11-17 10:39:52 +00:00
2013-11-17 20:05:14 +00:00
def save_console_title ( self ) :
if not self . params . get ( ' consoletitle ' , False ) :
return
if ' TERM ' in os . environ :
2013-11-18 15:35:41 +00:00
# Save the title on stack
write_string ( u ' \033 [22;0t ' , self . _screen_file )
2013-11-17 20:05:14 +00:00
def restore_console_title ( self ) :
if not self . params . get ( ' consoletitle ' , False ) :
return
if ' TERM ' in os . environ :
2013-11-18 15:35:41 +00:00
# Restore the title from stack
write_string ( u ' \033 [23;0t ' , self . _screen_file )
2013-11-17 20:05:14 +00:00
def __enter__ ( self ) :
self . save_console_title ( )
return self
def __exit__ ( self , * args ) :
self . restore_console_title ( )
2013-11-22 18:57:52 +00:00
if self . params . get ( ' cookiefile ' ) is not None :
self . cookiejar . save ( )
2013-11-17 20:05:14 +00:00
2013-06-18 20:14:21 +00:00
def trouble ( self , message = None , tb = None ) :
""" Determine action to take when a download problem appears.
Depending on if the downloader has been configured to ignore
download errors or not , this method may throw an exception or
not when errors are found , after printing the message .
tb , if given , is additional traceback information .
"""
if message is not None :
self . to_stderr ( message )
if self . params . get ( ' verbose ' ) :
if tb is None :
if sys . exc_info ( ) [ 0 ] : # if .trouble has been called from an except block
tb = u ' '
if hasattr ( sys . exc_info ( ) [ 1 ] , ' exc_info ' ) and sys . exc_info ( ) [ 1 ] . exc_info [ 0 ] :
tb + = u ' ' . join ( traceback . format_exception ( * sys . exc_info ( ) [ 1 ] . exc_info ) )
tb + = compat_str ( traceback . format_exc ( ) )
else :
tb_data = traceback . format_list ( traceback . extract_stack ( ) )
tb = u ' ' . join ( tb_data )
self . to_stderr ( tb )
if not self . params . get ( ' ignoreerrors ' , False ) :
if sys . exc_info ( ) [ 0 ] and hasattr ( sys . exc_info ( ) [ 1 ] , ' exc_info ' ) and sys . exc_info ( ) [ 1 ] . exc_info [ 0 ] :
exc_info = sys . exc_info ( ) [ 1 ] . exc_info
else :
exc_info = sys . exc_info ( )
raise DownloadError ( message , exc_info )
self . _download_retcode = 1
def report_warning ( self , message ) :
'''
Print the message to stderr , it will be prefixed with ' WARNING: '
If stderr is a tty file the ' WARNING: ' will be colored
'''
2013-12-09 03:08:51 +00:00
if self . _err_file . isatty ( ) and os . name != ' nt ' :
2013-10-22 12:49:34 +00:00
_msg_header = u ' \033 [0;33mWARNING: \033 [0m '
2013-06-18 20:14:21 +00:00
else :
2013-10-22 12:49:34 +00:00
_msg_header = u ' WARNING: '
warning_message = u ' %s %s ' % ( _msg_header , message )
2013-06-18 20:14:21 +00:00
self . to_stderr ( warning_message )
def report_error ( self , message , tb = None ) :
'''
Do the same as trouble , but prefixes the message with ' ERROR: ' , colored
in red if stderr is a tty file .
'''
2013-12-09 03:08:51 +00:00
if self . _err_file . isatty ( ) and os . name != ' nt ' :
2013-06-18 20:14:21 +00:00
_msg_header = u ' \033 [0;31mERROR: \033 [0m '
else :
_msg_header = u ' ERROR: '
error_message = u ' %s %s ' % ( _msg_header , message )
self . trouble ( error_message , tb )
def report_writedescription ( self , descfn ) :
""" Report that the description file is being written """
self . to_screen ( u ' [info] Writing video description to: ' + descfn )
def report_writesubtitles ( self , sub_filename ) :
""" Report that the subtitles file is being written """
self . to_screen ( u ' [info] Writing video subtitles to: ' + sub_filename )
def report_writeinfojson ( self , infofn ) :
""" Report that the metadata file has been written """
self . to_screen ( u ' [info] Video description metadata as JSON to: ' + infofn )
2013-10-14 05:18:58 +00:00
def report_writeannotations ( self , annofn ) :
""" Report that the annotations file has been written. """
self . to_screen ( u ' [info] Writing video annotations to: ' + annofn )
2013-06-18 20:14:21 +00:00
def report_file_already_downloaded ( self , file_name ) :
""" Report file has already been fully downloaded. """
try :
self . to_screen ( u ' [download] %s has already been downloaded ' % file_name )
2013-11-17 15:47:52 +00:00
except UnicodeEncodeError :
2013-06-18 20:14:21 +00:00
self . to_screen ( u ' [download] The file has already been downloaded ' )
def increment_downloads ( self ) :
""" Increment the ordinal that assigns a number to each file. """
self . _num_downloads + = 1
def prepare_filename ( self , info_dict ) :
""" Generate the output filename. """
try :
template_dict = dict ( info_dict )
template_dict [ ' epoch ' ] = int ( time . time ( ) )
autonumber_size = self . params . get ( ' autonumber_size ' )
if autonumber_size is None :
autonumber_size = 5
autonumber_templ = u ' % 0 ' + str ( autonumber_size ) + u ' d '
template_dict [ ' autonumber ' ] = autonumber_templ % self . _num_downloads
2013-10-28 21:01:37 +00:00
if template_dict . get ( ' playlist_index ' ) is not None :
2013-06-18 20:14:21 +00:00
template_dict [ ' playlist_index ' ] = u ' %05d ' % template_dict [ ' playlist_index ' ]
2013-10-22 20:28:19 +00:00
sanitize = lambda k , v : sanitize_filename (
2013-06-18 20:14:21 +00:00
u ' NA ' if v is None else compat_str ( v ) ,
restricted = self . params . get ( ' restrictfilenames ' ) ,
2013-10-22 20:28:19 +00:00
is_id = ( k == u ' id ' ) )
template_dict = dict ( ( k , sanitize ( k , v ) )
for k , v in template_dict . items ( ) )
2013-06-18 20:14:21 +00:00
2013-10-22 20:28:19 +00:00
tmpl = os . path . expanduser ( self . params [ ' outtmpl ' ] )
filename = tmpl % template_dict
2013-06-18 20:14:21 +00:00
return filename
except KeyError as err :
self . report_error ( u ' Erroneous output template ' )
return None
except ValueError as err :
2013-08-08 06:55:26 +00:00
self . report_error ( u ' Error in output template: ' + str ( err ) + u ' (encoding: ' + repr ( preferredencoding ( ) ) + ' ) ' )
2013-06-18 20:14:21 +00:00
return None
def _match_entry ( self , info_dict ) :
""" Returns None iff the file should be downloaded """
2013-11-22 21:46:46 +00:00
if ' title ' in info_dict :
# This can happen when we're just evaluating the playlist
title = info_dict [ ' title ' ]
matchtitle = self . params . get ( ' matchtitle ' , False )
if matchtitle :
if not re . search ( matchtitle , title , re . IGNORECASE ) :
return u ' [download] " ' + title + ' " title did not match pattern " ' + matchtitle + ' " '
rejecttitle = self . params . get ( ' rejecttitle ' , False )
if rejecttitle :
if re . search ( rejecttitle , title , re . IGNORECASE ) :
return u ' " ' + title + ' " title matched reject pattern " ' + rejecttitle + ' " '
2013-06-18 20:14:21 +00:00
date = info_dict . get ( ' upload_date ' , None )
if date is not None :
dateRange = self . params . get ( ' daterange ' , DateRange ( ) )
if date not in dateRange :
return u ' [download] %s upload date is not in range %s ' % ( date_from_str ( date ) . isoformat ( ) , dateRange )
2013-10-06 04:06:30 +00:00
age_limit = self . params . get ( ' age_limit ' )
if age_limit is not None :
2013-10-06 14:23:06 +00:00
if age_limit < info_dict . get ( ' age_limit ' , 0 ) :
2013-10-06 04:06:30 +00:00
return u ' Skipping " ' + title + ' " because it is age restricted '
2013-10-06 02:27:09 +00:00
if self . in_download_archive ( info_dict ) :
2013-11-22 21:46:46 +00:00
return ( u ' %s has already been recorded in archive '
% info_dict . get ( ' title ' , info_dict . get ( ' id ' , u ' video ' ) ) )
2013-06-18 20:14:21 +00:00
return None
2013-10-22 12:49:34 +00:00
2013-11-03 10:56:45 +00:00
@staticmethod
def add_extra_info ( info_dict , extra_info ) :
''' Set the keys from extra_info in info dict if they are missing '''
for key , value in extra_info . items ( ) :
info_dict . setdefault ( key , value )
2013-12-05 13:29:08 +00:00
def extract_info ( self , url , download = True , ie_key = None , extra_info = { } ,
process = True ) :
2013-06-18 20:14:21 +00:00
'''
Returns a list with a dictionary for each video we find .
If ' download ' , also downloads the videos .
extra_info is a dict containing the extra values to add to each result
'''
2013-10-22 12:49:34 +00:00
2013-06-18 20:14:21 +00:00
if ie_key :
2013-07-08 13:14:27 +00:00
ies = [ self . get_info_extractor ( ie_key ) ]
2013-06-18 20:14:21 +00:00
else :
ies = self . _ies
for ie in ies :
if not ie . suitable ( url ) :
continue
if not ie . working ( ) :
self . report_warning ( u ' The program functionality for this site has been marked as broken, '
u ' and will probably not work. ' )
try :
ie_result = ie . extract ( url )
if ie_result is None : # Finished already (backwards compatibility; listformats and friends should be moved here)
break
if isinstance ( ie_result , list ) :
# Backwards compatibility: old IE result format
ie_result = {
' _type ' : ' compat_list ' ,
' entries ' : ie_result ,
}
2013-11-03 11:11:13 +00:00
self . add_extra_info ( ie_result ,
{
' extractor ' : ie . IE_NAME ,
2013-11-03 11:14:44 +00:00
' webpage_url ' : url ,
' extractor_key ' : ie . ie_key ( ) ,
2013-11-03 11:11:13 +00:00
} )
2013-12-05 13:29:08 +00:00
if process :
return self . process_ie_result ( ie_result , download , extra_info )
else :
return ie_result
2013-06-18 20:14:21 +00:00
except ExtractorError as de : # An error we somewhat expected
self . report_error ( compat_str ( de ) , de . format_traceback ( ) )
break
except Exception as e :
if self . params . get ( ' ignoreerrors ' , False ) :
self . report_error ( compat_str ( e ) , tb = compat_str ( traceback . format_exc ( ) ) )
break
else :
raise
else :
self . report_error ( u ' no suitable InfoExtractor: %s ' % url )
2013-10-22 12:49:34 +00:00
2013-06-18 20:14:21 +00:00
def process_ie_result ( self , ie_result , download = True , extra_info = { } ) :
"""
Take the result of the ie ( may be modified ) and resolve all unresolved
references ( URLs , playlist items ) .
It will also download the videos if ' download ' .
Returns the resolved ie_result .
"""
result_type = ie_result . get ( ' _type ' , ' video ' ) # If not given we suppose it's a video, support the default old system
if result_type == ' video ' :
2013-11-03 10:56:45 +00:00
self . add_extra_info ( ie_result , extra_info )
2013-11-15 10:04:26 +00:00
return self . process_video_result ( ie_result , download = download )
2013-06-18 20:14:21 +00:00
elif result_type == ' url ' :
# We have to add extra_info to the results because it may be
# contained in a playlist
return self . extract_info ( ie_result [ ' url ' ] ,
download ,
ie_key = ie_result . get ( ' ie_key ' ) ,
extra_info = extra_info )
2013-12-05 13:29:08 +00:00
elif result_type == ' url_transparent ' :
# Use the information from the embedding page
info = self . extract_info (
ie_result [ ' url ' ] , ie_key = ie_result . get ( ' ie_key ' ) ,
extra_info = extra_info , download = False , process = False )
def make_result ( embedded_info ) :
new_result = ie_result . copy ( )
for f in ( ' _type ' , ' url ' , ' ext ' , ' player_url ' , ' formats ' ,
' entries ' , ' urlhandle ' , ' ie_key ' , ' duration ' ,
2013-12-06 08:15:04 +00:00
' subtitles ' , ' annotations ' , ' format ' ,
' thumbnail ' , ' thumbnails ' ) :
2013-12-05 13:29:08 +00:00
if f in new_result :
del new_result [ f ]
if f in embedded_info :
new_result [ f ] = embedded_info [ f ]
return new_result
new_result = make_result ( info )
assert new_result . get ( ' _type ' ) != ' url_transparent '
if new_result . get ( ' _type ' ) == ' compat_list ' :
new_result [ ' entries ' ] = [
make_result ( e ) for e in new_result [ ' entries ' ] ]
return self . process_ie_result (
new_result , download = download , extra_info = extra_info )
2013-06-18 20:14:21 +00:00
elif result_type == ' playlist ' :
# We process each entry in the playlist
playlist = ie_result . get ( ' title ' , None ) or ie_result . get ( ' id ' , None )
2013-10-22 12:49:34 +00:00
self . to_screen ( u ' [download] Downloading playlist: %s ' % playlist )
2013-06-18 20:14:21 +00:00
playlist_results = [ ]
n_all_entries = len ( ie_result [ ' entries ' ] )
playliststart = self . params . get ( ' playliststart ' , 1 ) - 1
playlistend = self . params . get ( ' playlistend ' , - 1 )
if playlistend == - 1 :
entries = ie_result [ ' entries ' ] [ playliststart : ]
else :
entries = ie_result [ ' entries ' ] [ playliststart : playlistend ]
n_entries = len ( entries )
self . to_screen ( u " [ %s ] playlist ' %s ' : Collected %d video ids (downloading %d of them) " %
( ie_result [ ' extractor ' ] , playlist , n_all_entries , n_entries ) )
2013-10-22 12:49:34 +00:00
for i , entry in enumerate ( entries , 1 ) :
self . to_screen ( u ' [download] Downloading video # %s of %s ' % ( i , n_entries ) )
2013-06-18 20:14:21 +00:00
extra = {
2013-10-22 12:49:34 +00:00
' playlist ' : playlist ,
' playlist_index ' : i + playliststart ,
2013-11-03 10:56:45 +00:00
' extractor ' : ie_result [ ' extractor ' ] ,
2013-11-03 11:11:13 +00:00
' webpage_url ' : ie_result [ ' webpage_url ' ] ,
2013-11-03 11:14:44 +00:00
' extractor_key ' : ie_result [ ' extractor_key ' ] ,
2013-10-22 12:49:34 +00:00
}
2013-11-22 21:46:46 +00:00
reason = self . _match_entry ( entry )
if reason is not None :
self . to_screen ( u ' [download] ' + reason )
continue
2013-06-18 20:14:21 +00:00
entry_result = self . process_ie_result ( entry ,
download = download ,
extra_info = extra )
playlist_results . append ( entry_result )
ie_result [ ' entries ' ] = playlist_results
return ie_result
elif result_type == ' compat_list ' :
def _fixup ( r ) :
2013-11-03 10:56:45 +00:00
self . add_extra_info ( r ,
2013-11-03 11:11:13 +00:00
{
' extractor ' : ie_result [ ' extractor ' ] ,
' webpage_url ' : ie_result [ ' webpage_url ' ] ,
2013-11-03 11:14:44 +00:00
' extractor_key ' : ie_result [ ' extractor_key ' ] ,
2013-11-03 11:11:13 +00:00
} )
2013-06-18 20:14:21 +00:00
return r
ie_result [ ' entries ' ] = [
2013-11-03 10:56:45 +00:00
self . process_ie_result ( _fixup ( r ) , download , extra_info )
2013-06-18 20:14:21 +00:00
for r in ie_result [ ' entries ' ]
]
return ie_result
else :
raise Exception ( ' Invalid result type: %s ' % result_type )
2013-10-21 11:19:58 +00:00
def select_format ( self , format_spec , available_formats ) :
if format_spec == ' best ' or format_spec is None :
return available_formats [ - 1 ]
elif format_spec == ' worst ' :
return available_formats [ 0 ]
else :
2013-10-21 11:31:55 +00:00
extensions = [ u ' mp4 ' , u ' flv ' , u ' webm ' , u ' 3gp ' ]
if format_spec in extensions :
filter_f = lambda f : f [ ' ext ' ] == format_spec
else :
filter_f = lambda f : f [ ' format_id ' ] == format_spec
2013-10-22 12:49:34 +00:00
matches = list ( filter ( filter_f , available_formats ) )
2013-10-21 11:19:58 +00:00
if matches :
return matches [ - 1 ]
return None
2013-07-02 08:08:58 +00:00
def process_video_result ( self , info_dict , download = True ) :
assert info_dict . get ( ' _type ' , ' video ' ) == ' video '
if ' playlist ' not in info_dict :
# It isn't part of a playlist
info_dict [ ' playlist ' ] = None
info_dict [ ' playlist_index ' ] = None
2013-07-13 15:51:26 +00:00
# This extractors handle format selection themselves
2013-10-28 10:41:32 +00:00
if info_dict [ ' extractor ' ] in [ u ' youtube ' , u ' Youku ' ] :
2013-10-21 22:01:59 +00:00
if download :
self . process_info ( info_dict )
2013-07-13 15:51:26 +00:00
return info_dict
2013-07-02 08:08:58 +00:00
# We now pick which formats have to be downloaded
if info_dict . get ( ' formats ' ) is None :
# There's only one format available
formats = [ info_dict ]
else :
formats = info_dict [ ' formats ' ]
# We check that all the formats have the format and format_id fields
for ( i , format ) in enumerate ( formats ) :
if format . get ( ' format_id ' ) is None :
2013-07-14 15:31:52 +00:00
format [ ' format_id ' ] = compat_str ( i )
2013-10-21 12:09:38 +00:00
if format . get ( ' format ' ) is None :
format [ ' format ' ] = u ' {id} - {res} {note} ' . format (
id = format [ ' format_id ' ] ,
res = self . format_resolution ( format ) ,
2013-10-30 00:17:00 +00:00
note = u ' ( {0} ) ' . format ( format [ ' format_note ' ] ) if format . get ( ' format_note ' ) is not None else ' ' ,
2013-10-21 12:09:38 +00:00
)
2013-10-28 10:28:02 +00:00
# Automatically determine file extension if missing
if ' ext ' not in format :
format [ ' ext ' ] = determine_ext ( format [ ' url ' ] )
2013-07-02 08:08:58 +00:00
if self . params . get ( ' listformats ' , None ) :
self . list_formats ( info_dict )
return
2013-07-08 10:10:47 +00:00
format_limit = self . params . get ( ' format_limit ' , None )
if format_limit :
2013-10-17 22:46:35 +00:00
formats = list ( takewhile_inclusive (
lambda f : f [ ' format_id ' ] != format_limit , formats
) )
2013-07-14 15:24:18 +00:00
if self . params . get ( ' prefer_free_formats ' ) :
def _free_formats_key ( f ) :
try :
ext_ord = [ u ' flv ' , u ' mp4 ' , u ' webm ' ] . index ( f [ ' ext ' ] )
except ValueError :
ext_ord = - 1
# We only compare the extension if they have the same height and width
return ( f . get ( ' height ' ) , f . get ( ' width ' ) , ext_ord )
formats = sorted ( formats , key = _free_formats_key )
2013-07-08 10:10:47 +00:00
2013-07-02 08:08:58 +00:00
req_format = self . params . get ( ' format ' , ' best ' )
2013-10-21 11:19:58 +00:00
if req_format is None :
req_format = ' best '
2013-07-02 08:08:58 +00:00
formats_to_download = [ ]
# The -1 is for supporting YoutubeIE
2013-10-21 11:19:58 +00:00
if req_format in ( ' -1 ' , ' all ' ) :
2013-07-02 08:08:58 +00:00
formats_to_download = formats
else :
2013-10-21 11:19:58 +00:00
# We can accept formats requestd in the format: 34/5/best, we pick
2013-10-17 22:49:45 +00:00
# the first that is available, starting from left
2013-07-02 08:08:58 +00:00
req_formats = req_format . split ( ' / ' )
for rf in req_formats :
2013-10-21 11:19:58 +00:00
selected_format = self . select_format ( rf , formats )
if selected_format is not None :
formats_to_download = [ selected_format ]
2013-07-02 08:08:58 +00:00
break
if not formats_to_download :
2013-10-28 10:41:43 +00:00
raise ExtractorError ( u ' requested format not available ' ,
expected = True )
2013-07-02 08:08:58 +00:00
if download :
if len ( formats_to_download ) > 1 :
self . to_screen ( u ' [info] %s : downloading video in %s formats ' % ( info_dict [ ' id ' ] , len ( formats_to_download ) ) )
for format in formats_to_download :
new_info = dict ( info_dict )
new_info . update ( format )
self . process_info ( new_info )
# We update the info dict with the best quality format (backwards compatibility)
info_dict . update ( formats_to_download [ - 1 ] )
return info_dict
2013-06-18 20:14:21 +00:00
def process_info ( self , info_dict ) :
""" Process a single resolved IE result. """
assert info_dict . get ( ' _type ' , ' video ' ) == ' video '
#We increment the download the download count here to match the previous behaviour.
self . increment_downloads ( )
info_dict [ ' fulltitle ' ] = info_dict [ ' title ' ]
if len ( info_dict [ ' title ' ] ) > 200 :
info_dict [ ' title ' ] = info_dict [ ' title ' ] [ : 197 ] + u ' ... '
# Keep for backwards compatibility
info_dict [ ' stitle ' ] = info_dict [ ' title ' ]
if not ' format ' in info_dict :
info_dict [ ' format ' ] = info_dict [ ' ext ' ]
reason = self . _match_entry ( info_dict )
if reason is not None :
self . to_screen ( u ' [download] ' + reason )
return
max_downloads = self . params . get ( ' max_downloads ' )
if max_downloads is not None :
if self . _num_downloads > int ( max_downloads ) :
raise MaxDownloadsReached ( )
filename = self . prepare_filename ( info_dict )
# Forced printings
if self . params . get ( ' forcetitle ' , False ) :
2013-12-09 03:08:51 +00:00
self . to_stdout ( info_dict [ ' fulltitle ' ] )
2013-06-18 20:14:21 +00:00
if self . params . get ( ' forceid ' , False ) :
2013-12-09 03:08:51 +00:00
self . to_stdout ( info_dict [ ' id ' ] )
2013-06-18 20:14:21 +00:00
if self . params . get ( ' forceurl ' , False ) :
2013-08-28 10:14:45 +00:00
# For RTMP URLs, also include the playpath
2013-12-09 03:08:51 +00:00
self . to_stdout ( info_dict [ ' url ' ] + info_dict . get ( ' play_path ' , u ' ' ) )
2013-10-28 15:28:35 +00:00
if self . params . get ( ' forcethumbnail ' , False ) and info_dict . get ( ' thumbnail ' ) is not None :
2013-12-09 03:08:51 +00:00
self . to_stdout ( info_dict [ ' thumbnail ' ] )
2013-10-28 15:28:35 +00:00
if self . params . get ( ' forcedescription ' , False ) and info_dict . get ( ' description ' ) is not None :
2013-12-09 03:08:51 +00:00
self . to_stdout ( info_dict [ ' description ' ] )
2013-06-18 20:14:21 +00:00
if self . params . get ( ' forcefilename ' , False ) and filename is not None :
2013-12-09 03:08:51 +00:00
self . to_stdout ( filename )
2013-06-18 20:14:21 +00:00
if self . params . get ( ' forceformat ' , False ) :
2013-12-09 03:08:51 +00:00
self . to_stdout ( info_dict [ ' format ' ] )
2013-11-19 13:59:22 +00:00
if self . params . get ( ' forcejson ' , False ) :
2013-12-09 03:31:18 +00:00
info_dict [ ' _filename ' ] = filename
2013-12-09 03:08:51 +00:00
self . to_stdout ( json . dumps ( info_dict ) )
2013-06-18 20:14:21 +00:00
# Do nothing else if in simulate mode
if self . params . get ( ' simulate ' , False ) :
return
if filename is None :
return
try :
dn = os . path . dirname ( encodeFilename ( filename ) )
if dn != ' ' and not os . path . exists ( dn ) :
os . makedirs ( dn )
except ( OSError , IOError ) as err :
self . report_error ( u ' unable to create directory ' + compat_str ( err ) )
return
if self . params . get ( ' writedescription ' , False ) :
try :
descfn = filename + u ' .description '
self . report_writedescription ( descfn )
with io . open ( encodeFilename ( descfn ) , ' w ' , encoding = ' utf-8 ' ) as descfile :
descfile . write ( info_dict [ ' description ' ] )
2013-08-30 15:53:01 +00:00
except ( KeyError , TypeError ) :
2013-09-13 16:20:09 +00:00
self . report_warning ( u ' There \' s no description to write. ' )
2013-06-18 20:14:21 +00:00
except ( OSError , IOError ) :
self . report_error ( u ' Cannot write description file ' + descfn )
return
2013-10-14 05:18:58 +00:00
if self . params . get ( ' writeannotations ' , False ) :
try :
2013-10-22 12:49:34 +00:00
annofn = filename + u ' .annotations.xml '
self . report_writeannotations ( annofn )
with io . open ( encodeFilename ( annofn ) , ' w ' , encoding = ' utf-8 ' ) as annofile :
annofile . write ( info_dict [ ' annotations ' ] )
2013-10-14 05:18:58 +00:00
except ( KeyError , TypeError ) :
self . report_warning ( u ' There are no annotations to write. ' )
except ( OSError , IOError ) :
2013-10-22 12:49:34 +00:00
self . report_error ( u ' Cannot write annotations file: ' + annofn )
return
2013-10-14 05:18:58 +00:00
2013-06-25 22:02:15 +00:00
subtitles_are_requested = any ( [ self . params . get ( ' writesubtitles ' , False ) ,
2013-09-14 09:14:40 +00:00
self . params . get ( ' writeautomaticsub ' ) ] )
2013-06-25 22:02:15 +00:00
2013-10-22 12:49:34 +00:00
if subtitles_are_requested and ' subtitles ' in info_dict and info_dict [ ' subtitles ' ] :
2013-06-18 20:14:21 +00:00
# subtitles download errors are already managed as troubles in relevant IE
# that way it will silently go on when used with unsupporting IE
subtitles = info_dict [ ' subtitles ' ]
2013-11-13 16:06:02 +00:00
sub_format = self . params . get ( ' subtitlesformat ' , ' srt ' )
2013-06-26 09:03:44 +00:00
for sub_lang in subtitles . keys ( ) :
sub = subtitles [ sub_lang ]
2013-07-20 10:59:47 +00:00
if sub is None :
continue
2013-06-18 20:14:21 +00:00
try :
2013-07-20 10:48:57 +00:00
sub_filename = subtitles_filename ( filename , sub_lang , sub_format )
2013-06-18 20:14:21 +00:00
self . report_writesubtitles ( sub_filename )
with io . open ( encodeFilename ( sub_filename ) , ' w ' , encoding = ' utf-8 ' ) as subfile :
2013-06-26 09:03:44 +00:00
subfile . write ( sub )
2013-06-18 20:14:21 +00:00
except ( OSError , IOError ) :
self . report_error ( u ' Cannot write subtitles file ' + descfn )
return
if self . params . get ( ' writeinfojson ' , False ) :
2013-11-13 17:34:03 +00:00
infofn = os . path . splitext ( filename ) [ 0 ] + u ' .info.json '
2013-06-18 20:14:21 +00:00
self . report_writeinfojson ( infofn )
try :
2013-10-22 12:49:34 +00:00
json_info_dict = dict ( ( k , v ) for k , v in info_dict . items ( ) if not k in [ ' urlhandle ' ] )
2013-06-18 20:14:21 +00:00
write_json_file ( json_info_dict , encodeFilename ( infofn ) )
except ( OSError , IOError ) :
self . report_error ( u ' Cannot write metadata to JSON file ' + infofn )
return
if self . params . get ( ' writethumbnail ' , False ) :
2013-07-12 20:11:59 +00:00
if info_dict . get ( ' thumbnail ' ) is not None :
2013-07-12 19:52:59 +00:00
thumb_format = determine_ext ( info_dict [ ' thumbnail ' ] , u ' jpg ' )
2013-06-18 20:14:21 +00:00
thumb_filename = filename . rpartition ( ' . ' ) [ 0 ] + u ' . ' + thumb_format
self . to_screen ( u ' [ %s ] %s : Downloading thumbnail ... ' %
( info_dict [ ' extractor ' ] , info_dict [ ' id ' ] ) )
2013-09-27 12:19:19 +00:00
try :
uf = compat_urllib_request . urlopen ( info_dict [ ' thumbnail ' ] )
with open ( thumb_filename , ' wb ' ) as thumbf :
shutil . copyfileobj ( uf , thumbf )
self . to_screen ( u ' [ %s ] %s : Writing thumbnail to: %s ' %
( info_dict [ ' extractor ' ] , info_dict [ ' id ' ] , thumb_filename ) )
except ( compat_urllib_error . URLError , compat_http_client . HTTPException , socket . error ) as err :
self . report_warning ( u ' Unable to download thumbnail " %s " : %s ' %
( info_dict [ ' thumbnail ' ] , compat_str ( err ) ) )
2013-06-18 20:14:21 +00:00
if not self . params . get ( ' skip_download ' , False ) :
if self . params . get ( ' nooverwrites ' , False ) and os . path . exists ( encodeFilename ( filename ) ) :
success = True
else :
try :
success = self . fd . _do_download ( filename , info_dict )
except ( compat_urllib_error . URLError , compat_http_client . HTTPException , socket . error ) as err :
self . report_error ( u ' unable to download video data: %s ' % str ( err ) )
return
2013-09-20 11:26:03 +00:00
except ( OSError , IOError ) as err :
raise UnavailableVideoError ( err )
2013-06-18 20:14:21 +00:00
except ( ContentTooShortError , ) as err :
self . report_error ( u ' content too short (expected %s bytes and served %s ) ' % ( err . expected , err . downloaded ) )
return
if success :
try :
self . post_process ( filename , info_dict )
except ( PostProcessingError ) as err :
self . report_error ( u ' postprocessing: %s ' % str ( err ) )
return
2013-10-06 02:27:09 +00:00
self . record_download_archive ( info_dict )
2013-06-18 20:14:21 +00:00
def download ( self , url_list ) :
""" Download a given list of URLs. """
2013-11-25 21:15:20 +00:00
if ( len ( url_list ) > 1 and
' % ' not in self . params [ ' outtmpl ' ]
and self . params . get ( ' max_downloads ' ) != 1 ) :
2013-06-18 20:14:21 +00:00
raise SameFileError ( self . params [ ' outtmpl ' ] )
for url in url_list :
try :
#It also downloads the videos
2013-11-22 18:57:52 +00:00
self . extract_info ( url )
2013-06-18 20:14:21 +00:00
except UnavailableVideoError :
self . report_error ( u ' unable to download video ' )
except MaxDownloadsReached :
self . to_screen ( u ' [info] Maximum number of downloaded files reached. ' )
raise
return self . _download_retcode
2013-11-22 13:57:53 +00:00
def download_with_info_file ( self , info_filename ) :
with open ( info_filename , ' r ' ) as f :
# TODO: Check for errors
info = json . load ( f )
2013-12-03 19:16:52 +00:00
try :
self . process_ie_result ( info , download = True )
except DownloadError :
webpage_url = info . get ( ' webpage_url ' )
if webpage_url is not None :
self . report_warning ( u ' The info failed to download, trying with " %s " ' % webpage_url )
return self . download ( [ webpage_url ] )
else :
raise
return self . _download_retcode
2013-11-22 13:57:53 +00:00
2013-06-18 20:14:21 +00:00
def post_process ( self , filename , ie_info ) :
""" Run all the postprocessors on the given file. """
info = dict ( ie_info )
info [ ' filepath ' ] = filename
keep_video = None
for pp in self . _pps :
try :
2013-10-22 12:49:34 +00:00
keep_video_wish , new_info = pp . run ( info )
2013-06-18 20:14:21 +00:00
if keep_video_wish is not None :
if keep_video_wish :
keep_video = keep_video_wish
elif keep_video is None :
# No clear decision yet, let IE decide
keep_video = keep_video_wish
except PostProcessingError as e :
2013-07-31 19:20:46 +00:00
self . report_error ( e . msg )
2013-06-18 20:14:21 +00:00
if keep_video is False and not self . params . get ( ' keepvideo ' , False ) :
try :
self . to_screen ( u ' Deleting original file %s (pass -k to keep) ' % filename )
os . remove ( encodeFilename ( filename ) )
except ( IOError , OSError ) :
self . report_warning ( u ' Unable to remove downloaded video file ' )
2013-10-06 02:27:09 +00:00
2013-11-25 14:46:54 +00:00
def _make_archive_id ( self , info_dict ) :
# Future-proof against any change in case
# and backwards compatibility with prior versions
2013-11-25 21:57:15 +00:00
extractor = info_dict . get ( ' extractor_key ' )
2013-11-22 21:46:46 +00:00
if extractor is None :
if ' id ' in info_dict :
extractor = info_dict . get ( ' ie_key ' ) # key in a playlist
if extractor is None :
2013-11-25 14:46:54 +00:00
return None # Incomplete video information
return extractor . lower ( ) + u ' ' + info_dict [ ' id ' ]
def in_download_archive ( self , info_dict ) :
fn = self . params . get ( ' download_archive ' )
if fn is None :
return False
vid_id = self . _make_archive_id ( info_dict )
if vid_id is None :
2013-11-22 21:46:46 +00:00
return False # Incomplete video information
2013-11-25 14:46:54 +00:00
2013-10-06 02:27:09 +00:00
try :
with locked_file ( fn , ' r ' , encoding = ' utf-8 ' ) as archive_file :
for line in archive_file :
if line . strip ( ) == vid_id :
return True
except IOError as ioe :
if ioe . errno != errno . ENOENT :
raise
return False
def record_download_archive ( self , info_dict ) :
fn = self . params . get ( ' download_archive ' )
if fn is None :
return
2013-11-25 14:46:54 +00:00
vid_id = self . _make_archive_id ( info_dict )
assert vid_id
2013-10-06 02:27:09 +00:00
with locked_file ( fn , ' a ' , encoding = ' utf-8 ' ) as archive_file :
archive_file . write ( vid_id + u ' \n ' )
2013-07-02 08:08:58 +00:00
2013-10-21 12:09:38 +00:00
@staticmethod
2013-10-28 10:31:12 +00:00
def format_resolution ( format , default = ' unknown ' ) :
2013-11-25 21:34:56 +00:00
if format . get ( ' vcodec ' ) == ' none ' :
return ' audio only '
2013-10-29 14:09:45 +00:00
if format . get ( ' _resolution ' ) is not None :
return format [ ' _resolution ' ]
2013-10-21 12:09:38 +00:00
if format . get ( ' height ' ) is not None :
if format . get ( ' width ' ) is not None :
res = u ' %s x %s ' % ( format [ ' width ' ] , format [ ' height ' ] )
else :
res = u ' %s p ' % format [ ' height ' ]
else :
2013-10-28 10:31:12 +00:00
res = default
2013-10-21 12:09:38 +00:00
return res
2013-07-02 08:08:58 +00:00
def list_formats ( self , info_dict ) :
2013-11-16 00:08:43 +00:00
def format_note ( fdict ) :
res = u ' '
2013-11-25 02:12:26 +00:00
if fdict . get ( ' format_note ' ) is not None :
res + = fdict [ ' format_note ' ] + u ' '
2013-11-25 21:34:56 +00:00
if ( fdict . get ( ' vcodec ' ) is not None and
fdict . get ( ' vcodec ' ) != ' none ' ) :
2013-11-16 00:33:12 +00:00
res + = u ' %-5s ' % fdict [ ' vcodec ' ]
elif fdict . get ( ' vbr ' ) is not None :
res + = u ' video '
2013-11-16 00:08:43 +00:00
if fdict . get ( ' vbr ' ) is not None :
res + = u ' @ %4d k ' % fdict [ ' vbr ' ]
if fdict . get ( ' acodec ' ) is not None :
if res :
res + = u ' , '
2013-11-16 00:33:12 +00:00
res + = u ' %-5s ' % fdict [ ' acodec ' ]
elif fdict . get ( ' abr ' ) is not None :
if res :
res + = u ' , '
res + = ' audio '
2013-11-16 00:08:43 +00:00
if fdict . get ( ' abr ' ) is not None :
res + = u ' @ %3d k ' % fdict [ ' abr ' ]
2013-11-25 02:12:26 +00:00
if fdict . get ( ' filesize ' ) is not None :
if res :
res + = u ' , '
res + = format_bytes ( fdict [ ' filesize ' ] )
2013-11-16 00:08:43 +00:00
return res
2013-11-25 02:12:26 +00:00
def line ( format , idlen = 20 ) :
return ( ( u ' % - ' + compat_str ( idlen + 1 ) + u ' s %-10s %-12s %s ' ) % (
2013-10-21 12:09:38 +00:00
format [ ' format_id ' ] ,
format [ ' ext ' ] ,
self . format_resolution ( format ) ,
2013-11-16 00:08:43 +00:00
format_note ( format ) ,
2013-11-25 02:12:26 +00:00
) )
2013-10-29 14:09:45 +00:00
2013-10-30 00:09:26 +00:00
formats = info_dict . get ( ' formats ' , [ info_dict ] )
2013-11-25 02:12:26 +00:00
idlen = max ( len ( u ' format code ' ) ,
max ( len ( f [ ' format_id ' ] ) for f in formats ) )
formats_s = [ line ( f , idlen ) for f in formats ]
2013-10-30 00:09:26 +00:00
if len ( formats ) > 1 :
2013-11-16 00:39:45 +00:00
formats_s [ 0 ] + = ( ' ' if format_note ( formats [ 0 ] ) else ' ' ) + ' (worst) '
formats_s [ - 1 ] + = ( ' ' if format_note ( formats [ - 1 ] ) else ' ' ) + ' (best) '
2013-10-29 14:09:45 +00:00
header_line = line ( {
' format_id ' : u ' format code ' , ' ext ' : u ' extension ' ,
2013-11-25 02:12:26 +00:00
' _resolution ' : u ' resolution ' , ' format_note ' : u ' note ' } , idlen = idlen )
2013-10-29 14:09:45 +00:00
self . to_screen ( u ' [info] Available formats for %s : \n %s \n %s ' %
( info_dict [ ' id ' ] , header_line , u " \n " . join ( formats_s ) ) )
2013-11-22 18:57:52 +00:00
def urlopen ( self , req ) :
""" Start an HTTP download """
return self . _opener . open ( req )
def print_debug_header ( self ) :
if not self . params . get ( ' verbose ' ) :
return
write_string ( u ' [debug] youtube-dl version ' + __version__ + u ' \n ' )
try :
sp = subprocess . Popen (
[ ' git ' , ' rev-parse ' , ' --short ' , ' HEAD ' ] ,
stdout = subprocess . PIPE , stderr = subprocess . PIPE ,
cwd = os . path . dirname ( os . path . abspath ( __file__ ) ) )
out , err = sp . communicate ( )
out = out . decode ( ) . strip ( )
if re . match ( ' [0-9a-f]+ ' , out ) :
write_string ( u ' [debug] Git HEAD: ' + out + u ' \n ' )
except :
try :
sys . exc_clear ( )
except :
pass
write_string ( u ' [debug] Python version %s - %s ' %
( platform . python_version ( ) , platform_name ( ) ) + u ' \n ' )
proxy_map = { }
for handler in self . _opener . handlers :
if hasattr ( handler , ' proxies ' ) :
proxy_map . update ( handler . proxies )
write_string ( u ' [debug] Proxy map: ' + compat_str ( proxy_map ) + u ' \n ' )
2013-12-01 10:42:02 +00:00
def _setup_opener ( self ) :
2013-12-02 12:37:05 +00:00
timeout_val = self . params . get ( ' socket_timeout ' )
timeout = 600 if timeout_val is None else float ( timeout_val )
2013-11-22 18:57:52 +00:00
opts_cookiefile = self . params . get ( ' cookiefile ' )
opts_proxy = self . params . get ( ' proxy ' )
if opts_cookiefile is None :
self . cookiejar = compat_cookiejar . CookieJar ( )
else :
self . cookiejar = compat_cookiejar . MozillaCookieJar (
opts_cookiefile )
if os . access ( opts_cookiefile , os . R_OK ) :
self . cookiejar . load ( )
cookie_processor = compat_urllib_request . HTTPCookieProcessor (
self . cookiejar )
if opts_proxy is not None :
if opts_proxy == ' ' :
proxies = { }
else :
proxies = { ' http ' : opts_proxy , ' https ' : opts_proxy }
else :
proxies = compat_urllib_request . getproxies ( )
# Set HTTPS proxy to HTTP one if given (https://github.com/rg3/youtube-dl/issues/805)
if ' http ' in proxies and ' https ' not in proxies :
proxies [ ' https ' ] = proxies [ ' http ' ]
proxy_handler = compat_urllib_request . ProxyHandler ( proxies )
https_handler = make_HTTPS_handler (
self . params . get ( ' nocheckcertificate ' , False ) )
opener = compat_urllib_request . build_opener (
https_handler , proxy_handler , cookie_processor , YoutubeDLHandler ( ) )
# Delete the default user-agent header, which would otherwise apply in
# cases where our custom HTTP handler doesn't come into play
# (See https://github.com/rg3/youtube-dl/issues/1309 for details)
opener . addheaders = [ ]
self . _opener = opener
# TODO remove this global modification
compat_urllib_request . install_opener ( opener )
socket . setdefaulttimeout ( timeout )