X-Git-Url: https://jfr.im/git/z_archive/twitter.git/blobdiff_plain/4b12a3a0d81d07d954935313642af53209dc3d40..c7dd86d1ada07b039ca1cefbdbc1d44b3076c7f9:/twitter/api.py diff --git a/twitter/api.py b/twitter/api.py index 52c800e..2c02790 100644 --- a/twitter/api.py +++ b/twitter/api.py @@ -13,6 +13,9 @@ try: except ImportError: import simplejson as json +class _DEFAULT(object): + pass + class TwitterError(Exception): """ Base Exception thrown by the Twitter object when there is a @@ -30,13 +33,14 @@ class TwitterHTTPError(TwitterError): self.uri = uri self.format = format self.uriparts = uriparts + self.response_data = self.e.fp.read() def __str__(self): return ( "Twitter sent status %i for URL: %s.%s using parameters: " "(%s)\ndetails: %s" %( self.e.code, self.uri, self.format, self.uriparts, - self.e.fp.read())) + self.response_data)) class TwitterResponse(object): """ @@ -75,22 +79,19 @@ def wrap_response(response, headers): class WrappedTwitterResponse(response_typ, TwitterResponse): __doc__ = TwitterResponse.__doc__ - def __init__(self, response): - if response_typ is not int: - response_typ.__init__(self, response) - TwitterResponse.__init__(self, headers) - return WrappedTwitterResponse(response) class TwitterCall(object): + def __init__( - self, auth, format, domain, uri="", + self, auth, format, domain, callable_cls, uri="", uriparts=None, secure=True): self.auth = auth self.format = format self.domain = domain + self.callable_cls = callable_cls self.uri = uri self.uriparts = uriparts self.secure = secure @@ -99,10 +100,16 @@ class TwitterCall(object): try: return object.__getattr__(self, k) except AttributeError: - return TwitterCall( - auth=self.auth, format=self.format, domain=self.domain, - uriparts=self.uriparts + (k,), - secure=self.secure) + 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) + if k == "_": + return extend_call + else: + return extend_call(k) def __call__(self, **kwargs): # Build the uri. @@ -145,7 +152,9 @@ class TwitterCall(object): body = arg_data.encode('utf8') req = urllib_request.Request(uriBase, body, headers) + return self._handle_response(req, uri, arg_data) + def _handle_response(self, req, uri, arg_data): try: handle = urllib_request.urlopen(req) if "json" == self.format: @@ -236,7 +245,7 @@ class Twitter(TwitterCall): def __init__( self, format="json", domain="api.twitter.com", secure=True, auth=None, - api_version='1'): + api_version=_DEFAULT): """ Create a new twitter API connector. @@ -256,7 +265,7 @@ class Twitter(TwitterCall): HTTPS. `api_version` is used to set the base uri. By default it's - '1'. + '1'. If you are using "search.twitter.com" set this to None. """ if not auth: auth = NoAuth() @@ -264,12 +273,19 @@ class Twitter(TwitterCall): if (format not in ("json", "xml", "")): raise ValueError("Unknown data format '%s'" %(format)) + if api_version is _DEFAULT: + if domain == 'api.twitter.com': + api_version = '1' + else: + api_version = None + uriparts = () if api_version: uriparts += (str(api_version),) TwitterCall.__init__( self, auth=auth, format=format, domain=domain, + callable_cls=TwitterCall, secure=secure, uriparts=uriparts)