mirror of https://github.com/scrapy/scrapy.git
py3: pass http proxy tests
This commit is contained in:
parent
c6f14a39de
commit
4950f5988e
|
|
@ -181,10 +181,11 @@ class ScrapyAgent(object):
|
|||
if proxy:
|
||||
_, _, proxyHost, proxyPort, proxyParams = _parse(proxy)
|
||||
scheme = _parse(request.url)[0]
|
||||
omitConnectTunnel = proxyParams.find('noconnect') >= 0
|
||||
proxyHost = to_unicode(proxyHost)
|
||||
omitConnectTunnel = proxyParams.find(b'noconnect') >= 0
|
||||
if scheme == b'https' and not omitConnectTunnel:
|
||||
proxyConf = (proxyHost, proxyPort,
|
||||
request.headers.get('Proxy-Authorization', None))
|
||||
request.headers.get(b'Proxy-Authorization', None))
|
||||
return self._TunnelingAgent(reactor, proxyConf,
|
||||
contextFactory=self._contextFactory, connectTimeout=timeout,
|
||||
bindAddress=bindaddress, pool=self._pool)
|
||||
|
|
@ -205,7 +206,7 @@ class ScrapyAgent(object):
|
|||
method = to_bytes(request.method)
|
||||
headers = TxHeaders(request.headers)
|
||||
if isinstance(agent, self._TunnelingAgent):
|
||||
headers.removeHeader('Proxy-Authorization')
|
||||
headers.removeHeader(b'Proxy-Authorization')
|
||||
bodyproducer = _RequestBodyProducer(request.body) if request.body else None
|
||||
|
||||
start_time = time()
|
||||
|
|
|
|||
|
|
@ -351,7 +351,7 @@ class HttpProxyTestCase(unittest.TestCase):
|
|||
def _test(response):
|
||||
self.assertEquals(response.status, 200)
|
||||
self.assertEquals(response.url, request.url)
|
||||
self.assertEquals(response.body, 'http://example.com')
|
||||
self.assertEquals(response.body, b'http://example.com')
|
||||
|
||||
http_proxy = self.getURL('')
|
||||
request = Request('http://example.com', meta={'proxy': http_proxy})
|
||||
|
|
@ -361,7 +361,7 @@ class HttpProxyTestCase(unittest.TestCase):
|
|||
def _test(response):
|
||||
self.assertEquals(response.status, 200)
|
||||
self.assertEquals(response.url, request.url)
|
||||
self.assertEquals(response.body, 'https://example.com')
|
||||
self.assertEquals(response.body, b'https://example.com')
|
||||
|
||||
http_proxy = '%s?noconnect' % self.getURL('')
|
||||
request = Request('https://example.com', meta={'proxy': http_proxy})
|
||||
|
|
@ -371,7 +371,7 @@ class HttpProxyTestCase(unittest.TestCase):
|
|||
def _test(response):
|
||||
self.assertEquals(response.status, 200)
|
||||
self.assertEquals(response.url, request.url)
|
||||
self.assertEquals(response.body, '/path/to/resource')
|
||||
self.assertEquals(response.body, b'/path/to/resource')
|
||||
|
||||
request = Request(self.getURL('path/to/resource'))
|
||||
return self.download_request(request, Spider('foo')).addCallback(_test)
|
||||
|
|
|
|||
Loading…
Reference in New Issue