Commit ab63d08d authored by Julien Muchembled's avatar Julien Muchembled Committed by Xavier Thompson

[feat] download: add netrc file support

Like for URL that contain credentials, we still skip auth challenge
because it's faster and:
- we only support one auth scheme (basic)
- netrc provides no way to specify realms, which seem anyway to be
  less and less used (https://stackoverflow.com/q/69303610 reports
  that recent browsers don't display them anymore)

See merge request nexedi/slapos.buildout!25
parent 958c554f
...@@ -32,7 +32,9 @@ except ImportError: ...@@ -32,7 +32,9 @@ except ImportError:
from zc.buildout.easy_install import realpath from zc.buildout.easy_install import realpath
from base64 import b64encode from base64 import b64encode
from contextlib import closing from contextlib import closing
import errno
import logging import logging
import netrc
import os import os
import os.path import os.path
import re import re
...@@ -43,6 +45,23 @@ from . import bytes2str, str2bytes ...@@ -43,6 +45,23 @@ from . import bytes2str, str2bytes
from .rmtree import rmtree from .rmtree import rmtree
class netrc(netrc.netrc):
def __init__(*args):
pass
def authenticators(self, host):
self.__class__, = self.__class__.__bases__
try:
self.__init__()
except IOError as e:
if e.errno != errno.ENOENT:
raise
self.__init__(os.devnull)
return self.authenticators(host)
netrc = netrc()
class ChecksumError(zc.buildout.UserError): class ChecksumError(zc.buildout.UserError):
pass pass
...@@ -253,14 +272,20 @@ class Download(object): ...@@ -253,14 +272,20 @@ class Download(object):
def urlretrieve(self, url, tmp_path): def urlretrieve(self, url, tmp_path):
parsed_url = urlparse(url) parsed_url = urlparse(url)
req = url req = url
if parsed_url.scheme in ('http', 'https'): while parsed_url.scheme in ('http', 'https'): # not a loop
auth_host = parsed_url.netloc.rsplit('@', 1) auth_host = parsed_url.netloc.rsplit('@', 1)
if len(auth_host) > 1: if len(auth_host) > 1:
auth = auth_host[0] auth = auth_host[0]
url = parsed_url._replace(netloc=auth_host[1]).geturl() url = parsed_url._replace(netloc=auth_host[1]).geturl()
req = Request(url) else:
req.add_header("Authorization", auth = netrc.authenticators(parsed_url.hostname)
"Basic " + bytes2str(b64encode(str2bytes(auth)))) if not auth:
break
auth = '{0}:{2}'.format(*auth)
req = Request(url)
req.add_header("Authorization",
"Basic " + bytes2str(b64encode(str2bytes(auth))))
break
with closing(urlopen(req)) as src: with closing(urlopen(req)) as src:
with open(tmp_path, 'wb') as dst: with open(tmp_path, 'wb') as dst:
shutil.copyfileobj(src, dst) shutil.copyfileobj(src, dst)
......
...@@ -166,6 +166,24 @@ True ...@@ -166,6 +166,24 @@ True
Traceback (most recent call last): Traceback (most recent call last):
UserError: Error downloading ...: HTTP Error 403: Forbidden UserError: Error downloading ...: HTTP Error 403: Forbidden
... with netrc:
>>> url = server_url + 'private/foo:bar'
>>> download(url)
Traceback (most recent call last):
UserError: Error downloading ...: HTTP Error 403: Forbidden
>>> import os, zc.buildout.download
>>> old_home = os.environ['HOME']
>>> home = os.environ['HOME'] = tmpdir('test-netrc')
>>> netrc = join(home, '.netrc')
>>> write(netrc, 'machine localhost login foo password bar')
>>> os.chmod(netrc, 0o600)
>>> zc.buildout.download.netrc.__init__()
>>> path, is_temp = download(url)
>>> is_temp; remove(path)
True
>>> os.environ['HOME'] = old_home
Downloading using the download cache Downloading using the download cache
------------------------------------ ------------------------------------
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment