From: Josh Roesslein Date: Tue, 14 Jul 2009 03:14:23 +0000 (-0500) Subject: Revert "Added support for callbacks." X-Git-Url: https://vcs.fsf.org/?a=commitdiff_plain;h=a4e16f364a7ba022577f21dade38e3e191b3df7b;p=tweepy.git Revert "Added support for callbacks." This reverts commit 58ee4790515e99f1486f63ff30dcbf6fe0ce11c2. --- diff --git a/binder.py b/binder.py index f41ef11..80bd8d3 100644 --- a/binder.py +++ b/binder.py @@ -1,19 +1,34 @@ import httplib import urllib -from threading import Thread from parsers import parse_error from error import TweepError def bind_api(path, parser, allowed_param=None, method='GET', require_auth=False): - def do_request(url, parameters, api): + def _call(api, *args, **kargs): + # If require auth, throw exception if credentials not provided + if require_auth and not api._b64up: + raise TweepError('Authentication required!') + + # Filter out unallowed parameters + if allowed_param: + parameters = dict((k,v) for k,v in kargs.items() if k in allowed_param) + else: + parameters = None + # Open connection if api.secure: conn = httplib.HTTPSConnection(api.host) else: conn = httplib.HTTPConnection(api.host) + # Build url with parameters + if parameters: + url = '%s?%s' % (path, urllib.urlencode(parameters)) + else: + url = path + # Assemble headers headers = { 'User-Agent': 'tweepy' @@ -38,34 +53,4 @@ def bind_api(path, parser, allowed_param=None, method='GET', require_auth=False) conn.close() return out - def async_request(url, parameters, api, callback): - out = do_request(url, parameters,api) - callback(out) - - def call(api, *args, **kargs): - # If require auth, throw exception if credentials not provided - if require_auth and not api._b64up: - raise TweepError('Authentication required!') - - # Filter out unallowed parameters - if allowed_param: - parameters = dict((k,v) for k,v in kargs.items() if k in allowed_param) - else: - parameters = None - - # Build url with parameters - if parameters: - url = '%s?%s' % (path, urllib.urlencode(parameters)) - else: - url = path - - # check for callback - callback = kargs.get('callback') - if callback: - # execute request async - Thread(target=async_request, args=(url, parameters, api, callback,)).start() - else: - # execute request sync - return do_request(url, parameters, api) - - return call + return _call