X-Git-Url: https://jfr.im/git/z_archive/twitter.git/blobdiff_plain/4e7d9694a7ae245377d292693252fafb679cfd64..58ccea4e1489a735d2b01bcdd45677b2c4374f00:/twitter/api.py diff --git a/twitter/api.py b/twitter/api.py index 8c7b08a..6571735 100644 --- a/twitter/api.py +++ b/twitter/api.py @@ -74,14 +74,21 @@ class TwitterResponse(object): """ Remaining requests in the current rate-limit. """ - return int(self.headers.get('X-RateLimit-Remaining', "0")) + return int(self.headers.get('X-Rate-Limit-Remaining', "0")) + + @property + def rate_limit_limit(self): + """ + The rate limit ceiling for that given request. + """ + return int(self.headers.get('X-Rate-Limit-Limit', "0")) @property def rate_limit_reset(self): """ Time in UTC epoch seconds when the rate limit will reset. """ - return int(self.headers.get('X-RateLimit-Reset', "0")) + return int(self.headers.get('X-Rate-Limit-Reset', "0")) def wrap_response(response, headers): @@ -155,6 +162,15 @@ class TwitterCall(object): if id: uri += "/%s" %(id) + # If an _id kwarg is present, this is treated as id as a CGI + # param. + _id = kwargs.pop('_id', None) + if _id: + kwargs['id'] = _id + + # If an _timeout is specified in kwargs, use it + _timeout = kwargs.pop('_timeout', None) + secure_str = '' if self.secure: secure_str = 's' @@ -175,11 +191,14 @@ class TwitterCall(object): body = arg_data.encode('utf8') req = urllib_request.Request(uriBase, body, headers) - return self._handle_response(req, uri, arg_data) + return self._handle_response(req, uri, arg_data, _timeout) - def _handle_response(self, req, uri, arg_data): + def _handle_response(self, req, uri, arg_data, _timeout=None): + kwargs = {} + if _timeout: + kwargs['timeout'] = _timeout try: - handle = urllib_request.urlopen(req) + handle = urllib_request.urlopen(req, **kwargs) if handle.headers['Content-Type'] in ['image/jpeg', 'image/png']: return handle elif handle.info().get('Content-Encoding') == 'gzip': @@ -219,8 +238,8 @@ class Twitter(TwitterCall): t = Twitter( auth=OAuth(token, token_key, con_secret, con_secret_key))) - # Get the public timeline - t.statuses.public_timeline() + # Get your "home" timeline + t.statuses.home_timeline() # Get a particular friend's timeline t.statuses.friends_timeline(id="billybob") @@ -244,16 +263,19 @@ class Twitter(TwitterCall): # into the middle of a call. You can also use replacement: t.user.list.members(user="tamtar", list="things-that-are-rad") + # An *optional* `_timeout` parameter can also be used for API + # calls which take much more time than normal or twitter stops + # responding for some reasone + t.users.lookup( + screen_name=','.join(A_LIST_OF_100_SCREEN_NAMES), \ + _timeout=1) - Searching Twitter:: - twitter_search = Twitter(domain="search.twitter.com") - # Find the latest search trends - twitter_search.trends() + Searching Twitter:: - # Search for the latest News on #gaza - twitter_search.search(q="#gaza") + # Search for the latest tweets about #pycon + t.search.tweets(q="#pycon") Using the data returned @@ -262,7 +284,7 @@ class Twitter(TwitterCall): Twitter API calls return decoded JSON. This is converted into a bunch of Python lists, dicts, ints, and strings. For example:: - x = twitter.statuses.public_timeline() + x = twitter.statuses.home_timeline() # The first 'tweet' in the timeline x[0]