From: Kenneth Reitz Date: Mon, 23 Jan 2012 05:15:25 +0000 (-0500) Subject: blah X-Git-Tag: v0.10.1~25 X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=b0e2e4f284f619536b7f405122bb1a93900cd743;p=services%2Fpython-requests.git blah --- diff --git a/requests/auth.py b/requests/auth.py index d1da4ee..61ea850 100644 --- a/requests/auth.py +++ b/requests/auth.py @@ -7,11 +7,14 @@ requests.auth This module contains the authentication handlers for Requests. """ +from __future__ import unicode_literals + import time import hashlib from base64 import b64encode -from urlparse import urlparse +# from urlparse import urlparse +from urllib.parse import urlparse from .utils import randombytes, parse_dict_header @@ -19,7 +22,8 @@ from .utils import randombytes, parse_dict_header def _basic_auth_str(username, password): """Returns a Basic Auth string.""" - return 'Basic %s' % b64encode('%s:%s' % (username, password)) + + return 'Basic ' + b64encode(("%s:%s" % (username, password)).encode('utf-8')).strip().decode('utf-8') class AuthBase(object): @@ -32,8 +36,8 @@ class AuthBase(object): class HTTPBasicAuth(AuthBase): """Attaches HTTP Basic Authentication to the given Request object.""" def __init__(self, username, password): - self.username = str(username) - self.password = str(password) + self.username = username + self.password = password def __call__(self, r): r.headers['Authorization'] = _basic_auth_str(self.username, self.password) @@ -101,10 +105,12 @@ class HTTPDigestAuth(AuthBase): last_nonce = nonce ncvalue = '%08x' % nonce_count - cnonce = (hashlib.sha1("%s:%s:%s:%s" % ( - nonce_count, nonce, time.ctime(), randombytes(8))) - .hexdigest()[:16] - ) + s = str(nonce_count).encode('utf-8') + s += nonce.encode('utf-8') + s += time.ctime().encode('utf-8') + s += randombytes(8) + + cnonce = (hashlib.sha1(s).hexdigest()[:16]) noncebit = "%s:%s:%s:%s:%s" % (nonce, ncvalue, cnonce, qop, H(A2)) respdig = KD(H(A1), noncebit) elif qop is None: diff --git a/requests/models.py b/requests/models.py index 84a2ec6..10e9231 100644 --- a/requests/models.py +++ b/requests/models.py @@ -8,15 +8,16 @@ This module contains the primary objects that power Requests. """ import os -import urllib +import urllib.request, urllib.parse, urllib.error -from urlparse import urlparse, urlunparse, urljoin, urlsplit +# from urlparse import urlparse, urlunparse, urljoin, urlsplit +from urllib.parse import urlparse, urlunparse, urljoin, urlsplit, urlencode from datetime import datetime from .hooks import dispatch_hook, HOOKS from .structures import CaseInsensitiveDict from .status_codes import codes -from .packages import oreos +# from .packages import oreos from .auth import HTTPBasicAuth, HTTPProxyAuth from .packages.urllib3.response import HTTPResponse from .packages.urllib3.exceptions import MaxRetryError @@ -29,7 +30,7 @@ from .exceptions import ( URLRequired, SSLError) from .utils import ( get_encoding_from_headers, stream_decode_response_unicode, - stream_decompress, guess_filename, requote_path) + stream_decompress, guess_filename, requote_path, dict_from_string) # Import chardet if it is available. try: @@ -70,6 +71,11 @@ class Request(object): self.timeout = timeout #: Request URL. + + # if isinstance(url, str): + # url = url.encode('utf-8') + # print(dir(url)) + self.url = url #: Dictionary of HTTP Headers to attach to the :class:`Request `. @@ -126,7 +132,7 @@ class Request(object): hooks = hooks or {} - for (k, v) in hooks.items(): + for (k, v) in list(hooks.items()): self.register_hook(event=k, hook=v) #: Session. @@ -141,7 +147,7 @@ class Request(object): headers = CaseInsensitiveDict() # Add configured base headers. - for (k, v) in self.config.get('base_headers', {}).items(): + for (k, v) in list(self.config.get('base_headers', {}).items()): if k not in headers: headers[k] = v @@ -186,7 +192,7 @@ class Request(object): # Add new cookies from the server. if 'set-cookie' in response.headers: cookie_header = response.headers['set-cookie'] - cookies = oreos.dict_from_string(cookie_header) + cookies = dict_from_string(cookie_header) # Save cookies in Response. response.cookies = cookies @@ -196,7 +202,7 @@ class Request(object): # Save original response for later. response.raw = resp - response.url = self.full_url.decode('utf-8') + response.url = self.full_url return response @@ -284,16 +290,17 @@ class Request(object): returns it twice. """ - if hasattr(data, '__iter__'): + if hasattr(data, '__iter__') and not isinstance(data, str): data = dict(data) + if hasattr(data, 'items'): result = [] - for k, vs in data.items(): + for k, vs in list(data.items()): for v in isinstance(vs, list) and vs or [vs]: - result.append((k.encode('utf-8') if isinstance(k, unicode) else k, - v.encode('utf-8') if isinstance(v, unicode) else v)) - return result, urllib.urlencode(result, doseq=True) + result.append((k.encode('utf-8') if isinstance(k, str) else k, + v.encode('utf-8') if isinstance(v, str) else v)) + return result, urlencode(result, doseq=True) else: return data, data @@ -304,20 +311,26 @@ class Request(object): if not self.url: raise URLRequired() + url = self.url + # Support for unicode domain names and paths. - scheme, netloc, path, params, query, fragment = urlparse(self.url) + scheme, netloc, path, params, query, fragment = urlparse(url) + if not scheme: - raise ValueError("Invalid URL %r: No schema supplied" %self.url) + raise ValueError("Invalid URL %r: No schema supplied" % url) - netloc = netloc.encode('idna') + netloc = netloc.encode('idna').decode('utf-8') - if isinstance(path, unicode): - path = path.encode('utf-8') + # if isinstance(path, str): + # path = path.encode('utf-8') - path = requote_path(path) + # path = requote_path(path) - url = str(urlunparse([ scheme, netloc, path, params, query, fragment ])) + # print([ scheme, netloc, path, params, query, fragment ]) + # print('---------------------') + + url = (urlunparse([ scheme, netloc, path, params, query, fragment ])) if self._enc_params: if urlparse(url).query: @@ -342,6 +355,10 @@ class Request(object): path = p.path if not path: path = '/' + + from urllib.parse import quote, unquote + + path = quote(path.encode('utf-8')) url.append(path) query = p.query @@ -349,6 +366,8 @@ class Request(object): url.append('?') url.append(query) + # print(url) + return ''.join(url) @@ -384,14 +403,14 @@ class Request(object): # Multi-part file uploads. if self.files: - if not isinstance(self.data, basestring): + if not isinstance(self.data, str): try: fields = self.data.copy() except AttributeError: fields = dict(self.data) - for (k, v) in self.files.items(): + for (k, v) in list(self.files.items()): # support for explicit filename if isinstance(v, (tuple, list)): fn, fp = v @@ -408,7 +427,7 @@ class Request(object): if self.data: body = self._enc_data - if isinstance(self.data, basestring): + if isinstance(self.data, str): content_type = None else: content_type = 'application/x-www-form-urlencoded' @@ -481,8 +500,10 @@ class Request(object): if 'cookie' not in self.headers: # Simple cookie with our dict. - c = oreos.monkeys.SimpleCookie() - for (k, v) in self.cookies.items(): + # c = oreos.monkeys.SimpleCookie() + from http.cookies import SimpleCookie + c = SimpleCookie() + for (k, v) in list(self.cookies.items()): c[k] = v # Turn it into a header. @@ -511,16 +532,16 @@ class Request(object): ) self.sent = True - except MaxRetryError, e: + except MaxRetryError as e: raise ConnectionError(e) - except (_SSLError, _HTTPError), e: + except (_SSLError, _HTTPError) as e: if self.verify and isinstance(e, _SSLError): raise SSLError(e) raise Timeout('Request timed out.') - except RequestException, e: + except RequestException as e: if self.config.get('safe_mode', False): # In safe mode, catch the exception and attach it to # a blank urllib3.HTTPResponse object. @@ -599,7 +620,7 @@ class Response(object): def __repr__(self): return '' % (self.status_code) - def __nonzero__(self): + def __bool__(self): """Returns true if :attr:`status_code` is 'OK'.""" return self.ok @@ -750,15 +771,15 @@ class Response(object): # Decode unicode from given encoding. try: - content = unicode(self.content, encoding) - except UnicodeError, TypeError: + content = str(self.content, encoding) + except (UnicodeError, TypeError): pass # Try to fall back: if not content: try: - content = unicode(content, encoding, errors='replace') - except UnicodeError, TypeError: + content = str(content, encoding, errors='replace') + except (UnicodeError, TypeError): pass diff --git a/requests/packages/oreos/monkeys.py b/requests/packages/oreos/monkeys.py index 6be3074..2269e30 100644 --- a/requests/packages/oreos/monkeys.py +++ b/requests/packages/oreos/monkeys.py @@ -318,7 +318,7 @@ _Translator = { '\375' : '\\375', '\376' : '\\376', '\377' : '\\377' } -_idmap = ''.join(chr(x) for x in xrange(256)) +_idmap = ''.join(chr(x) for x in range(256)) def _quote(str, LegalChars=_LegalChars, idmap=_idmap, translate=string.translate): diff --git a/requests/packages/urllib3/connectionpool.py b/requests/packages/urllib3/connectionpool.py index c5ad34a..b9c912f 100644 --- a/requests/packages/urllib3/connectionpool.py +++ b/requests/packages/urllib3/connectionpool.py @@ -15,13 +15,13 @@ try: # Python 3 from http.client import HTTPConnection, HTTPSConnection, HTTPException from http.client import HTTP_PORT, HTTPS_PORT except ImportError: - from httplib import HTTPConnection, HTTPSConnection, HTTPException - from httplib import HTTP_PORT, HTTPS_PORT + from http.client import HTTPConnection, HTTPSConnection, HTTPException + from http.client import HTTP_PORT, HTTPS_PORT try: # Python 3 from queue import Queue, Empty, Full except ImportError: - from Queue import Queue, Empty, Full + from queue import Queue, Empty, Full try: # Compiled with SSL? import ssl @@ -40,8 +40,8 @@ from .exceptions import (SSLError, EmptyPoolError, ) -from urllib3.packages.ssl_match_hostname import match_hostname, CertificateError -from urllib3.packages import six +from .packages.ssl_match_hostname import match_hostname, CertificateError +from .packages import six xrange = six.moves.xrange @@ -160,7 +160,7 @@ class HTTPConnectionPool(ConnectionPool, RequestMethods): self.headers = headers or {} # Fill the queue up so that doing get() on it will block properly - for _ in xrange(maxsize): + for _ in range(maxsize): self.pool.put(None) # These are mostly for testing and debugging purposes. diff --git a/requests/packages/urllib3/contrib/ntlmpool.py b/requests/packages/urllib3/contrib/ntlmpool.py index bb41fd1..443cb8f 100644 --- a/requests/packages/urllib3/contrib/ntlmpool.py +++ b/requests/packages/urllib3/contrib/ntlmpool.py @@ -13,7 +13,7 @@ Issue #10, see: http://code.google.com/p/urllib3/issues/detail?id=10 try: from http.client import HTTPSConnection except ImportError: - from httplib import HTTPSConnection + from http.client import HTTPSConnection from logging import getLogger from ntlm import ntlm diff --git a/requests/packages/urllib3/packages/__init__.py b/requests/packages/urllib3/packages/__init__.py index 37e8351..ec2d3b4 100644 --- a/requests/packages/urllib3/packages/__init__.py +++ b/requests/packages/urllib3/packages/__init__.py @@ -1,4 +1,4 @@ -from __future__ import absolute_import + from . import ssl_match_hostname diff --git a/requests/packages/urllib3/packages/six.py b/requests/packages/urllib3/packages/six.py index a64f6fb..2cd0458 100644 --- a/requests/packages/urllib3/packages/six.py +++ b/requests/packages/urllib3/packages/six.py @@ -39,10 +39,10 @@ if PY3: MAXSIZE = sys.maxsize else: - string_types = basestring, - integer_types = (int, long) - class_types = (type, types.ClassType) - text_type = unicode + string_types = str, + integer_types = (int, int) + class_types = (type, type) + text_type = str binary_type = str # It's possible to have sizeof(long) != sizeof(Py_ssize_t). @@ -230,11 +230,11 @@ if PY3: return any("__call__" in klass.__dict__ for klass in type(obj).__mro__) else: def get_unbound_function(unbound): - return unbound.im_func + return unbound.__func__ def advance_iterator(it): - return it.next() + return next(it) callable = callable _add_doc(get_unbound_function, @@ -278,10 +278,10 @@ else: def b(s): return s def u(s): - return unicode(s, "unicode_escape") + return str(s, "unicode_escape") int2byte = chr - import StringIO - StringIO = BytesIO = StringIO.StringIO + import io + StringIO = BytesIO = io.StringIO _add_doc(b, """Byte literal""") _add_doc(u, """Text literal""") @@ -325,19 +325,19 @@ else: if fp is None: return def write(data): - if not isinstance(data, basestring): + if not isinstance(data, str): data = str(data) fp.write(data) want_unicode = False sep = kwargs.pop("sep", None) if sep is not None: - if isinstance(sep, unicode): + if isinstance(sep, str): want_unicode = True elif not isinstance(sep, str): raise TypeError("sep must be None or a string") end = kwargs.pop("end", None) if end is not None: - if isinstance(end, unicode): + if isinstance(end, str): want_unicode = True elif not isinstance(end, str): raise TypeError("end must be None or a string") @@ -345,12 +345,12 @@ else: raise TypeError("invalid keyword arguments to print()") if not want_unicode: for arg in args: - if isinstance(arg, unicode): + if isinstance(arg, str): want_unicode = True break if want_unicode: - newline = unicode("\n") - space = unicode(" ") + newline = str("\n") + space = str(" ") else: newline = "\n" space = " " diff --git a/requests/packages/urllib3/request.py b/requests/packages/urllib3/request.py index 5ea26a0..d2efdd6 100644 --- a/requests/packages/urllib3/request.py +++ b/requests/packages/urllib3/request.py @@ -7,7 +7,7 @@ try: from urllib.parse import urlencode except ImportError: - from urllib import urlencode + from urllib.parse import urlencode from .filepost import encode_multipart_formdata diff --git a/requests/packages/urllib3/response.py b/requests/packages/urllib3/response.py index d0b371d..df95aad 100644 --- a/requests/packages/urllib3/response.py +++ b/requests/packages/urllib3/response.py @@ -67,7 +67,7 @@ class HTTPResponse(object): self.strict = strict self._decode_content = decode_content - self._body = body if body and isinstance(body, basestring) else None + self._body = body if body and isinstance(body, str) else None self._fp = None self._original_response = original_response diff --git a/requests/sessions.py b/requests/sessions.py index af9f9c7..d9683b0 100644 --- a/requests/sessions.py +++ b/requests/sessions.py @@ -25,7 +25,7 @@ def merge_kwargs(local_kwarg, default_kwarg): if default_kwarg is None: return local_kwarg - if isinstance(local_kwarg, basestring): + if isinstance(local_kwarg, str): return local_kwarg if local_kwarg is None: @@ -40,7 +40,7 @@ def merge_kwargs(local_kwarg, default_kwarg): kwargs.update(local_kwarg) # Remove keys that are set to None. - for (k,v) in local_kwarg.items(): + for (k,v) in list(local_kwarg.items()): if v is None: del kwargs[k] @@ -76,7 +76,7 @@ class Session(object): self.config = config or {} self.verify = verify - for (k, v) in defaults.items(): + for (k, v) in list(defaults.items()): self.config.setdefault(k, v) self.poolmanager = PoolManager( @@ -150,12 +150,12 @@ class Session(object): verify = self.verify # use session's hooks as defaults - for key, cb in self.hooks.iteritems(): + for key, cb in list(self.hooks.items()): hooks.setdefault(key, cb) # Expand header values. if headers: - for k, v in headers.items() or {}: + for k, v in list(headers.items()) or {}: headers[k] = header_expand(v) args = dict( diff --git a/requests/status_codes.py b/requests/status_codes.py index fab8e95..da74286 100644 --- a/requests/status_codes.py +++ b/requests/status_codes.py @@ -79,7 +79,7 @@ _codes = { codes = LookupDict(name='status_codes') -for (code, titles) in _codes.items(): +for (code, titles) in list(_codes.items()): for title in titles: setattr(codes, title, code) if not title.startswith('\\'): diff --git a/requests/structures.py b/requests/structures.py index 35a903f..3746754 100644 --- a/requests/structures.py +++ b/requests/structures.py @@ -18,7 +18,7 @@ class CaseInsensitiveDict(dict): @property def lower_keys(self): if not hasattr(self, '_lower_keys') or not self._lower_keys: - self._lower_keys = dict((k.lower(), k) for k in self.iterkeys()) + self._lower_keys = dict((k.lower(), k) for k in list(self.keys())) return self._lower_keys def _clear_lower_keys(self): @@ -63,4 +63,4 @@ class LookupDict(dict): return self.__dict__.get(key, None) def get(self, key, default=None): - return self.__dict__.get(key, default) \ No newline at end of file + return self.__dict__.get(key, default) diff --git a/requests/utils.py b/requests/utils.py index 95dea4b..673b46f 100644 --- a/requests/utils.py +++ b/requests/utils.py @@ -11,15 +11,34 @@ that are also useful for external consumption. import cgi import codecs -import cookielib +# import cookielib +from http import cookiejar as cookielib import os import random import re import zlib -import urllib +import urllib.request, urllib.parse, urllib.error -from urllib2 import parse_http_list as _parse_list_header +from urllib.parse import quote, unquote + +# from urllib2 import parse_http_list as _parse_list_header +from urllib.request import parse_http_list as _parse_list_header + +from http.cookies import SimpleCookie + +def dict_from_string(s): + """Returns a MultiDict with Cookies.""" + + cookies = dict() + + c = SimpleCookie() + c.load(s) + + for k,v in list(c.items()): + cookies.update({k: v.value}) + + return cookies def guess_filename(obj): """Tries to guess the filename of the given object.""" @@ -132,16 +151,16 @@ def header_expand(headers): collector = [] if isinstance(headers, dict): - headers = headers.items() + headers = list(headers.items()) - elif isinstance(headers, basestring): + elif isinstance(headers, str): return headers for i, (value, params) in enumerate(headers): _params = [] - for (p_k, p_v) in params.items(): + for (p_k, p_v) in list(params.items()): _params.append('%s=%s' % (p_k, p_v)) @@ -166,17 +185,8 @@ def header_expand(headers): def randombytes(n): """Return n random bytes.""" - # Use /dev/urandom if it is available. Fall back to random module - # if not. It might be worthwhile to extend this function to use - # other platform-specific mechanisms for getting random bytes. - if os.path.exists("/dev/urandom"): - f = open("/dev/urandom") - s = f.read(n) - f.close() - return s - else: - L = [chr(random.randrange(0, 256)) for i in range(n)] - return "".join(L) + L = [chr(random.randrange(0, 256)).encode('utf-8') for i in range(n)] + return b"".join(L) def dict_from_cookiejar(cj): @@ -187,9 +197,9 @@ def dict_from_cookiejar(cj): cookie_dict = {} - for _, cookies in cj._cookies.items(): - for _, cookies in cookies.items(): - for cookie in cookies.values(): + for _, cookies in list(cj._cookies.items()): + for _, cookies in list(cookies.items()): + for cookie in list(cookies.values()): # print cookie cookie_dict[cookie.name] = cookie.value @@ -221,7 +231,7 @@ def add_dict_to_cookiejar(cj, cookie_dict): :param cookie_dict: Dict of key/values to insert into CookieJar. """ - for k, v in cookie_dict.items(): + for k, v in list(cookie_dict.items()): cookie = cookielib.Cookie( version=0, @@ -290,7 +300,7 @@ def unicode_from_html(content): for encoding in encodings: try: - return unicode(content, encoding) + return str(content, encoding) except (UnicodeError, TypeError): pass @@ -337,13 +347,13 @@ def get_unicode_from_response(r): if encoding: try: - return unicode(r.content, encoding) + return str(r.content, encoding) except UnicodeError: tried_encodings.append(encoding) # Fall back: try: - return unicode(r.content, encoding, errors='replace') + return str(r.content, encoding, errors='replace') except TypeError: return r.content @@ -396,6 +406,6 @@ def requote_path(path): This function passes the given path through an unquote/quote cycle to ensure that it is fully and consistently quoted. """ - parts = path.split("/") - parts = (urllib.quote(urllib.unquote(part), safe="") for part in parts) - return "/".join(parts) + parts = path.split(b"/") + parts = (quote(unquote(part), safe=b"") for part in parts) + return b"/".join(parts) diff --git a/test_requests.py b/test_requests.py index 95de17c..a392684 100755 --- a/test_requests.py +++ b/test_requests.py @@ -3,16 +3,16 @@ -from __future__ import with_statement -import StringIO + +import io import time import os import sys import unittest import requests -import envoy +# import envoy from requests import HTTPError from requests.auth import HTTPBasicAuth, HTTPDigestAuth @@ -50,8 +50,8 @@ class RequestsTestSuite(unittest.TestCase): global _httpbin if (not 'HTTPBIN_URL' in os.environ) and not _httpbin: - c = envoy.connect('httpbin %s' % (PORT)) - time.sleep(1) + # c = envoy.connect('httpbin %s' % (PORT)) + # time.sleep(1) _httpbin = True @@ -94,7 +94,7 @@ class RequestsTestSuite(unittest.TestCase): r = requests.get(httpbin('user-agent'), headers=heads) - assert heads['User-agent'] in r.content + assert heads['User-agent'] in r.text self.assertEqual(r.status_code, 200) @@ -114,7 +114,7 @@ class RequestsTestSuite(unittest.TestCase): } r = requests.get(httpbin('user-agent'), headers=heads); - self.assertTrue(heads['User-agent'] in r.content) + self.assertTrue(heads['User-agent'] in r.text) heads = { 'user-agent': @@ -122,7 +122,7 @@ class RequestsTestSuite(unittest.TestCase): } r = requests.get(httpbin('user-agent'), headers=heads); - self.assertTrue(heads['user-agent'] in r.content) + self.assertTrue(heads['user-agent'] in r.text) def test_HTTP_200_OK_HEAD(self): @@ -290,7 +290,7 @@ class RequestsTestSuite(unittest.TestCase): response = requests.get(url) - self.assertIsInstance(response.url, unicode) + self.assertIsInstance(response.url, str) def test_unicode_get(self): @@ -299,11 +299,21 @@ class RequestsTestSuite(unittest.TestCase): url = service('/get') - requests.get(url, params={'foo': u'føø'}) - requests.get(url, params={u'føø': u'føø'}) + requests.get(url, params={'foo': 'føø'}) + requests.get(url, params={'føø': 'føø'}) requests.get(url, params={'føø': 'føø'}) - requests.get(url, params={'foo': u'foo'}) - requests.get(service('ø'), params={'foo': u'foo'}) + requests.get(url, params={'foo': 'foo'}) + # print('\n') + # print('\n') + # print('\n') + # print('\n') + # print(service('ø')) + # print('\n') + # print('\n') + # print('\n') + # print('\n') + # print('\n') + requests.get(service('ø'), params={'foo': 'foo'}) def test_httpauth_recursion(self): @@ -312,7 +322,7 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.get(service('basic-auth', 'user', 'pass'), auth=http_auth) - self.assertEquals(r.status_code, 401) + self.assertEqual(r.status_code, 401) def test_urlencoded_post_data(self): @@ -321,14 +331,14 @@ class RequestsTestSuite(unittest.TestCase): r = requests.post(service('post'), data=dict(test='fooaowpeuf')) - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') - self.assertEquals(r.url, service('post')) + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') + self.assertEqual(r.url, service('post')) - rbody = json.loads(r.content) + rbody = json.loads(r.text) - self.assertEquals(rbody.get('form'), dict(test='fooaowpeuf')) - self.assertEquals(rbody.get('data'), '') + self.assertEqual(rbody.get('form'), dict(test='fooaowpeuf')) + self.assertEqual(rbody.get('data'), '') def test_nonurlencoded_post_data(self): @@ -337,15 +347,15 @@ class RequestsTestSuite(unittest.TestCase): r = requests.post(service('post'), data='fooaowpeuf') - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') - self.assertEquals(r.url, service('post')) + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') + self.assertEqual(r.url, service('post')) - rbody = json.loads(r.content) + rbody = json.loads(r.text) # Body wasn't valid url encoded data, so the server returns None as # "form" and the raw body as "data". - self.assertEquals(rbody.get('form'), {}) - self.assertEquals(rbody.get('data'), 'fooaowpeuf') + self.assertEqual(rbody.get('form'), {}) + self.assertEqual(rbody.get('data'), 'fooaowpeuf') def test_urlencoded_post_querystring(self): @@ -354,13 +364,13 @@ class RequestsTestSuite(unittest.TestCase): r = requests.post(service('post'), params=dict(test='fooaowpeuf')) - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') - self.assertEquals(r.url, service('post?test=fooaowpeuf')) + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') + self.assertEqual(r.url, service('post?test=fooaowpeuf')) - rbody = json.loads(r.content) - self.assertEquals(rbody.get('form'), {}) # No form supplied - self.assertEquals(rbody.get('data'), '') + rbody = json.loads(r.text) + self.assertEqual(rbody.get('form'), {}) # No form supplied + self.assertEqual(rbody.get('data'), '') def test_urlencoded_post_query_and_data(self): @@ -372,13 +382,13 @@ class RequestsTestSuite(unittest.TestCase): params=dict(test='fooaowpeuf'), data=dict(test2="foobar")) - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') - self.assertEquals(r.url, service('post?test=fooaowpeuf')) + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') + self.assertEqual(r.url, service('post?test=fooaowpeuf')) - rbody = json.loads(r.content) - self.assertEquals(rbody.get('form'), dict(test2='foobar')) - self.assertEquals(rbody.get('data'), '') + rbody = json.loads(r.text) + self.assertEqual(rbody.get('form'), dict(test2='foobar')) + self.assertEqual(rbody.get('data'), '') def test_nonurlencoded_postdata(self): @@ -387,13 +397,13 @@ class RequestsTestSuite(unittest.TestCase): r = requests.post(service('post'), data="foobar") - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') - rbody = json.loads(r.content) + rbody = json.loads(r.text) - self.assertEquals(rbody.get('form'), {}) - self.assertEquals(rbody.get('data'), 'foobar') + self.assertEqual(rbody.get('form'), {}) + self.assertEqual(rbody.get('data'), 'foobar') # def test_idna(self): @@ -406,8 +416,8 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.get(service('get'), params=dict(test=['foo','baz'])) - self.assertEquals(r.status_code, 200) - self.assertEquals(r.url, service('get?test=foo&test=baz')) + self.assertEqual(r.status_code, 200) + self.assertEqual(r.url, service('get?test=foo&test=baz')) def test_urlencoded_post_querystring_multivalued(self): @@ -415,13 +425,13 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.post(service('post'), params=dict(test=['foo','baz'])) - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') - self.assertEquals(r.url, service('post?test=foo&test=baz')) + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') + self.assertEqual(r.url, service('post?test=foo&test=baz')) - rbody = json.loads(r.content) - self.assertEquals(rbody.get('form'), {}) # No form supplied - self.assertEquals(rbody.get('data'), '') + rbody = json.loads(r.text) + self.assertEqual(rbody.get('form'), {}) # No form supplied + self.assertEqual(rbody.get('data'), '') def test_urlencoded_post_query_multivalued_and_data(self): @@ -433,12 +443,16 @@ class RequestsTestSuite(unittest.TestCase): params=dict(test=['foo','baz']), data=dict(test2="foobar",test3=['foo','baz'])) - self.assertEquals(r.status_code, 200) - self.assertEquals(r.headers['content-type'], 'application/json') - self.assertEquals(r.url, service('post?test=foo&test=baz')) - rbody = json.loads(r.content) - self.assertEquals(rbody.get('form'), dict(test2='foobar',test3=['foo','baz'])) - self.assertEquals(rbody.get('data'), '') + self.assertEqual(r.status_code, 200) + self.assertEqual(r.headers['content-type'], 'application/json') + self.assertEqual(r.url, service('post?test=foo&test=baz')) + + # print(r.text) + # print('-----------------------') + + rbody = json.loads(r.text) + self.assertEqual(rbody.get('form'), dict(test2='foobar',test3=['foo','baz'])) + self.assertEqual(rbody.get('data'), '') def test_GET_no_redirect(self): @@ -446,8 +460,8 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.get(service('redirect', '3'), allow_redirects=False) - self.assertEquals(r.status_code, 302) - self.assertEquals(len(r.history), 0) + self.assertEqual(r.status_code, 302) + self.assertEqual(len(r.history), 0) def test_HEAD_no_redirect(self): @@ -455,8 +469,8 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.head(service('redirect', '3'), allow_redirects=False) - self.assertEquals(r.status_code, 302) - self.assertEquals(len(r.history), 0) + self.assertEqual(r.status_code, 302) + self.assertEqual(len(r.history), 0) def test_redirect_history(self): @@ -464,8 +478,8 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.get(service('redirect', '3')) - self.assertEquals(r.status_code, 200) - self.assertEquals(len(r.history), 3) + self.assertEqual(r.status_code, 200) + self.assertEqual(len(r.history), 3) def test_relative_redirect_history(self): @@ -473,8 +487,8 @@ class RequestsTestSuite(unittest.TestCase): for service in SERVICES: r = requests.get(service('relative-redirect', '3')) - self.assertEquals(r.status_code, 200) - self.assertEquals(len(r.history), 3) + self.assertEqual(r.status_code, 200) + self.assertEqual(len(r.history), 3) def test_session_HTTP_200_OK_GET(self): @@ -493,14 +507,14 @@ class RequestsTestSuite(unittest.TestCase): # Make 2 requests from Session object, should send header both times r1 = s.get(httpbin('user-agent')) - assert heads['User-agent'] in r1.content + assert heads['User-agent'] in r1.text r2 = s.get(httpbin('user-agent')) - assert heads['User-agent'] in r2.content + assert heads['User-agent'] in r2.text new_heads = {'User-agent': 'blah'} r3 = s.get(httpbin('user-agent'), headers=new_heads) - assert new_heads['User-agent'] in r3.content + assert new_heads['User-agent'] in r3.text self.assertEqual(r2.status_code, 200) @@ -526,7 +540,7 @@ class RequestsTestSuite(unittest.TestCase): } ) - assert 'foo' in response.content + assert 'foo' in response.text def test_multiple_hooks(self): @@ -560,8 +574,8 @@ class RequestsTestSuite(unittest.TestCase): } ) - assert 'foo' in response.content - assert 'bar' in response.content + assert 'foo' in response.text + assert 'bar' in response.text def test_session_persistent_cookies(self): @@ -573,35 +587,35 @@ class RequestsTestSuite(unittest.TestCase): r = s.get(httpbin('cookies')) # Those cookies persist transparently. - c = json.loads(r.content).get('cookies') + c = json.loads(r.text).get('cookies') assert c == _c # Double check. r = s.get(httpbin('cookies'), cookies={}) - c = json.loads(r.content).get('cookies') + c = json.loads(r.text).get('cookies') assert c == _c # Remove a cookie by setting it's value to None. r = s.get(httpbin('cookies'), cookies={'bessie': None}) - c = json.loads(r.content).get('cookies') + c = json.loads(r.text).get('cookies') del _c['bessie'] assert c == _c # Test session-level cookies. s = requests.session(cookies=_c) r = s.get(httpbin('cookies')) - c = json.loads(r.content).get('cookies') + c = json.loads(r.text).get('cookies') assert c == _c # Have the server set a cookie. r = s.get(httpbin('cookies', 'set', 'k', 'v'), allow_redirects=True) - c = json.loads(r.content).get('cookies') + c = json.loads(r.text).get('cookies') assert 'k' in c # And server-set cookie persistience. r = s.get(httpbin('cookies')) - c = json.loads(r.content).get('cookies') + c = json.loads(r.text).get('cookies') assert 'k' in c @@ -616,23 +630,23 @@ class RequestsTestSuite(unittest.TestCase): # Make 2 requests from Session object, should send header both times r1 = s.get(httpbin('get')) - assert params['a'] in r1.content + assert params['a'] in r1.text params2 = {'b': 'b_test'} r2 = s.get(httpbin('get'), params=params2) - assert params['a'] in r2.content - assert params2['b'] in r2.content + assert params['a'] in r2.text + assert params2['b'] in r2.text params3 = {'b': 'b_test', 'a': None, 'c': 'c_test'} r3 = s.get(httpbin('get'), params=params3) - assert not params['a'] in r3.content - assert params3['b'] in r3.content - assert params3['c'] in r3.content + assert not params['a'] in r3.text + assert params3['b'] in r3.text + assert params3['c'] in r3.text def test_invalid_content(self): # WARNING: if you're using a terrible DNS provider (comcast), @@ -653,12 +667,14 @@ class RequestsTestSuite(unittest.TestCase): def test_cached_response(self): r1 = requests.get(httpbin('get'), prefetch=False) + assert not r1._content assert r1.content - assert r1.content + assert r1.text r2 = requests.get(httpbin('get'), prefetch=True) assert r2._content assert r2.content + assert r2.text def test_iter_lines(self): @@ -680,7 +696,7 @@ class RequestsTestSuite(unittest.TestCase): # Make a request and monkey-patch its contents r = requests.get(httpbin('get')) - r.raw = StringIO.StringIO(quote) + r.raw = io.StringIO(quote) # Make sure iter_lines doesn't chop the trailing bit lines = '\n'.join(r.iter_lines()) @@ -693,11 +709,11 @@ class RequestsTestSuite(unittest.TestCase): # Safe mode creates empty responses for failed requests. # Iterating on these responses should produce empty sequences r = safe.get('http://_/') - self.assertEquals(list(r.iter_lines()), []) + self.assertEqual(list(r.iter_lines()), []) self.assertIsInstance(r.error, requests.exceptions.ConnectionError) r = safe.get('http://_/') - self.assertEquals(list(r.iter_content()), []) + self.assertEqual(list(r.iter_content()), []) self.assertIsInstance(r.error, requests.exceptions.ConnectionError) # When not in safe mode, should raise Timeout exception