X-Git-Url: https://jfr.im/git/z_archive/twitter.git/blobdiff_plain/82a93c036394fa6d7b40914e21617c7494a193fd..d908997bbf25f5d00f527a86d0c9e0240ef2960d:/twitter/api.py diff --git a/twitter/api.py b/twitter/api.py index ba9ce5d..0e4377d 100644 --- a/twitter/api.py +++ b/twitter/api.py @@ -10,8 +10,8 @@ try: except ImportError: from io import BytesIO as StringIO -from twitter.twitter_globals import POST_ACTIONS -from twitter.auth import NoAuth +from .twitter_globals import POST_ACTIONS +from .auth import NoAuth import re import gzip @@ -108,6 +108,8 @@ def wrap_response(response, headers): if response_typ is bool: # HURF DURF MY NAME IS PYTHON AND I CAN'T SUBCLASS bool. response_typ = int + elif response_typ is str: + return response class WrappedTwitterResponse(response_typ, TwitterResponse): __doc__ = TwitterResponse.__doc__ @@ -118,7 +120,6 @@ def wrap_response(response, headers): def __new__(cls, response, headers): return response_typ.__new__(cls, response) - return WrappedTwitterResponse(response, headers) @@ -127,7 +128,7 @@ class TwitterCall(object): def __init__( self, auth, format, domain, callable_cls, uri="", - uriparts=None, secure=True): + uriparts=None, secure=True, timeout=None, gzip=False): self.auth = auth self.format = format self.domain = domain @@ -135,6 +136,8 @@ class TwitterCall(object): self.uri = uri self.uriparts = uriparts self.secure = secure + self.timeout = timeout + self.gzip = gzip def __getattr__(self, k): try: @@ -143,9 +146,9 @@ class TwitterCall(object): def extend_call(arg): return self.callable_cls( auth=self.auth, format=self.format, domain=self.domain, - callable_cls=self.callable_cls, uriparts=self.uriparts \ - + (arg,), - secure=self.secure) + callable_cls=self.callable_cls, timeout=self.timeout, + secure=self.secure, gzip=self.gzip, + uriparts=self.uriparts + (arg,)) if k == "_": return extend_call else: @@ -192,13 +195,13 @@ class TwitterCall(object): uriBase = "http%s://%s/%s%s%s" %( secure_str, self.domain, uri, dot, self.format) - headers = {'Accept-Encoding': 'gzip'} + headers = {'Accept-Encoding': 'gzip'} if self.gzip else dict() + body = None; arg_data = None if self.auth: headers.update(self.auth.generate_headers()) arg_data = self.auth.encode_params(uriBase, method, kwargs) if method == 'GET': uriBase += '?' + arg_data - body = None else: body = arg_data.encode('utf8')