mercurial/url.py

43505:47fac1692ede

                self.no_list = no_list

            # Keys and values need to be str because the standard library
            # expects them to be.
            proxyurl = str(proxy)
            proxies = {r'http': proxyurl, r'https': proxyurl}
            ui.debug(b'proxying through %s\n' % util.hidepassword(bytes(proxy)))
        else:
            proxies = {}

        urlreq.proxyhandler.__init__(self, proxies)

# Large parts of this function have their origin from before Python 2.6
# and could potentially be removed.
def _generic_start_transaction(handler, h, req):
    tunnel_host = req._tunnel_host
    if tunnel_host:
        if tunnel_host[:7] not in [r'http://', r'https:/']:
            tunnel_host = r'https://' + tunnel_host
        new_tunnel = True
    else:
        tunnel_host = urllibcompat.getselector(req)
        new_tunnel = False

def _generic_proxytunnel(self):
    proxyheaders = dict(
        [
            (x, self.headers[x])
            for x in self.headers
            if x.lower().startswith(r'proxy-')
        ]
    )
    self.send(b'CONNECT %s HTTP/1.0\r\n' % self.realhostport)
    for header in pycompat.iteritems(proxyheaders):
        self.send(b'%s: %s\r\n' % header)

        user, pw = self.passwd.find_user_password(
            realm, urllibcompat.getfullurl(req)
        )
        if pw is not None:
            raw = b"%s:%s" % (pycompat.bytesurl(user), pycompat.bytesurl(pw))
            auth = r'Basic %s' % pycompat.strurl(base64.b64encode(raw).strip())
            if req.get_header(self.auth_header, None) == auth:
                return None
            self.auth = auth
            req.add_unredirected_header(self.auth_header, auth)
            return self.parent.open(req)

    #
    # The custom user agent is for lfs, because unfortunately some servers
    # do look at this value.
    if not useragent:
        agent = b'mercurial/proto-1.0 (Mercurial %s)' % util.version()
        opener.addheaders = [(r'User-agent', pycompat.sysstr(agent))]
    else:
        opener.addheaders = [(r'User-agent', pycompat.sysstr(useragent))]

    # This header should only be needed by wire protocol requests. But it has
    # been sent on all requests since forever. We keep sending it for backwards
    # compatibility reasons. Modern versions of the wire protocol use
    # X-HgProto-<N> for advertising client support.
    if sendaccept:
        opener.addheaders.append((r'Accept', r'application/mercurial-0.1'))

    return opener


def open(ui, url_, data=None, sendaccept=True):

43506:9f70512ae2cf

                self.no_list = no_list

            # Keys and values need to be str because the standard library
            # expects them to be.
            proxyurl = str(proxy)
            proxies = {'http': proxyurl, 'https': proxyurl}
            ui.debug(b'proxying through %s\n' % util.hidepassword(bytes(proxy)))
        else:
            proxies = {}

        urlreq.proxyhandler.__init__(self, proxies)

# Large parts of this function have their origin from before Python 2.6
# and could potentially be removed.
def _generic_start_transaction(handler, h, req):
    tunnel_host = req._tunnel_host
    if tunnel_host:
        if tunnel_host[:7] not in ['http://', 'https:/']:
            tunnel_host = 'https://' + tunnel_host
        new_tunnel = True
    else:
        tunnel_host = urllibcompat.getselector(req)
        new_tunnel = False

def _generic_proxytunnel(self):
    proxyheaders = dict(
        [
            (x, self.headers[x])
            for x in self.headers
            if x.lower().startswith('proxy-')
        ]
    )
    self.send(b'CONNECT %s HTTP/1.0\r\n' % self.realhostport)
    for header in pycompat.iteritems(proxyheaders):
        self.send(b'%s: %s\r\n' % header)

        user, pw = self.passwd.find_user_password(
            realm, urllibcompat.getfullurl(req)
        )
        if pw is not None:
            raw = b"%s:%s" % (pycompat.bytesurl(user), pycompat.bytesurl(pw))
            auth = 'Basic %s' % pycompat.strurl(base64.b64encode(raw).strip())
            if req.get_header(self.auth_header, None) == auth:
                return None
            self.auth = auth
            req.add_unredirected_header(self.auth_header, auth)
            return self.parent.open(req)

    #
    # The custom user agent is for lfs, because unfortunately some servers
    # do look at this value.
    if not useragent:
        agent = b'mercurial/proto-1.0 (Mercurial %s)' % util.version()
        opener.addheaders = [('User-agent', pycompat.sysstr(agent))]
    else:
        opener.addheaders = [('User-agent', pycompat.sysstr(useragent))]

    # This header should only be needed by wire protocol requests. But it has
    # been sent on all requests since forever. We keep sending it for backwards
    # compatibility reasons. Modern versions of the wire protocol use
    # X-HgProto-<N> for advertising client support.
    if sendaccept:
        opener.addheaders.append(('Accept', 'application/mercurial-0.1'))

    return opener


def open(ui, url_, data=None, sendaccept=True):