ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Merge upstream changes

Browse source
This commit is contained in:
Iiro Uusitalo 2015-07-10 08:44:20 +03:00
parent 403f4881ee
commit 4e7542af37
1 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
lib/ansible/module_utils/urls.py
View file

@ -413,7 +413,7 @@ class SSLValidationHandler(urllib2.BaseHandler):
# Write the dummy ca cert if we are running on Mac OS X # Write the dummy ca cert if we are running on Mac OS X
if system == 'Darwin': if system == 'Darwin':
os.write(tmp_fd, DUMMY_CA_CERT) os.write(tmp_fd, DUMMY_CA_CERT)
# Default Homebrew path for OpenSSL certs # Default Homebrew path for OpenSSL certs
paths_checked.append('/usr/local/etc/openssl') paths_checked.append('/usr/local/etc/openssl')
# for all of the paths, find any .crt or .pem files # for all of the paths, find any .crt or .pem files
@ -523,13 +523,11 @@ class SSLValidationHandler(urllib2.BaseHandler):
# Rewrite of fetch_url to not require the module environment # Rewrite of fetch_url to not require the module environment
def open_url(url, data=None, headers=None, method=None, use_proxy=True, def open_url(url, data=None, headers=None, method=None, use_proxy=True,
force=False, last_mod_time=None, timeout=10, validate_certs=True, force=False, last_mod_time=None, timeout=10, validate_certs=True,
url_username=None, url_password=None, http_agent=None): url_username=None, url_password=None, http_agent=None, force_basic_auth=False):
force_basic_auth = dict(required=False, type='bool')
''' '''
Fetches a file from an HTTP/FTP server using urllib2 Fetches a file from an HTTP/FTP server using urllib2
''' '''
handlers = [] handlers = []
# FIXME: change the following to use the generic_urlparse function # FIXME: change the following to use the generic_urlparse function
# to remove the indexed references for 'parsed' # to remove the indexed references for 'parsed'
parsed = urlparse.urlparse(url) parsed = urlparse.urlparse(url)
@ -556,7 +554,6 @@ def open_url(url, data=None, headers=None, method=None, use_proxy=True,
if parsed[0] != 'ftp': if parsed[0] != 'ftp':
username = url_username username = url_username
force_basic_auth = module.params.get('force_basic_auth', False)
if username: if username:
password = url_password password = url_password
@ -614,11 +611,11 @@ def open_url(url, data=None, headers=None, method=None, use_proxy=True,
else: else:
request = urllib2.Request(url, data) request = urllib2.Request(url, data)
# add the custom agent header, to help prevent issues # add the custom agent header, to help prevent issues
# with sites that block the default urllib agent string # with sites that block the default urllib agent string
request.add_header('User-agent', http_agent) request.add_header('User-agent', http_agent)
# if we're ok with getting a 304, set the timestamp in the # if we're ok with getting a 304, set the timestamp in the
# header, otherwise make sure we don't get a cached copy # header, otherwise make sure we don't get a cached copy
if last_mod_time and not force: if last_mod_time and not force:
tstamp = last_mod_time.strftime('%a, %d %b %Y %H:%M:%S +0000') tstamp = last_mod_time.strftime('%a, %d %b %Y %H:%M:%S +0000')
@ -659,9 +656,11 @@ def url_argument_spec():
validate_certs = dict(default='yes', type='bool'), validate_certs = dict(default='yes', type='bool'),
url_username = dict(required=False), url_username = dict(required=False),
url_password = dict(required=False), url_password = dict(required=False),
force_basic_auth = dict(required=False, type='bool', default='no'),
) )
def fetch_url(module, url, data=None, headers=None, method=None, def fetch_url(module, url, data=None, headers=None, method=None,
use_proxy=True, force=False, last_mod_time=None, timeout=10): use_proxy=True, force=False, last_mod_time=None, timeout=10):
''' '''
Fetches a file from an HTTP/FTP server using urllib2. Requires the module environment Fetches a file from an HTTP/FTP server using urllib2. Requires the module environment
@ -678,6 +677,7 @@ def fetch_url(module, url, data=None, headers=None, method=None,
username = module.params.get('url_username', '') username = module.params.get('url_username', '')
password = module.params.get('url_password', '') password = module.params.get('url_password', '')
http_agent = module.params.get('http_agent', None) http_agent = module.params.get('http_agent', None)
force_basic_auth = module.params.get('force_basic_auth', '')
r = None r = None
info = dict(url=url) info = dict(url=url)
@ -685,7 +685,7 @@ def fetch_url(module, url, data=None, headers=None, method=None,
r = open_url(url, data=data, headers=headers, method=method, r = open_url(url, data=data, headers=headers, method=method,
use_proxy=use_proxy, force=force, last_mod_time=last_mod_time, timeout=timeout, use_proxy=use_proxy, force=force, last_mod_time=last_mod_time, timeout=timeout,
validate_certs=validate_certs, url_username=username, validate_certs=validate_certs, url_username=username,
url_password=password, http_agent=http_agent) url_password=password, http_agent=http_agent, force_basic_auth=force_basic_auth)
info.update(r.info()) info.update(r.info())
info['url'] = r.geturl() # The URL goes in too, because of redirects. info['url'] = r.geturl() # The URL goes in too, because of redirects.
info.update(dict(msg="OK (%s bytes)" % r.headers.get('Content-Length', 'unknown'), status=200)) info.update(dict(msg="OK (%s bytes)" % r.headers.get('Content-Length', 'unknown'), status=200))