repos/twython
1
Fork 0
Code Issues 23 Pull requests 4 Projects Releases 5 Packages Wiki Activity Actions

removed XML files from pycharm, and fixed indentation chaos i created

Browse source 
back to original indentation
This commit is contained in:
Luis Morales 2011-08-30 20:37:13 +02:00
parent 1a8230bd3e
commit b4da474671
7 changed files with 438 additions and 490 deletions
Download patch file Download diff file Expand all files Collapse all files

1
.gitignore vendored
View file

@ -3,3 +3,4 @@ build
dist dist
twython.egg-info twython.egg-info
*.swp *.swp
.idea

5
.idea/encodings.xml generated
View file

@ -1,5 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding" useUTFGuessing="true" native2AsciiForPropertiesFiles="false" />
</project>

8
.idea/misc.xml generated
View file

@ -1,8 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="DependencyValidationManager">
<option name="SKIP_IMPORT_STATEMENTS" value="false" />
</component>
<component name="ProjectRootManager" version="2" project-jdk-name="Python 2.7.1 (C:/projects/critiqus/environment/Scripts/python.exe)" project-jdk-type="Python SDK" />
</project>

9
.idea/modules.xml generated
View file

@ -1,9 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/.idea/twython.iml" filepath="$PROJECT_DIR$/.idea/twython.iml" />
</modules>
</component>
</project>

9
.idea/twython.iml generated
View file

@ -1,9 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<module type="PYTHON_MODULE" version="4">
<component name="NewModuleRootManager">
<content url="file://$MODULE_DIR$" />
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
</component>
</module>

7
.idea/vcs.xml generated
View file

@ -1,7 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$" vcs="Git" />
</component>
</project>

889
twython/twython.py
View file

@ -34,489 +34,474 @@ from urllib2 import HTTPError
# simplejson exists behind the scenes anyway. Past Python 2.6, this should # simplejson exists behind the scenes anyway. Past Python 2.6, this should
# never really cause any problems to begin with. # never really cause any problems to begin with.
try: try:
# Python 2.6 and up # Python 2.6 and up
import json as simplejson import json as simplejson
except ImportError: except ImportError:
try: try:
# Python 2.6 and below (2.4/2.5, 2.3 is not guranteed to work with this library to begin with) # Python 2.6 and below (2.4/2.5, 2.3 is not guranteed to work with this library to begin with)
import simplejson import simplejson
except ImportError: except ImportError:
try: try:
# This case gets rarer by the day, but if we need to, we can pull it from Django provided it's there. # This case gets rarer by the day, but if we need to, we can pull it from Django provided it's there.
from django.utils import simplejson from django.utils import simplejson
except: except:
# Seriously wtf is wrong with you if you get this Exception. # Seriously wtf is wrong with you if you get this Exception.
raise Exception( raise Exception("Twython requires the simplejson library (or Python 2.6) to work. http://www.undefined.org/python/")
"Twython requires the simplejson library (or Python 2.6) to work. http://www.undefined.org/python/")
# Try and gauge the old OAuth2 library spec. Versions 1.5 and greater no longer have the callback # Try and gauge the old OAuth2 library spec. Versions 1.5 and greater no longer have the callback
# url as part of the request object; older versions we need to patch for Python 2.5... ugh. ;P # url as part of the request object; older versions we need to patch for Python 2.5... ugh. ;P
OAUTH_CALLBACK_IN_URL = False OAUTH_CALLBACK_IN_URL = False
OAUTH_LIB_SUPPORTS_CALLBACK = False OAUTH_LIB_SUPPORTS_CALLBACK = False
if float(oauth._version.manual_verstr) <= 1.4: if float(oauth._version.manual_verstr) <= 1.4:
OAUTH_CLIENT_INSPECTION = inspect.getargspec(oauth.Client.request) OAUTH_CLIENT_INSPECTION = inspect.getargspec(oauth.Client.request)
try: try:
OAUTH_LIB_SUPPORTS_CALLBACK = 'callback_url' in OAUTH_CLIENT_INSPECTION.args OAUTH_LIB_SUPPORTS_CALLBACK = 'callback_url' in OAUTH_CLIENT_INSPECTION.args
except AttributeError: except AttributeError:
# Python 2.5 doesn't return named tuples, so don't look for an args section specifically. # Python 2.5 doesn't return named tuples, so don't look for an args section specifically.
OAUTH_LIB_SUPPORTS_CALLBACK = 'callback_url' in OAUTH_CLIENT_INSPECTION OAUTH_LIB_SUPPORTS_CALLBACK = 'callback_url' in OAUTH_CLIENT_INSPECTION
else: else:
OAUTH_CALLBACK_IN_URL = True OAUTH_CALLBACK_IN_URL = True
class TwythonError(AttributeError): class TwythonError(AttributeError):
""" """
Generic error class, catch-all for most Twython issues. Generic error class, catch-all for most Twython issues.
Special cases are handled by APILimit and AuthError. Special cases are handled by APILimit and AuthError.
Note: To use these, the syntax has changed as of Twython 1.3. To catch these, Note: To use these, the syntax has changed as of Twython 1.3. To catch these,
you need to explicitly import them into your code, e.g: you need to explicitly import them into your code, e.g:
from twython import TwythonError, APILimit, AuthError from twython import TwythonError, APILimit, AuthError
""" """
def __init__(self, msg, error_code=None):
self.msg = msg
if error_code == 400:
raise APILimit(msg)
def __init__(self, msg, error_code=None): def __str__(self):
self.msg = msg return repr(self.msg)
if error_code == 400:
raise APILimit(msg)
def __str__(self):
return repr(self.msg)
class APILimit(TwythonError): class APILimit(TwythonError):
""" """
Raised when you've hit an API limit. Try to avoid these, read the API Raised when you've hit an API limit. Try to avoid these, read the API
docs if you're running into issues here, Twython does not concern itself with docs if you're running into issues here, Twython does not concern itself with
this matter beyond telling you that you've done goofed. this matter beyond telling you that you've done goofed.
""" """
def __init__(self, msg):
self.msg = msg
def __init__(self, msg): def __str__(self):
self.msg = msg return repr(self.msg)
def __str__(self):
return repr(self.msg)
class AuthError(TwythonError): class AuthError(TwythonError):
""" """
Raised when you try to access a protected resource and it fails due to some issue with Raised when you try to access a protected resource and it fails due to some issue with
your authentication. your authentication.
""" """
def __init__(self, msg):
self.msg = msg
def __init__(self, msg): def __str__(self):
self.msg = msg return repr(self.msg)
def __str__(self):
return repr(self.msg)
class Twython(object): class Twython(object):
def __init__(self, twitter_token=None, twitter_secret=None, oauth_token=None, oauth_token_secret=None, headers=None, def __init__(self, twitter_token = None, twitter_secret = None, oauth_token = None, oauth_token_secret = None, headers=None, callback_url=None, client_args={}):
callback_url=None, client_args={}): """setup(self, oauth_token = None, headers = None)
"""setup(self, oauth_token = None, headers = None)
Instantiates an instance of Twython. Takes optional parameters for authentication and such (see below).
Instantiates an instance of Twython. Takes optional parameters for authentication and such (see below).
Parameters:
Parameters: twitter_token - Given to you when you register your application with Twitter.
twitter_token - Given to you when you register your application with Twitter. twitter_secret - Given to you when you register your application with Twitter.
twitter_secret - Given to you when you register your application with Twitter. oauth_token - If you've gone through the authentication process and have a token for this user,
oauth_token - If you've gone through the authentication process and have a token for this user, pass it in and it'll be used for all requests going forward.
pass it in and it'll be used for all requests going forward. oauth_token_secret - see oauth_token; it's the other half.
oauth_token_secret - see oauth_token; it's the other half. headers - User agent header, dictionary style ala {'User-Agent': 'Bert'}
headers - User agent header, dictionary style ala {'User-Agent': 'Bert'} client_args - additional arguments for HTTP client (see httplib2.Http.__init__), e.g. {'timeout': 10.0}
client_args - additional arguments for HTTP client (see httplib2.Http.__init__), e.g. {'timeout': 10.0}
** Note: versioning is not currently used by search.twitter functions; when Twitter moves their junk, it'll be supported.
** Note: versioning is not currently used by search.twitter functions; when Twitter moves their junk, it'll be supported. """
""" # Needed for hitting that there API.
# Needed for hitting that there API. self.request_token_url = 'http://twitter.com/oauth/request_token'
self.request_token_url = 'http://twitter.com/oauth/request_token' self.access_token_url = 'http://twitter.com/oauth/access_token'
self.access_token_url = 'http://twitter.com/oauth/access_token' self.authorize_url = 'http://twitter.com/oauth/authorize'
self.authorize_url = 'http://twitter.com/oauth/authorize' self.authenticate_url = 'http://twitter.com/oauth/authenticate'
self.authenticate_url = 'http://twitter.com/oauth/authenticate' self.twitter_token = twitter_token
self.twitter_token = twitter_token self.twitter_secret = twitter_secret
self.twitter_secret = twitter_secret self.oauth_token = oauth_token
self.oauth_token = oauth_token self.oauth_secret = oauth_token_secret
self.oauth_secret = oauth_token_secret self.callback_url = callback_url
self.callback_url = callback_url
# If there's headers, set them, otherwise be an embarassing parent for their own good.
# If there's headers, set them, otherwise be an embarassing parent for their own good. self.headers = headers
self.headers = headers if self.headers is None:
if self.headers is None: self.headers = {'User-agent': 'Twython Python Twitter Library v1.3'}
self.headers = {'User-agent': 'Twython Python Twitter Library v1.3'}
consumer = None
consumer = None token = None
token = None
if self.twitter_token is not None and self.twitter_secret is not None:
if self.twitter_token is not None and self.twitter_secret is not None: consumer = oauth.Consumer(self.twitter_token, self.twitter_secret)
consumer = oauth.Consumer(self.twitter_token, self.twitter_secret)
if self.oauth_token is not None and self.oauth_secret is not None:
if self.oauth_token is not None and self.oauth_secret is not None: token = oauth.Token(oauth_token, oauth_token_secret)
token = oauth.Token(oauth_token, oauth_token_secret)
# Filter down through the possibilities here - if they have a token, if they're first stage, etc.
# Filter down through the possibilities here - if they have a token, if they're first stage, etc. if consumer is not None and token is not None:
if consumer is not None and token is not None: self.client = oauth.Client(consumer, token, **client_args)
self.client = oauth.Client(consumer, token, **client_args) elif consumer is not None:
elif consumer is not None: self.client = oauth.Client(consumer, **client_args)
self.client = oauth.Client(consumer, **client_args) else:
else: # If they don't do authentication, but still want to request unprotected resources, we need an opener.
# If they don't do authentication, but still want to request unprotected resources, we need an opener. self.client = httplib2.Http(**client_args)
self.client = httplib2.Http(**client_args)
def __getattr__(self, api_call):
def __getattr__(self, api_call): """
""" The most magically awesome block of code you'll see in 2010.
The most magically awesome block of code you'll see in 2010.
Rather than list out 9 million damn methods for this API, we just keep a table (see above) of
Rather than list out 9 million damn methods for this API, we just keep a table (see above) of every API endpoint and their corresponding function id for this library. This pretty much gives
every API endpoint and their corresponding function id for this library. This pretty much gives unlimited flexibility in API support - there's a slight chance of a performance hit here, but if this is
unlimited flexibility in API support - there's a slight chance of a performance hit here, but if this is going to be your bottleneck... well, don't use Python. ;P
going to be your bottleneck... well, don't use Python. ;P
For those who don't get what's going on here, Python classes have this great feature known as __getattr__().
For those who don't get what's going on here, Python classes have this great feature known as __getattr__(). It's called when an attribute that was called on an object doesn't seem to exist - since it doesn't exist,
It's called when an attribute that was called on an object doesn't seem to exist - since it doesn't exist, we can take over and find the API method in our table. We then return a function that downloads and parses
we can take over and find the API method in our table. We then return a function that downloads and parses what we're looking for, based on the keywords passed in.
what we're looking for, based on the keywords passed in.
I'll hate myself for saying this, but this is heavily inspired by Ruby's "method_missing".
I'll hate myself for saying this, but this is heavily inspired by Ruby's "method_missing". """
""" def get(self, **kwargs):
# Go through and replace any mustaches that are in our API url.
def get(self, **kwargs): fn = api_table[api_call]
# Go through and replace any mustaches that are in our API url. base = re.sub(
fn = api_table[api_call] '\{\{(?P<m>[a-zA-Z_]+)\}\}',
base = re.sub( lambda m: "%s" % kwargs.get(m.group(1), '1'), # The '1' here catches the API version. Slightly hilarious.
'\{\{(?P<m>[a-zA-Z_]+)\}\}', base_url + fn['url']
lambda m: "%s" % kwargs.get(m.group(1), '1'), )
# The '1' here catches the API version. Slightly hilarious.
base_url + fn['url'] # Then open and load that shiiit, yo. TODO: check HTTP method and junk, handle errors/authentication
) if fn['method'] == 'POST':
resp, content = self.client.request(base, fn['method'], urllib.urlencode(dict([k, Twython.encode(v)] for k, v in kwargs.items())), headers = self.headers)
# Then open and load that shiiit, yo. TODO: check HTTP method and junk, handle errors/authentication else:
if fn['method'] == 'POST': url = base + "?" + "&".join(["%s=%s" %(key, value) for (key, value) in kwargs.iteritems()])
resp, content = self.client.request(base, fn['method'], urllib.urlencode( resp, content = self.client.request(url, fn['method'], headers = self.headers)
dict([k, Twython.encode(v)] for k, v in kwargs.items())), headers=self.headers)
else: return simplejson.loads(content)
url = base + "?" + "&".join(["%s=%s" % (key, value) for (key, value) in kwargs.iteritems()])
resp, content = self.client.request(url, fn['method'], headers=self.headers) if api_call in api_table:
return get.__get__(self)
return simplejson.loads(content) else:
raise TwythonError, api_call
if api_call in api_table:
return get.__get__(self) def get_authentication_tokens(self):
else: """
raise TwythonError, api_call get_auth_url(self)
def get_authentication_tokens(self): Returns an authorization URL for a user to hit.
""" """
get_auth_url(self) callback_url = self.callback_url or 'oob'
Returns an authorization URL for a user to hit. request_args = {}
""" if OAUTH_LIB_SUPPORTS_CALLBACK:
callback_url = self.callback_url or 'oob' request_args['callback_url'] = callback_url
request_args = {} resp, content = self.client.request(self.request_token_url, "GET", **request_args)
if OAUTH_LIB_SUPPORTS_CALLBACK:
request_args['callback_url'] = callback_url if resp['status'] != '200':
raise AuthError("Seems something couldn't be verified with your OAuth junk. Error: %s, Message: %s" % (resp['status'], content))
resp, content = self.client.request(self.request_token_url, "GET", **request_args)
try:
if resp['status'] != '200': request_tokens = dict(urlparse.parse_qsl(content))
raise AuthError("Seems something couldn't be verified with your OAuth junk. Error: %s, Message: %s" % ( except:
resp['status'], content)) request_tokens = dict(cgi.parse_qsl(content))
try: oauth_callback_confirmed = request_tokens.get('oauth_callback_confirmed')=='true'
request_tokens = dict(urlparse.parse_qsl(content))
except: if not OAUTH_LIB_SUPPORTS_CALLBACK and callback_url != 'oob' and oauth_callback_confirmed:
request_tokens = dict(cgi.parse_qsl(content)) import warnings
warnings.warn("oauth2 library doesn't support OAuth 1.0a type callback, but remote requires it")
oauth_callback_confirmed = request_tokens.get('oauth_callback_confirmed') == 'true' oauth_callback_confirmed = False
if not OAUTH_LIB_SUPPORTS_CALLBACK and callback_url != 'oob' and oauth_callback_confirmed: auth_url_params = {
import warnings 'oauth_token' : request_tokens['oauth_token'],
}
warnings.warn("oauth2 library doesn't support OAuth 1.0a type callback, but remote requires it")
oauth_callback_confirmed = False # Use old-style callback argument
if OAUTH_CALLBACK_IN_URL or (callback_url!='oob' and not oauth_callback_confirmed):
auth_url_params = { auth_url_params['oauth_callback'] = callback_url
'oauth_token': request_tokens['oauth_token'],
} request_tokens['auth_url'] = self.authenticate_url + '?' + urllib.urlencode(auth_url_params)
# Use old-style callback argument return request_tokens
if OAUTH_CALLBACK_IN_URL or (callback_url != 'oob' and not oauth_callback_confirmed):
auth_url_params['oauth_callback'] = callback_url def get_authorized_tokens(self):
"""
request_tokens['auth_url'] = self.authenticate_url + '?' + urllib.urlencode(auth_url_params) get_authorized_tokens
return request_tokens Returns authorized tokens after they go through the auth_url phase.
"""
def get_authorized_tokens(self): resp, content = self.client.request(self.access_token_url, "GET")
""" try:
get_authorized_tokens return dict(urlparse.parse_qsl(content))
except:
Returns authorized tokens after they go through the auth_url phase. return dict(cgi.parse_qsl(content))
"""
resp, content = self.client.request(self.access_token_url, "GET") # ------------------------------------------------------------------------------------------------------------------------
try: # The following methods are all different in some manner or require special attention with regards to the Twitter API.
return dict(urlparse.parse_qsl(content)) # Because of this, we keep them separate from all the other endpoint definitions - ideally this should be change-able,
except: # but it's not high on the priority list at the moment.
return dict(cgi.parse_qsl(content)) # ------------------------------------------------------------------------------------------------------------------------
# ------------------------------------------------------------------------------------------------------------------------ @staticmethod
# The following methods are all different in some manner or require special attention with regards to the Twitter API. def constructApiURL(base_url, params):
# Because of this, we keep them separate from all the other endpoint definitions - ideally this should be change-able, return base_url + "?" + "&".join(["%s=%s" %(Twython.unicode2utf8(key), urllib.quote_plus(Twython.unicode2utf8(value))) for (key, value) in params.iteritems()])
# but it's not high on the priority list at the moment.
# ------------------------------------------------------------------------------------------------------------------------ @staticmethod
def shortenURL(url_to_shorten, shortener = "http://is.gd/api.php", query = "longurl"):
@staticmethod """shortenURL(url_to_shorten, shortener = "http://is.gd/api.php", query = "longurl")
def constructApiURL(base_url, params):
return base_url + "?" + "&".join( Shortens url specified by url_to_shorten.
["%s=%s" % (Twython.unicode2utf8(key), urllib.quote_plus(Twython.unicode2utf8(value))) for (key, value) in
params.iteritems()]) Parameters:
url_to_shorten - URL to shorten.
@staticmethod shortener - In case you want to use a url shortening service other than is.gd.
def shortenURL(url_to_shorten, shortener="http://is.gd/api.php", query="longurl"): """
"""shortenURL(url_to_shorten, shortener = "http://is.gd/api.php", query = "longurl") try:
content = urllib2.urlopen(shortener + "?" + urllib.urlencode({query: Twython.unicode2utf8(url_to_shorten)})).read()
Shortens url specified by url_to_shorten. return content
except HTTPError, e:
Parameters: raise TwythonError("shortenURL() failed with a %s error code." % `e.code`)
url_to_shorten - URL to shorten.
shortener - In case you want to use a url shortening service other than is.gd. def bulkUserLookup(self, ids = None, screen_names = None, version = 1, **kwargs):
""" """ bulkUserLookup(self, ids = None, screen_names = None, version = 1, **kwargs)
try:
content = urllib2.urlopen( A method to do bulk user lookups against the Twitter API. Arguments (ids (numbers) / screen_names (strings)) should be flat Arrays that
shortener + "?" + urllib.urlencode({query: Twython.unicode2utf8(url_to_shorten)})).read() contain their respective data sets.
return content
except HTTPError, e: Statuses for the users in question will be returned inline if they exist. Requires authentication!
raise TwythonError("shortenURL() failed with a %s error code." % `e.code`) """
if ids:
def bulkUserLookup(self, ids=None, screen_names=None, version=1, **kwargs): kwargs['user_id'] = ','.join(map(str, ids))
""" bulkUserLookup(self, ids = None, screen_names = None, version = 1, **kwargs) if screen_names:
kwargs['screen_name'] = ','.join(screen_names)
A method to do bulk user lookups against the Twitter API. Arguments (ids (numbers) / screen_names (strings)) should be flat Arrays that
contain their respective data sets. lookupURL = Twython.constructApiURL("http://api.twitter.com/%d/users/lookup.json" % version, kwargs)
try:
Statuses for the users in question will be returned inline if they exist. Requires authentication! resp, content = self.client.request(lookupURL, "POST", headers = self.headers)
""" return simplejson.loads(content)
if ids: except HTTPError, e:
kwargs['user_id'] = ','.join(map(str, ids)) raise TwythonError("bulkUserLookup() failed with a %s error code." % `e.code`, e.code)
if screen_names:
kwargs['screen_name'] = ','.join(screen_names) def searchTwitter(self, **kwargs):
"""searchTwitter(search_query, **kwargs)
lookupURL = Twython.constructApiURL("http://api.twitter.com/%d/users/lookup.json" % version, kwargs)
try: Returns tweets that match a specified query.
resp, content = self.client.request(lookupURL, "POST", headers=self.headers)
return simplejson.loads(content) Parameters:
except HTTPError, e: See the documentation at http://dev.twitter.com/doc/get/search. Pass in the API supported arguments as named parameters.
raise TwythonError("bulkUserLookup() failed with a %s error code." % `e.code`, e.code)
e.g x.searchTwitter(q="jjndf", page="2")
def searchTwitter(self, **kwargs): """
"""searchTwitter(search_query, **kwargs) searchURL = Twython.constructApiURL("http://search.twitter.com/search.json", kwargs)
try:
Returns tweets that match a specified query. resp, content = self.client.request(searchURL, "GET", headers = self.headers)
return simplejson.loads(content)
Parameters: except HTTPError, e:
See the documentation at http://dev.twitter.com/doc/get/search. Pass in the API supported arguments as named parameters. raise TwythonError("getSearchTimeline() failed with a %s error code." % `e.code`, e.code)
e.g x.searchTwitter(q="jjndf", page="2") def searchTwitterGen(self, search_query, **kwargs):
""" """searchTwitterGen(search_query, **kwargs)
searchURL = Twython.constructApiURL("http://search.twitter.com/search.json", kwargs)
try: Returns a generator of tweets that match a specified query.
resp, content = self.client.request(searchURL, "GET", headers=self.headers)
return simplejson.loads(content) Parameters:
except HTTPError, e: See the documentation at http://dev.twitter.com/doc/get/search. Pass in the API supported arguments as named parameters.
raise TwythonError("getSearchTimeline() failed with a %s error code." % `e.code`, e.code)
e.g x.searchTwitter(q="jjndf", page="2")
def searchTwitterGen(self, search_query, **kwargs): """
"""searchTwitterGen(search_query, **kwargs) searchURL = Twython.constructApiURL("http://search.twitter.com/search.json?q=%s" % Twython.unicode2utf8(search_query), kwargs)
try:
Returns a generator of tweets that match a specified query. resp, content = self.client.request(searchURL, "GET", headers = self.headers)
data = simplejson.loads(content)
Parameters: except HTTPError, e:
See the documentation at http://dev.twitter.com/doc/get/search. Pass in the API supported arguments as named parameters. raise TwythonError("searchTwitterGen() failed with a %s error code." % `e.code`, e.code)
e.g x.searchTwitter(q="jjndf", page="2") if not data['results']:
""" raise StopIteration
searchURL = Twython.constructApiURL(
"http://search.twitter.com/search.json?q=%s" % Twython.unicode2utf8(search_query), kwargs) for tweet in data['results']:
try: yield tweet
resp, content = self.client.request(searchURL, "GET", headers=self.headers)
data = simplejson.loads(content) if 'page' not in kwargs:
except HTTPError, e: kwargs['page'] = 2
raise TwythonError("searchTwitterGen() failed with a %s error code." % `e.code`, e.code) else:
kwargs['page'] += 1
if not data['results']:
raise StopIteration for tweet in self.searchTwitterGen(search_query, **kwargs):
yield tweet
for tweet in data['results']:
yield tweet def isListMember(self, list_id, id, username, version = 1):
""" isListMember(self, list_id, id, version)
if 'page' not in kwargs:
kwargs['page'] = 2 Check if a specified user (id) is a member of the list in question (list_id).
else:
kwargs['page'] += 1 **Note: This method may not work for private/protected lists, unless you're authenticated and have access to those lists.
for tweet in self.searchTwitterGen(search_query, **kwargs): Parameters:
yield tweet list_id - Required. The slug of the list to check against.
id - Required. The ID of the user being checked in the list.
def isListMember(self, list_id, id, username, version=1): username - User who owns the list you're checking against (username)
""" isListMember(self, list_id, id, version) version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
"""
Check if a specified user (id) is a member of the list in question (list_id). try:
resp, content = self.client.request("http://api.twitter.com/%d/%s/%s/members/%s.json" % (version, username, list_id, `id`), headers = self.headers)
**Note: This method may not work for private/protected lists, unless you're authenticated and have access to those lists. return simplejson.loads(content)
except HTTPError, e:
Parameters: raise TwythonError("isListMember() failed with a %d error code." % e.code, e.code)
list_id - Required. The slug of the list to check against.
id - Required. The ID of the user being checked in the list. def isListSubscriber(self, username, list_id, id, version = 1):
username - User who owns the list you're checking against (username) """ isListSubscriber(self, list_id, id, version)
version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
""" Check if a specified user (id) is a subscriber of the list in question (list_id).
try:
resp, content = self.client.request( **Note: This method may not work for private/protected lists, unless you're authenticated and have access to those lists.
"http://api.twitter.com/%d/%s/%s/members/%s.json" % (version, username, list_id, `id`),
headers=self.headers) Parameters:
return simplejson.loads(content) list_id - Required. The slug of the list to check against.
except HTTPError, e: id - Required. The ID of the user being checked in the list.
raise TwythonError("isListMember() failed with a %d error code." % e.code, e.code) username - Required. The username of the owner of the list that you're seeing if someone is subscribed to.
version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
def isListSubscriber(self, username, list_id, id, version=1): """
""" isListSubscriber(self, list_id, id, version) try:
resp, content = self.client.request("http://api.twitter.com/%d/%s/%s/following/%s.json" % (version, username, list_id, `id`), headers = self.headers)
Check if a specified user (id) is a subscriber of the list in question (list_id). return simplejson.loads(content)
except HTTPError, e:
**Note: This method may not work for private/protected lists, unless you're authenticated and have access to those lists. raise TwythonError("isListMember() failed with a %d error code." % e.code, e.code)
Parameters: # The following methods are apart from the other Account methods, because they rely on a whole multipart-data posting function set.
list_id - Required. The slug of the list to check against. def updateProfileBackgroundImage(self, filename, tile="true", version = 1):
id - Required. The ID of the user being checked in the list. """ updateProfileBackgroundImage(filename, tile="true")
username - Required. The username of the owner of the list that you're seeing if someone is subscribed to.
version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc. Updates the authenticating user's profile background image.
"""
try: Parameters:
resp, content = self.client.request( image - Required. Must be a valid GIF, JPG, or PNG image of less than 800 kilobytes in size. Images with width larger than 2048 pixels will be forceably scaled down.
"http://api.twitter.com/%d/%s/%s/following/%s.json" % (version, username, list_id, `id`), tile - Optional (defaults to true). If set to true the background image will be displayed tiled. The image will not be tiled otherwise.
headers=self.headers) ** Note: It's sad, but when using this method, pass the tile value as a string, e.g tile="false"
return simplejson.loads(content) version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
except HTTPError, e: """
raise TwythonError("isListMember() failed with a %d error code." % e.code, e.code) try:
files = [("image", filename, open(filename, 'rb').read())]
# The following methods are apart from the other Account methods, because they rely on a whole multipart-data posting function set. fields = []
def updateProfileBackgroundImage(self, filename, tile="true", version=1): content_type, body = Twython.encode_multipart_formdata(fields, files)
""" updateProfileBackgroundImage(filename, tile="true") headers = {'Content-Type': content_type, 'Content-Length': str(len(body))}
r = urllib2.Request("http://api.twitter.com/%d/account/update_profile_background_image.json?tile=%s" % (version, tile), body, headers)
Updates the authenticating user's profile background image. return urllib2.urlopen(r).read()
except HTTPError, e:
Parameters: raise TwythonError("updateProfileBackgroundImage() failed with a %d error code." % e.code, e.code)
image - Required. Must be a valid GIF, JPG, or PNG image of less than 800 kilobytes in size. Images with width larger than 2048 pixels will be forceably scaled down.
tile - Optional (defaults to true). If set to true the background image will be displayed tiled. The image will not be tiled otherwise. def updateProfileImage(self, filename, version = 1):
** Note: It's sad, but when using this method, pass the tile value as a string, e.g tile="false" """ updateProfileImage(filename)
version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
""" Updates the authenticating user's profile image (avatar).
try:
files = [("image", filename, open(filename, 'rb').read())] Parameters:
fields = [] image - Required. Must be a valid GIF, JPG, or PNG image of less than 700 kilobytes in size. Images with width larger than 500 pixels will be scaled down.
content_type, body = Twython.encode_multipart_formdata(fields, files) version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
headers = {'Content-Type': content_type, 'Content-Length': str(len(body))} """
r = urllib2.Request( try:
"http://api.twitter.com/%d/account/update_profile_background_image.json?tile=%s" % (version, tile), body files = [("image", filename, open(filename, 'rb').read())]
, headers) fields = []
return urllib2.urlopen(r).read() content_type, body = Twython.encode_multipart_formdata(fields, files)
except HTTPError, e: headers = {'Content-Type': content_type, 'Content-Length': str(len(body))}
raise TwythonError("updateProfileBackgroundImage() failed with a %d error code." % e.code, e.code) r = urllib2.Request("http://api.twitter.com/%d/account/update_profile_image.json" % version, body, headers)
return urllib2.urlopen(r).read()
def updateProfileImage(self, filename, version=1): except HTTPError, e:
""" updateProfileImage(filename) raise TwythonError("updateProfileImage() failed with a %d error code." % e.code, e.code)
Updates the authenticating user's profile image (avatar). def getProfileImageUrl(self, username, size=None, version=1):
""" getProfileImageUrl(username)
Parameters:
image - Required. Must be a valid GIF, JPG, or PNG image of less than 700 kilobytes in size. Images with width larger than 500 pixels will be scaled down. Gets the URL for the user's profile image.
version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
""" Parameters:
try: username - Required. User name of the user you want the image url of.
files = [("image", filename, open(filename, 'rb').read())] size - Optional. Image size. Valid options include 'normal', 'mini' and 'bigger'. Defaults to 'normal' if not given.
fields = [] version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
content_type, body = Twython.encode_multipart_formdata(fields, files) """
headers = {'Content-Type': content_type, 'Content-Length': str(len(body))} url = "http://api.twitter.com/%s/users/profile_image/%s.json" % (version, username)
r = urllib2.Request("http://api.twitter.com/%d/account/update_profile_image.json" % version, body, headers) if size:
return urllib2.urlopen(r).read() url = self.constructApiURL(url, {'size':size})
except HTTPError, e:
raise TwythonError("updateProfileImage() failed with a %d error code." % e.code, e.code) client = httplib2.Http()
client.follow_redirects = False
def getProfileImageUrl(self, username, size=None, version=1): resp, content = client.request(url, 'GET')
""" getProfileImageUrl(username)
if resp.status in (301,302,303,307):
Gets the URL for the user's profile image. return resp['location']
elif resp.status == 200:
Parameters: return simplejson.loads(content)
username - Required. User name of the user you want the image url of.
size - Optional. Image size. Valid options include 'normal', 'mini' and 'bigger'. Defaults to 'normal' if not given. raise TwythonError("getProfileImageUrl() failed with a %d error code." % resp.status, resp.status)
version (number) - Optional. API version to request. Entire Twython class defaults to 1, but you can override on a function-by-function or class basis - (version=2), etc.
""" def getUserProfile(self, **kwargs):
url = "http://api.twitter.com/%s/users/profile_image/%s.json" % (version, username) """getUserProfile(**kwargs)
if size:
url = self.constructApiURL(url, {'size': size}) Parameters:
username - Required. User name of the user you want the profile information.
client = httplib2.Http() OR
client.follow_redirects = False id - Required. User id of the user you want the profile information.
resp, content = client.request(url, 'GET')
if resp.status in (301, 302, 303, 307):
return resp['location']
elif resp.status == 200:
return simplejson.loads(content)
raise TwythonError("getProfileImageUrl() failed with a %d error code." % resp.status, resp.status)
def getUserProfile(self, **kwargs):
"""getUserProfile(screen_name, **kwargs)
Returns user profile that match a specified screen_name. Returns user profile that match a specified screen_name.
Parameters: Parameters:
See the documentation at https://dev.twitter.com/docs/api/1/get/users/show. Pass in the API supported arguments as named parameters. See the documentation at https://dev.twitter.com/docs/api/1/get/users/show. Pass in the API supported arguments as named parameters.
e.g x.searchTwitter(screen_name="lacion"[, user_id=123[, include_entities=True]]) e.g x.getUserProfile(screen_name="lacion"[, user_id=123[, include_entities=True]])
""" """
userShowURL = Twython.constructApiURL("http://api.twitter.com/version/users/show.json", kwargs) userShowURL = Twython.constructApiURL("http://api.twitter.com/1/users/show.json", kwargs)
try: try:
resp, content = self.client.request(searchURL, "GET", headers=self.headers) resp, content = self.client.request(userShowURL, "GET", headers=self.headers)
return simplejson.loads(content) return simplejson.loads(content)
except HTTPError, e: except HTTPError, e:
raise TwythonError("getUserProfile() failed with a %s error code." % `e.code`, e.code) raise TwythonError("getUserProfile() failed with a %s error code." % `e.code`, e.code)
@staticmethod @staticmethod
def encode_multipart_formdata(fields, files): def encode_multipart_formdata(fields, files):
BOUNDARY = mimetools.choose_boundary() BOUNDARY = mimetools.choose_boundary()
CRLF = '\r\n' CRLF = '\r\n'
L = [] L = []
for (key, value) in fields: for (key, value) in fields:
L.append('--' + BOUNDARY) L.append('--' + BOUNDARY)
L.append('Content-Disposition: form-data; name="%s"' % key) L.append('Content-Disposition: form-data; name="%s"' % key)
L.append('') L.append('')
L.append(value) L.append(value)
for (key, filename, value) in files: for (key, filename, value) in files:
L.append('--' + BOUNDARY) L.append('--' + BOUNDARY)
L.append('Content-Disposition: form-data; name="%s"; filename="%s"' % (key, filename)) L.append('Content-Disposition: form-data; name="%s"; filename="%s"' % (key, filename))
L.append('Content-Type: %s' % mimetypes.guess_type(filename)[0] or 'application/octet-stream') L.append('Content-Type: %s' % mimetypes.guess_type(filename)[0] or 'application/octet-stream')
L.append('') L.append('')
L.append(value) L.append(value)
L.append('--' + BOUNDARY + '--') L.append('--' + BOUNDARY + '--')
L.append('') L.append('')
body = CRLF.join(L) body = CRLF.join(L)
content_type = 'multipart/form-data; boundary=%s' % BOUNDARY content_type = 'multipart/form-data; boundary=%s' % BOUNDARY
return content_type, body return content_type, body
@staticmethod @staticmethod
def unicode2utf8(text): def unicode2utf8(text):
try: try:
if isinstance(text, unicode): if isinstance(text, unicode):
text = text.encode('utf-8') text = text.encode('utf-8')
except: except:
pass pass
return text return text
@staticmethod @staticmethod
def encode(text): def encode(text):
if isinstance(text, (str, unicode)): if isinstance(text, (str,unicode)):
return Twython.unicode2utf8(text) return Twython.unicode2utf8(text)
return str(text) return str(text)