oauth2.py
2053 lines
| 58.3 KiB
| text/x-python
|
PythonLexer
r3912 | # -*- coding: utf-8 -*- | |||
""" | ||||
|oauth2| Providers | ||||
------------------- | ||||
Providers which implement the |oauth2|_ protocol. | ||||
.. autosummary:: | ||||
OAuth2 | ||||
Amazon | ||||
Behance | ||||
Bitly | ||||
Bitbucket | ||||
Cosm | ||||
DeviantART | ||||
Eventbrite | ||||
Foursquare | ||||
GitHub | ||||
PayPal | ||||
Viadeo | ||||
VK | ||||
WindowsLive | ||||
Yammer | ||||
Yandex | ||||
""" | ||||
import base64 | ||||
import datetime | ||||
import json | ||||
import logging | ||||
from authomatic.six.moves.urllib.parse import unquote | ||||
from authomatic import providers | ||||
from authomatic.exceptions import CancellationError, FailureError, OAuth2Error | ||||
import authomatic.core as core | ||||
__all__ = [ | ||||
'OAuth2', | ||||
'Amazon', | ||||
'Behance', | ||||
'Bitly', | ||||
'Bitbucket', | ||||
'Cosm', | ||||
'DeviantART', | ||||
'Eventbrite', | ||||
'Facebook', | ||||
'Foursquare', | ||||
'GitHub', | ||||
'Google', | ||||
'LinkedIn', | ||||
'PayPal', | ||||
'Reddit', | ||||
'Viadeo', | ||||
'VK', | ||||
'WindowsLive', | ||||
'Yammer', | ||||
'Yandex' | ||||
] | ||||
class OAuth2(providers.AuthorizationProvider): | ||||
""" | ||||
Base class for |oauth2|_ providers. | ||||
""" | ||||
PROVIDER_TYPE_ID = 2 | ||||
TOKEN_TYPES = ['', 'Bearer'] | ||||
#: A scope preset to get most of the **user** info. | ||||
#: Use it in the :doc:`config` like | ||||
#: ``{'scope': oauth2.Facebook.user_info_scope}``. | ||||
user_info_scope = [] | ||||
#: :class:`bool` If ``False``, the provider doesn't support CSRF | ||||
#: protection. | ||||
supports_csrf_protection = True | ||||
#: :class:`bool` If ``False``, the provider doesn't support user_state. | ||||
supports_user_state = True | ||||
token_request_method = 'POST' # method for requesting an access token | ||||
def __init__(self, *args, **kwargs): | ||||
""" | ||||
Accepts additional keyword arguments: | ||||
:param list scope: | ||||
List of strings specifying requested permissions as described | ||||
in the | ||||
`OAuth 2.0 spec <http://tools.ietf.org/html/rfc6749#section-3.3>`_. | ||||
:param bool offline: | ||||
If ``True`` the **provider** will be set up to request an | ||||
*offline access token*. | ||||
Default is ``False``. | ||||
As well as those inherited from :class:`.AuthorizationProvider` | ||||
constructor. | ||||
""" | ||||
super(OAuth2, self).__init__(*args, **kwargs) | ||||
self.scope = self._kwarg(kwargs, 'scope', []) | ||||
self.offline = self._kwarg(kwargs, 'offline', False) | ||||
# ======================================================================== | ||||
# Internal methods | ||||
# ======================================================================== | ||||
def _x_scope_parser(self, scope): | ||||
""" | ||||
Override this to handle differences between accepted format of scope | ||||
across providers. | ||||
:attr list scope: | ||||
List of scopes. | ||||
""" | ||||
# pylint:disable=no-self-use | ||||
# Most providers accept csv scope. | ||||
return ','.join(scope) if scope else '' | ||||
@classmethod | ||||
def create_request_elements( | ||||
cls, request_type, credentials, url, method='GET', params=None, | ||||
headers=None, body='', secret=None, redirect_uri='', scope='', | ||||
csrf='', user_state='' | ||||
): | ||||
""" | ||||
Creates |oauth2| request elements. | ||||
""" | ||||
headers = headers or {} | ||||
params = params or {} | ||||
consumer_key = credentials.consumer_key or '' | ||||
consumer_secret = credentials.consumer_secret or '' | ||||
token = credentials.token or '' | ||||
refresh_token = credentials.refresh_token or credentials.token or '' | ||||
# Separate url base and query parameters. | ||||
url, base_params = cls._split_url(url) | ||||
# Add params extracted from URL. | ||||
params.update(dict(base_params)) | ||||
if request_type == cls.USER_AUTHORIZATION_REQUEST_TYPE: | ||||
# User authorization request. | ||||
# TODO: Raise error for specific message for each missing argument. | ||||
if consumer_key and redirect_uri and ( | ||||
csrf or not cls.supports_csrf_protection): | ||||
params['client_id'] = consumer_key | ||||
params['redirect_uri'] = redirect_uri | ||||
params['scope'] = scope | ||||
if cls.supports_user_state: | ||||
params['state'] = base64.urlsafe_b64encode( | ||||
json.dumps( | ||||
{"csrf": csrf, "user_state": user_state} | ||||
).encode('utf-8') | ||||
) | ||||
else: | ||||
params['state'] = csrf | ||||
params['response_type'] = 'code' | ||||
# Add authorization header | ||||
headers.update(cls._authorization_header(credentials)) | ||||
else: | ||||
raise OAuth2Error( | ||||
'Credentials with valid consumer_key and arguments ' | ||||
'redirect_uri, scope and state are required to create ' | ||||
'OAuth 2.0 user authorization request elements!') | ||||
elif request_type == cls.ACCESS_TOKEN_REQUEST_TYPE: | ||||
# Access token request. | ||||
if consumer_key and consumer_secret: | ||||
params['code'] = token | ||||
params['client_id'] = consumer_key | ||||
params['client_secret'] = consumer_secret | ||||
params['redirect_uri'] = redirect_uri | ||||
params['grant_type'] = 'authorization_code' | ||||
# TODO: Check whether all providers accept it | ||||
headers.update(cls._authorization_header(credentials)) | ||||
else: | ||||
raise OAuth2Error( | ||||
'Credentials with valid token, consumer_key, ' | ||||
'consumer_secret and argument redirect_uri are required ' | ||||
'to create OAuth 2.0 access token request elements!') | ||||
elif request_type == cls.REFRESH_TOKEN_REQUEST_TYPE: | ||||
# Refresh access token request. | ||||
if refresh_token and consumer_key and consumer_secret: | ||||
params['refresh_token'] = refresh_token | ||||
params['client_id'] = consumer_key | ||||
params['client_secret'] = consumer_secret | ||||
params['grant_type'] = 'refresh_token' | ||||
else: | ||||
raise OAuth2Error( | ||||
'Credentials with valid refresh_token, consumer_key, ' | ||||
'consumer_secret are required to create OAuth 2.0 ' | ||||
'refresh token request elements!') | ||||
elif request_type == cls.PROTECTED_RESOURCE_REQUEST_TYPE: | ||||
# Protected resource request. | ||||
# Add Authorization header. See: | ||||
# http://tools.ietf.org/html/rfc6749#section-7.1 | ||||
if credentials.token_type == cls.BEARER: | ||||
# http://tools.ietf.org/html/rfc6750#section-2.1 | ||||
headers.update( | ||||
{'Authorization': 'Bearer {0}'.format(credentials.token)}) | ||||
elif token: | ||||
params['access_token'] = token | ||||
else: | ||||
raise OAuth2Error( | ||||
'Credentials with valid token are required to create ' | ||||
'OAuth 2.0 protected resources request elements!') | ||||
request_elements = core.RequestElements( | ||||
url, method, params, headers, body) | ||||
return cls._x_request_elements_filter( | ||||
request_type, request_elements, credentials) | ||||
@staticmethod | ||||
def _x_refresh_credentials_if(credentials): | ||||
""" | ||||
Override this to specify conditions when it gives sense to refresh | ||||
credentials. | ||||
.. warning:: | ||||
|classmethod| | ||||
:param credentials: | ||||
:class:`.Credentials` | ||||
:returns: | ||||
``True`` or ``False`` | ||||
""" | ||||
if credentials.refresh_token: | ||||
return True | ||||
# ======================================================================== | ||||
# Exposed methods | ||||
# ======================================================================== | ||||
@classmethod | ||||
def to_tuple(cls, credentials): | ||||
return (credentials.token, | ||||
credentials.refresh_token, | ||||
credentials.expiration_time, | ||||
cls.TOKEN_TYPES.index(credentials.token_type)) | ||||
@classmethod | ||||
def reconstruct(cls, deserialized_tuple, credentials, cfg): | ||||
token, refresh_token, expiration_time, token_type = deserialized_tuple | ||||
credentials.token = token | ||||
credentials.refresh_token = refresh_token | ||||
credentials.expiration_time = expiration_time | ||||
credentials.token_type = cls.TOKEN_TYPES[int(token_type)] | ||||
return credentials | ||||
@classmethod | ||||
def decode_state(cls, state, param='user_state'): | ||||
""" | ||||
Decode state and return param. | ||||
:param str state: | ||||
state parameter passed through by provider | ||||
:param str param: | ||||
key to query from decoded state variable. Options include 'csrf' | ||||
and 'user_state'. | ||||
:returns: | ||||
string value from decoded state | ||||
""" | ||||
if state and cls.supports_user_state: | ||||
# urlsafe_b64 may include = which the browser quotes so must | ||||
# unquote Cast to str to void b64decode translation error. Base64 | ||||
# should be str compatible. | ||||
return json.loads(base64.urlsafe_b64decode( | ||||
unquote(str(state))).decode('utf-8'))[param] | ||||
else: | ||||
return state if param == 'csrf' else '' | ||||
def refresh_credentials(self, credentials): | ||||
""" | ||||
Refreshes :class:`.Credentials` if it gives sense. | ||||
:param credentials: | ||||
:class:`.Credentials` to be refreshed. | ||||
:returns: | ||||
:class:`.Response`. | ||||
""" | ||||
if not self._x_refresh_credentials_if(credentials): | ||||
return | ||||
# We need consumer key and secret to make this kind of request. | ||||
cfg = credentials.config.get(credentials.provider_name) | ||||
credentials.consumer_key = cfg.get('consumer_key') | ||||
credentials.consumer_secret = cfg.get('consumer_secret') | ||||
request_elements = self.create_request_elements( | ||||
request_type=self.REFRESH_TOKEN_REQUEST_TYPE, | ||||
credentials=credentials, | ||||
url=self.access_token_url, | ||||
method='POST' | ||||
) | ||||
self._log(logging.INFO, u'Refreshing credentials.') | ||||
response = self._fetch(*request_elements) | ||||
# We no longer need consumer info. | ||||
credentials.consumer_key = None | ||||
credentials.consumer_secret = None | ||||
# Extract the refreshed data. | ||||
access_token = response.data.get('access_token') | ||||
refresh_token = response.data.get('refresh_token') | ||||
# Update credentials only if there is access token. | ||||
if access_token: | ||||
credentials.token = access_token | ||||
credentials.expire_in = response.data.get('expires_in') | ||||
# Update refresh token only if there is a new one. | ||||
if refresh_token: | ||||
credentials.refresh_token = refresh_token | ||||
# Handle different naming conventions across providers. | ||||
credentials = self._x_credentials_parser( | ||||
credentials, response.data) | ||||
return response | ||||
@providers.login_decorator | ||||
def login(self): | ||||
# get request parameters from which we can determine the login phase | ||||
authorization_code = self.params.get('code') | ||||
error = self.params.get('error') | ||||
error_message = self.params.get('error_message') | ||||
state = self.params.get('state') | ||||
# optional user_state to be passed in oauth2 state | ||||
user_state = self.params.get('user_state', '') | ||||
if authorization_code or not self.user_authorization_url: | ||||
if authorization_code: | ||||
# ============================================================= | ||||
# Phase 2 after redirect with success | ||||
# ============================================================= | ||||
self._log( | ||||
logging.INFO, | ||||
u'Continuing OAuth 2.0 authorization procedure after ' | ||||
u'redirect.') | ||||
# validate CSRF token | ||||
if self.supports_csrf_protection: | ||||
self._log( | ||||
logging.INFO, | ||||
u'Validating request by comparing request state with ' | ||||
u'stored state.') | ||||
stored_csrf = self._session_get('csrf') | ||||
state_csrf = self.decode_state(state, 'csrf') | ||||
if not stored_csrf: | ||||
raise FailureError(u'Unable to retrieve stored state!') | ||||
elif stored_csrf != state_csrf: | ||||
raise FailureError( | ||||
u'The returned state csrf cookie "{0}" doesn\'t ' | ||||
u'match with the stored state!'.format( | ||||
state_csrf | ||||
), | ||||
url=self.user_authorization_url) | ||||
self._log(logging.INFO, u'Request is valid.') | ||||
else: | ||||
self._log(logging.WARN, u'Skipping CSRF validation!') | ||||
elif not self.user_authorization_url: | ||||
# ============================================================= | ||||
# Phase 1 without user authorization redirect. | ||||
# ============================================================= | ||||
self._log( | ||||
logging.INFO, | ||||
u'Starting OAuth 2.0 authorization procedure without ' | ||||
u'user authorization redirect.') | ||||
# exchange authorization code for access token by the provider | ||||
self._log( | ||||
logging.INFO, | ||||
u'Fetching access token from {0}.'.format( | ||||
self.access_token_url)) | ||||
self.credentials.token = authorization_code | ||||
request_elements = self.create_request_elements( | ||||
request_type=self.ACCESS_TOKEN_REQUEST_TYPE, | ||||
credentials=self.credentials, | ||||
url=self.access_token_url, | ||||
method=self.token_request_method, | ||||
redirect_uri=self.url, | ||||
params=self.access_token_params, | ||||
headers=self.access_token_headers | ||||
) | ||||
response = self._fetch(*request_elements) | ||||
self.access_token_response = response | ||||
access_token = response.data.get('access_token', '') | ||||
refresh_token = response.data.get('refresh_token', '') | ||||
if response.status != 200 or not access_token: | ||||
raise FailureError( | ||||
'Failed to obtain OAuth 2.0 access token from {0}! ' | ||||
'HTTP status: {1}, message: {2}.'.format( | ||||
self.access_token_url, | ||||
response.status, | ||||
response.content | ||||
), | ||||
original_message=response.content, | ||||
status=response.status, | ||||
url=self.access_token_url) | ||||
self._log(logging.INFO, u'Got access token.') | ||||
if refresh_token: | ||||
self._log(logging.INFO, u'Got refresh access token.') | ||||
# OAuth 2.0 credentials need access_token, refresh_token, | ||||
# token_type and expire_in. | ||||
self.credentials.token = access_token | ||||
self.credentials.refresh_token = refresh_token | ||||
self.credentials.expire_in = response.data.get('expires_in') | ||||
self.credentials.token_type = response.data.get('token_type', '') | ||||
# sWe don't need these two guys anymore. | ||||
self.credentials.consumer_key = '' | ||||
self.credentials.consumer_secret = '' | ||||
# update credentials | ||||
self.credentials = self._x_credentials_parser( | ||||
self.credentials, response.data) | ||||
# create user | ||||
self._update_or_create_user(response.data, self.credentials) | ||||
# ================================================================= | ||||
# We're done! | ||||
# ================================================================= | ||||
elif error or error_message: | ||||
# ================================================================= | ||||
# Phase 2 after redirect with error | ||||
# ================================================================= | ||||
error_reason = self.params.get('error_reason') or error | ||||
error_description = self.params.get('error_description') \ | ||||
or error_message or error | ||||
if error_reason and 'denied' in error_reason: | ||||
raise CancellationError(error_description, | ||||
url=self.user_authorization_url) | ||||
else: | ||||
raise FailureError( | ||||
error_description, | ||||
url=self.user_authorization_url) | ||||
elif ( | ||||
not self.params or | ||||
len(self.params) == 1 and | ||||
'user_state' in self.params | ||||
): | ||||
# ================================================================= | ||||
# Phase 1 before redirect | ||||
# ================================================================= | ||||
self._log( | ||||
logging.INFO, | ||||
u'Starting OAuth 2.0 authorization procedure.') | ||||
csrf = '' | ||||
if self.supports_csrf_protection: | ||||
# generate csfr | ||||
csrf = self.csrf_generator(self.settings.secret) | ||||
# and store it to session | ||||
self._session_set('csrf', csrf) | ||||
else: | ||||
self._log( | ||||
logging.WARN, | ||||
u'Provider doesn\'t support CSRF validation!') | ||||
request_elements = self.create_request_elements( | ||||
request_type=self.USER_AUTHORIZATION_REQUEST_TYPE, | ||||
credentials=self.credentials, | ||||
url=self.user_authorization_url, | ||||
redirect_uri=self.url, | ||||
scope=self._x_scope_parser( | ||||
self.scope), | ||||
csrf=csrf, | ||||
user_state=user_state, | ||||
params=self.user_authorization_params | ||||
) | ||||
self._log( | ||||
logging.INFO, | ||||
u'Redirecting user to {0}.'.format( | ||||
request_elements.full_url)) | ||||
self.redirect(request_elements.full_url) | ||||
class Amazon(OAuth2): | ||||
""" | ||||
Amazon |oauth2| provider. | ||||
Thanks to `Ghufran Syed <https://github.com/ghufransyed>`__. | ||||
* Dashboard: https://developer.amazon.com/lwa/sp/overview.html | ||||
* Docs: https://developer.amazon.com/public/apis/engage/login-with-amazon/docs/conceptual_overview.html | ||||
* API reference: https://developer.amazon.com/public/apis | ||||
.. note:: | ||||
Amazon only accepts **redirect_uri** with **https** schema, | ||||
Therefore the *login handler* must also be accessible through | ||||
**https**. | ||||
Supported :class:`.User` properties: | ||||
* id | ||||
* name | ||||
* postal_code | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* nickname | ||||
* phone | ||||
* picture | ||||
* timezone | ||||
* username | ||||
""" | ||||
user_authorization_url = 'https://www.amazon.com/ap/oa' | ||||
access_token_url = 'https://api.amazon.com/auth/o2/token' | ||||
user_info_url = 'https://api.amazon.com/user/profile' | ||||
user_info_scope = ['profile', 'postal_code'] | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
email=True, | ||||
id=True, | ||||
name=True, | ||||
postal_code=True | ||||
) | ||||
def _x_scope_parser(self, scope): | ||||
# Amazon has space-separated scopes | ||||
return ' '.join(scope) | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.id = data.get('user_id') | ||||
return user | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
class Behance(OAuth2): | ||||
""" | ||||
Behance |oauth2| provider. | ||||
.. note:: | ||||
Behance doesn't support third party authorization anymore, | ||||
which renders this class pretty much useless. | ||||
* Dashboard: http://www.behance.net/dev/apps | ||||
* Docs: http://www.behance.net/dev/authentication | ||||
* API reference: http://www.behance.net/dev/api/endpoints/ | ||||
""" | ||||
user_authorization_url = 'https://www.behance.net/v2/oauth/authenticate' | ||||
access_token_url = 'https://www.behance.net/v2/oauth/token' | ||||
user_info_url = '' | ||||
user_info_scope = ['activity_read'] | ||||
def _x_scope_parser(self, scope): | ||||
""" | ||||
Behance has pipe-separated scopes. | ||||
""" | ||||
return '|'.join(scope) | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
_user = data.get('user', {}) | ||||
user.id = _user.get('id') | ||||
user.first_name = _user.get('first_name') | ||||
user.last_name = _user.get('last_name') | ||||
user.username = _user.get('username') | ||||
user.city = _user.get('city') | ||||
user.country = _user.get('country') | ||||
user.link = _user.get('url') | ||||
user.name = _user.get('display_name') | ||||
user.picture = _user.get('images', {}).get('138') | ||||
return user | ||||
class Bitly(OAuth2): | ||||
""" | ||||
Bitly |oauth2| provider. | ||||
.. warning:: | ||||
|no-csrf| | ||||
* Dashboard: https://bitly.com/a/oauth_apps | ||||
* Docs: http://dev.bitly.com/authentication.html | ||||
* API reference: http://dev.bitly.com/api.html | ||||
Supported :class:`.User` properties: | ||||
* id | ||||
* link | ||||
* name | ||||
* picture | ||||
* username | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* last_name | ||||
* locale | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* timezone | ||||
""" | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
id=True, | ||||
link=True, | ||||
name=True, | ||||
picture=True, | ||||
username=True | ||||
) | ||||
supports_csrf_protection = False | ||||
_x_use_authorization_header = False | ||||
user_authorization_url = 'https://bitly.com/oauth/authorize' | ||||
access_token_url = 'https://api-ssl.bitly.com/oauth/access_token' | ||||
user_info_url = 'https://api-ssl.bitly.com/v3/user/info' | ||||
def __init__(self, *args, **kwargs): | ||||
super(Bitly, self).__init__(*args, **kwargs) | ||||
if self.offline: | ||||
if 'grant_type' not in self.access_token_params: | ||||
self.access_token_params['grant_type'] = 'refresh_token' | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
info = data.get('data', {}) | ||||
user.id = info.get('login') | ||||
user.name = info.get('full_name') | ||||
user.username = info.get('display_name') | ||||
user.picture = info.get('profile_image') | ||||
user.link = info.get('profile_url') | ||||
return user | ||||
class Cosm(OAuth2): | ||||
""" | ||||
Cosm |oauth2| provider. | ||||
.. note:: | ||||
Cosm doesn't provide any *user info URL*. | ||||
* Dashboard: https://cosm.com/users/{your_username}/apps | ||||
* Docs: https://cosm.com/docs/ | ||||
* API reference: https://cosm.com/docs/v2/ | ||||
""" | ||||
user_authorization_url = 'https://cosm.com/oauth/authenticate' | ||||
access_token_url = 'https://cosm.com/oauth/token' | ||||
user_info_url = '' | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.id = user.username = data.get('user') | ||||
return user | ||||
class DeviantART(OAuth2): | ||||
""" | ||||
DeviantART |oauth2| provider. | ||||
* Dashboard: https://www.deviantart.com/settings/myapps | ||||
* Docs: https://www.deviantart.com/developers/authentication | ||||
* API reference: http://www.deviantart.com/developers/oauth2 | ||||
.. note:: | ||||
Although it is not documented anywhere, DeviantART requires the | ||||
*access token* request to contain a ``User-Agent`` header. | ||||
You can apply a default ``User-Agent`` header for all API calls in the | ||||
config like this: | ||||
.. code-block:: python | ||||
:emphasize-lines: 6 | ||||
CONFIG = { | ||||
'deviantart': { | ||||
'class_': oauth2.DeviantART, | ||||
'consumer_key': '#####', | ||||
'consumer_secret': '#####', | ||||
'access_headers': {'User-Agent': 'Some User Agent'}, | ||||
} | ||||
} | ||||
Supported :class:`.User` properties: | ||||
* name | ||||
* picture | ||||
* username | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* id | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* timezone | ||||
""" | ||||
user_authorization_url = 'https://www.deviantart.com/oauth2/authorize' | ||||
access_token_url = 'https://www.deviantart.com/oauth2/token' | ||||
user_info_url = 'https://www.deviantart.com/api/oauth2/user/whoami' | ||||
user_info_scope = ['basic'] | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
name=True, | ||||
picture=True, | ||||
username=True | ||||
) | ||||
def __init__(self, *args, **kwargs): | ||||
super(DeviantART, self).__init__(*args, **kwargs) | ||||
if self.offline: | ||||
if 'grant_type' not in self.access_token_params: | ||||
self.access_token_params['grant_type'] = 'refresh_token' | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.picture = data.get('usericonurl') | ||||
return user | ||||
class Eventbrite(OAuth2): | ||||
""" | ||||
Eventbrite |oauth2| provider. | ||||
Thanks to `Paul Brown <http://www.paulsprogrammingnotes.com/>`__. | ||||
* Dashboard: http://www.eventbrite.com/myaccount/apps/ | ||||
* Docs: https://developer.eventbrite.com/docs/auth/ | ||||
* API: http://developer.eventbrite.com/docs/ | ||||
Supported :class:`.User` properties: | ||||
* first_name | ||||
* id | ||||
* last_name | ||||
* name | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* gender | ||||
* link | ||||
* locale | ||||
* nickname | ||||
* phone | ||||
* picture | ||||
* postal_code | ||||
* timezone | ||||
* username | ||||
""" | ||||
user_authorization_url = 'https://www.eventbrite.com/oauth/authorize' | ||||
access_token_url = 'https://www.eventbrite.com/oauth/token' | ||||
user_info_url = 'https://www.eventbriteapi.com/v3/users/me' | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
email=True, | ||||
first_name=True, | ||||
id=True, | ||||
last_name=True, | ||||
name=True, | ||||
) | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
for email in data.get('emails', []): | ||||
if email.get('primary'): | ||||
user.email = email.get('email') | ||||
break | ||||
return user | ||||
class Facebook(OAuth2): | ||||
""" | ||||
Facebook |oauth2| provider. | ||||
* Dashboard: https://developers.facebook.com/apps | ||||
* Docs: http://developers.facebook.com/docs/howtos/login/server-side-login/ | ||||
* API reference: http://developers.facebook.com/docs/reference/api/ | ||||
* API explorer: http://developers.facebook.com/tools/explorer | ||||
Supported :class:`.User` properties: | ||||
* birth_date | ||||
* first_name | ||||
* id | ||||
* last_name | ||||
* name | ||||
* picture | ||||
Unsupported :class:`.User` properties: | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* username | ||||
""" | ||||
user_authorization_url = 'https://www.facebook.com/dialog/oauth' | ||||
access_token_url = 'https://graph.facebook.com/oauth/access_token' | ||||
user_info_url = 'https://graph.facebook.com/v2.3/me' | ||||
user_info_scope = ['email', 'public_profile', 'user_birthday', | ||||
'user_location'] | ||||
same_origin = False | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
birth_date=True, | ||||
city=False, | ||||
country=False, | ||||
email=True, | ||||
first_name=True, | ||||
gender=False, | ||||
id=True, | ||||
last_name=True, | ||||
link=False, | ||||
locale=False, | ||||
location=False, | ||||
name=True, | ||||
picture=True, | ||||
timezone=False, | ||||
username=False, | ||||
) | ||||
@classmethod | ||||
def _x_request_elements_filter(cls, request_type, request_elements, | ||||
credentials): | ||||
if request_type == cls.REFRESH_TOKEN_REQUEST_TYPE: | ||||
# As always, Facebook has it's original name for "refresh_token"! | ||||
url, method, params, headers, body = request_elements | ||||
params['fb_exchange_token'] = params.pop('refresh_token') | ||||
params['grant_type'] = 'fb_exchange_token' | ||||
request_elements = core.RequestElements(url, method, params, | ||||
headers, body) | ||||
return request_elements | ||||
def __init__(self, *args, **kwargs): | ||||
super(Facebook, self).__init__(*args, **kwargs) | ||||
# Handle special Facebook requirements to be able | ||||
# to refresh the access token. | ||||
if self.offline: | ||||
# Facebook needs an offline_access scope. | ||||
if 'offline_access' not in self.scope: | ||||
self.scope.append('offline_access') | ||||
if self.popup: | ||||
self.user_authorization_url += '?display=popup' | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
_birth_date = data.get('birthday') | ||||
if _birth_date: | ||||
try: | ||||
user.birth_date = datetime.datetime.strptime(_birth_date, | ||||
'%m/%d/%Y') | ||||
except ValueError: | ||||
pass | ||||
user.picture = ('http://graph.facebook.com/{0}/picture?type=large' | ||||
.format(user.id)) | ||||
user.location = data.get('location', {}).get('name') | ||||
if user.location: | ||||
split_location = user.location.split(', ') | ||||
user.city = split_location[0].strip() | ||||
if len(split_location) > 1: | ||||
user.country = split_location[1].strip() | ||||
return user | ||||
@staticmethod | ||||
def _x_credentials_parser(credentials, data): | ||||
""" | ||||
We need to override this method to fix Facebooks naming deviation. | ||||
""" | ||||
# Facebook returns "expires" instead of "expires_in". | ||||
credentials.expire_in = data.get('expires') | ||||
if data.get('token_type') == 'bearer': | ||||
# TODO: cls is not available here, hardcode for now. | ||||
credentials.token_type = 'Bearer' | ||||
return credentials | ||||
@staticmethod | ||||
def _x_refresh_credentials_if(credentials): | ||||
# Always refresh. | ||||
return True | ||||
def access(self, url, params=None, **kwargs): | ||||
if params is None: | ||||
params = {} | ||||
params['fields'] = 'id,first_name,last_name,picture,email,gender,' + \ | ||||
'timezone,location,birthday,locale' | ||||
return super(Facebook, self).access(url, params, **kwargs) | ||||
class Foursquare(OAuth2): | ||||
""" | ||||
Foursquare |oauth2| provider. | ||||
* Dashboard: https://foursquare.com/developers/apps | ||||
* Docs: https://developer.foursquare.com/overview/auth.html | ||||
* API reference: https://developer.foursquare.com/docs/ | ||||
.. note:: | ||||
Foursquare requires a *version* parameter in each request. | ||||
The default value is ``v=20140501``. You can override the version in | ||||
the ``params`` parameter of the :meth:`.Authomatic.access` method. | ||||
See https://developer.foursquare.com/overview/versioning | ||||
Supported :class:`.User` properties: | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* id | ||||
* last_name | ||||
* location | ||||
* name | ||||
* phone | ||||
* picture | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* link | ||||
* locale | ||||
* nickname | ||||
* postal_code | ||||
* timezone | ||||
* username | ||||
""" | ||||
user_authorization_url = 'https://foursquare.com/oauth2/authenticate' | ||||
access_token_url = 'https://foursquare.com/oauth2/access_token' | ||||
user_info_url = 'https://api.foursquare.com/v2/users/self' | ||||
same_origin = False | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
birth_date=True, | ||||
city=True, | ||||
country=True, | ||||
email=True, | ||||
first_name=True, | ||||
gender=True, | ||||
id=True, | ||||
last_name=True, | ||||
location=True, | ||||
name=True, | ||||
phone=True, | ||||
picture=True | ||||
) | ||||
@classmethod | ||||
def _x_request_elements_filter(cls, request_type, request_elements, | ||||
credentials): | ||||
if request_type == cls.PROTECTED_RESOURCE_REQUEST_TYPE: | ||||
# Foursquare uses OAuth 1.0 "oauth_token" for what should be | ||||
# "access_token" in OAuth 2.0! | ||||
url, method, params, headers, body = request_elements | ||||
params['oauth_token'] = params.pop('access_token') | ||||
# Foursquare needs the version "v" parameter in every request. | ||||
# https://developer.foursquare.com/overview/versioning | ||||
if not params.get('v'): | ||||
params['v'] = '20140501' | ||||
request_elements = core.RequestElements(url, method, params, | ||||
headers, body) | ||||
return request_elements | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
_resp = data.get('response', {}) | ||||
_user = _resp.get('user', {}) | ||||
user.id = _user.get('id') | ||||
user.first_name = _user.get('firstName') | ||||
user.last_name = _user.get('lastName') | ||||
user.gender = _user.get('gender') | ||||
_birth_date = _user.get('birthday') | ||||
if _birth_date: | ||||
user.birth_date = datetime.datetime.fromtimestamp(_birth_date) | ||||
_photo = _user.get('photo', {}) | ||||
if isinstance(_photo, dict): | ||||
_photo_prefix = _photo.get('prefix', '').strip('/') | ||||
_photo_suffix = _photo.get('suffix', '').strip('/') | ||||
user.picture = '/'.join([_photo_prefix, _photo_suffix]) | ||||
if isinstance(_photo, str): | ||||
user.picture = _photo | ||||
user.location = _user.get('homeCity') | ||||
if user.location: | ||||
split_location = user.location.split(',') | ||||
user.city = split_location[0].strip() | ||||
if len(user.location) > 1: | ||||
user.country = split_location[1].strip() | ||||
_contact = _user.get('contact', {}) | ||||
user.email = _contact.get('email') | ||||
user.phone = _contact.get('phone') | ||||
return user | ||||
class Bitbucket(OAuth2): | ||||
user_authorization_url = 'https://bitbucket.org/site/oauth2/authorize' | ||||
access_token_url = 'https://bitbucket.org/site/oauth2/access_token' | ||||
user_info_url = 'https://bitbucket.org/api/2.0/user' | ||||
user_email_info_url = 'https://bitbucket.org/api/2.0/user/emails' | ||||
same_origin = False | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
id=True, | ||||
first_name=True, | ||||
last_name=True, | ||||
link=True, | ||||
name=True, | ||||
picture=True, | ||||
username=True, | ||||
email=True | ||||
) | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.username = user.id = data.get('username') | ||||
user.name = data.get('display_name') | ||||
user.first_name = data.get('first_name') | ||||
user.last_name = data.get('last_name') | ||||
return user | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
def _access_user_info(self): | ||||
""" | ||||
Email is available in separate method so second request is needed. | ||||
""" | ||||
response = super(Bitbucket, self)._access_user_info() | ||||
response.data.setdefault("email", None) | ||||
email_response = self.access(self.user_email_info_url) | ||||
emails = email_response.data.get('values', []) | ||||
if emails: | ||||
for item in emails: | ||||
if item.get("is_primary", False): | ||||
response.data.update(email=item.get("email", None)) | ||||
return response | ||||
class GitHub(OAuth2): | ||||
""" | ||||
GitHub |oauth2| provider. | ||||
* Dashboard: https://github.com/settings/developers | ||||
* Docs: http://developer.github.com/v3/#authentication | ||||
* API reference: http://developer.github.com/v3/ | ||||
.. note:: | ||||
GitHub API | ||||
`documentation <http://developer.github.com/v3/#user-agent-required>`_ | ||||
says: | ||||
all API requests MUST include a valid ``User-Agent`` header. | ||||
You can apply a default ``User-Agent`` header for all API calls in | ||||
the config like this: | ||||
.. code-block:: python | ||||
:emphasize-lines: 6 | ||||
CONFIG = { | ||||
'github': { | ||||
'class_': oauth2.GitHub, | ||||
'consumer_key': '#####', | ||||
'consumer_secret': '#####', | ||||
'access_headers': {'User-Agent': 'Awesome-Octocat-App'}, | ||||
} | ||||
} | ||||
Supported :class:`.User` properties: | ||||
* id | ||||
* link | ||||
* location | ||||
* name | ||||
* picture | ||||
* username | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* last_name | ||||
* locale | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* timezone | ||||
""" | ||||
user_authorization_url = 'https://github.com/login/oauth/authorize' | ||||
access_token_url = 'https://github.com/login/oauth/access_token' | ||||
user_info_url = 'https://api.github.com/user' | ||||
same_origin = False | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
email=True, | ||||
id=True, | ||||
link=True, | ||||
location=True, | ||||
name=True, | ||||
picture=True, | ||||
username=True | ||||
) | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.username = data.get('login') | ||||
user.picture = data.get('avatar_url') | ||||
user.link = data.get('html_url') | ||||
return user | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
class Google(OAuth2): | ||||
""" | ||||
Google |oauth2| provider. | ||||
* Dashboard: https://console.developers.google.com/project | ||||
* Docs: https://developers.google.com/accounts/docs/OAuth2 | ||||
* API reference: https://developers.google.com/gdata/docs/directory | ||||
* API explorer: https://developers.google.com/oauthplayground/ | ||||
Supported :class:`.User` properties: | ||||
* first_name | ||||
* gender | ||||
* id | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* name | ||||
* picture | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* timezone | ||||
* username | ||||
.. note:: | ||||
To get the user info, you need to activate the **Google+ API** | ||||
in the **APIs & auth >> APIs** section of the`Google Developers Console | ||||
<https://console.developers.google.com/project>`__. | ||||
""" | ||||
user_authorization_url = 'https://accounts.google.com/o/oauth2/auth' | ||||
access_token_url = 'https://accounts.google.com/o/oauth2/token' | ||||
user_info_url = 'https://www.googleapis.com/oauth2/v3/userinfo?alt=json' | ||||
user_info_scope = ['profile', | ||||
'email'] | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
id=True, | ||||
email=True, | ||||
name=True, | ||||
first_name=True, | ||||
last_name=True, | ||||
locale=True, | ||||
picture=True | ||||
) | ||||
def __init__(self, *args, **kwargs): | ||||
super(Google, self).__init__(*args, **kwargs) | ||||
# Handle special Google requirements to be able to refresh the access | ||||
# token. | ||||
if self.offline: | ||||
if 'access_type' not in self.user_authorization_params: | ||||
# Google needs access_type=offline param in the user | ||||
# authorization request. | ||||
self.user_authorization_params['access_type'] = 'offline' | ||||
if 'approval_prompt' not in self.user_authorization_params: | ||||
# And also approval_prompt=force. | ||||
self.user_authorization_params['approval_prompt'] = 'force' | ||||
@classmethod | ||||
def _x_request_elements_filter(cls, request_type, request_elements, | ||||
credentials): | ||||
""" | ||||
Google doesn't accept client ID and secret to be at the same time in | ||||
request parameters and in the basic authorization header in the access | ||||
token request. | ||||
""" | ||||
if request_type is cls.ACCESS_TOKEN_REQUEST_TYPE: | ||||
params = request_elements[2] | ||||
del params['client_id'] | ||||
del params['client_secret'] | ||||
return request_elements | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
emails = data.get('emails', []) | ||||
if emails: | ||||
user.email = emails[0].get('value') | ||||
for email in emails: | ||||
if email.get('type') == 'account': | ||||
user.email = email.get('value') | ||||
break | ||||
user.id = data.get('sub') | ||||
user.name = data.get('name') | ||||
user.first_name = data.get('given_name', '') | ||||
user.last_name = data.get('family_name', '') | ||||
user.locale = data.get('locale', '') | ||||
user.picture = data.get('picture', '') | ||||
user.email_verified = data.get("email_verified") | ||||
user.hosted_domain = data.get("hd") | ||||
return user | ||||
def _x_scope_parser(self, scope): | ||||
""" | ||||
Google has space-separated scopes. | ||||
""" | ||||
return ' '.join(scope) | ||||
class LinkedIn(OAuth2): | ||||
""" | ||||
Linked In |oauth2| provider. | ||||
.. note:: | ||||
Doesn't support access token refreshment. | ||||
* Dashboard: https://www.linkedin.com/secure/developer | ||||
* Docs: http://developer.linkedin.com/documents/authentication | ||||
* API reference: http://developer.linkedin.com/rest | ||||
Supported :class:`.User` properties: | ||||
* city | ||||
* country | ||||
* first_name | ||||
* id | ||||
* last_name | ||||
* link | ||||
* name | ||||
* picture | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* gender | ||||
* locale | ||||
* location | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* timezone | ||||
* username | ||||
""" | ||||
user_authorization_url = 'https://www.linkedin.com/uas/oauth2/' + \ | ||||
'authorization' | ||||
access_token_url = 'https://www.linkedin.com/uas/oauth2/accessToken' | ||||
user_info_url = ('https://api.linkedin.com/v1/people/~:' | ||||
'(id,first-name,last-name,formatted-name,location,' | ||||
'picture-url,public-profile-url,email-address)' | ||||
'?format=json') | ||||
user_info_scope = ['r_emailaddress'] | ||||
token_request_method = 'GET' # To avoid a bug with OAuth2.0 on Linkedin | ||||
# http://developer.linkedin.com/forum/unauthorized-invalid-or-expired-token-immediately-after-receiving-oauth2-token | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
city=True, | ||||
country=True, | ||||
email=True, | ||||
first_name=True, | ||||
id=True, | ||||
last_name=True, | ||||
link=True, | ||||
location=False, | ||||
name=True, | ||||
picture=True | ||||
) | ||||
@classmethod | ||||
def _x_request_elements_filter(cls, request_type, request_elements, | ||||
credentials): | ||||
if request_type == cls.PROTECTED_RESOURCE_REQUEST_TYPE: | ||||
# LinkedIn too has it's own terminology! | ||||
url, method, params, headers, body = request_elements | ||||
params['oauth2_access_token'] = params.pop('access_token') | ||||
request_elements = core.RequestElements(url, method, params, | ||||
headers, body) | ||||
return request_elements | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.first_name = data.get('firstName') | ||||
user.last_name = data.get('lastName') | ||||
user.email = data.get('emailAddress') | ||||
user.name = data.get('formattedName') | ||||
user.city = user.city = data.get('location', {}).get('name') | ||||
user.country = data.get('location', {}).get('country', {}).get('code') | ||||
user.phone = data.get('phoneNumbers', {}).get('values', [{}])[0]\ | ||||
.get('phoneNumber') | ||||
user.picture = data.get('pictureUrl') | ||||
user.link = data.get('publicProfileUrl') | ||||
_birthdate = data.get('dateOfBirth', {}) | ||||
if _birthdate: | ||||
_day = _birthdate.get('day') | ||||
_month = _birthdate.get('month') | ||||
_year = _birthdate.get('year') | ||||
if _day and _month and _year: | ||||
user.birth_date = datetime.datetime(_year, _month, _day) | ||||
return user | ||||
class PayPal(OAuth2): | ||||
""" | ||||
PayPal |oauth2| provider. | ||||
* Dashboard: https://developer.paypal.com/webapps/developer/applications | ||||
* Docs: | ||||
https://developer.paypal.com/webapps/developer/docs/integration/direct/make-your-first-call/ | ||||
* API reference: https://developer.paypal.com/webapps/developer/docs/api/ | ||||
.. note:: | ||||
Paypal doesn't redirect the **user** to authorize your app! | ||||
It grants you an **access token** based on your **app's** key and | ||||
secret instead. | ||||
""" | ||||
_x_use_authorization_header = True | ||||
supported_user_attributes = core.SupportedUserAttributes() | ||||
@classmethod | ||||
def _x_request_elements_filter( | ||||
cls, request_type, request_elements, credentials): | ||||
if request_type == cls.ACCESS_TOKEN_REQUEST_TYPE: | ||||
url, method, params, headers, body = request_elements | ||||
params['grant_type'] = 'client_credentials' | ||||
request_elements = core.RequestElements( | ||||
url, method, params, headers, body) | ||||
return request_elements | ||||
user_authorization_url = '' | ||||
access_token_url = 'https://api.sandbox.paypal.com/v1/oauth2/token' | ||||
user_info_url = '' | ||||
class Reddit(OAuth2): | ||||
""" | ||||
Reddit |oauth2| provider. | ||||
.. note:: | ||||
Currently credentials refreshment returns | ||||
``{"error": "invalid_request"}``. | ||||
* Dashboard: https://ssl.reddit.com/prefs/apps | ||||
* Docs: https://github.com/reddit/reddit/wiki/OAuth2 | ||||
* API reference: http://www.reddit.com/dev/api | ||||
.. note:: | ||||
According to Reddit API | ||||
`docs <https://github.com/reddit/reddit/wiki/API#rules>`_, | ||||
you have to include a `User-Agent` header in each API call. | ||||
You can apply a default ``User-Agent`` header for all API calls in the | ||||
config like this: | ||||
.. code-block:: python | ||||
:emphasize-lines: 6 | ||||
CONFIG = { | ||||
'reddit': { | ||||
'class_': oauth2.Reddit, | ||||
'consumer_key': '#####', | ||||
'consumer_secret': '#####', | ||||
'access_headers': {'User-Agent': "Andy Pipkin's App"}, | ||||
} | ||||
} | ||||
Supported :class:`.User` properties: | ||||
* id | ||||
* username | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* country | ||||
* city | ||||
* first_name | ||||
* gender | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* location | ||||
* name | ||||
* nickname | ||||
* phone | ||||
* picture | ||||
* postal_code | ||||
* timezone | ||||
""" | ||||
user_authorization_url = 'https://ssl.reddit.com/api/v1/authorize' | ||||
access_token_url = 'https://ssl.reddit.com/api/v1/access_token' | ||||
user_info_url = 'https://oauth.reddit.com/api/v1/me.json' | ||||
user_info_scope = ['identity'] | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
id=True, | ||||
name=True, | ||||
username=True | ||||
) | ||||
def __init__(self, *args, **kwargs): | ||||
super(Reddit, self).__init__(*args, **kwargs) | ||||
if self.offline: | ||||
if 'duration' not in self.user_authorization_params: | ||||
# http://www.reddit.com/r/changelog/comments/11jab9/reddit_change_permanent_oauth_grants_using/ | ||||
self.user_authorization_params['duration'] = 'permanent' | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.username = data.get('name') | ||||
return user | ||||
class Viadeo(OAuth2): | ||||
""" | ||||
Viadeo |oauth2| provider. | ||||
.. note:: | ||||
As stated in the `Viadeo documentation | ||||
<http://dev.viadeo.com/documentation/authentication/request-an-api-key/>`__: | ||||
Viadeo restrains access to its API. | ||||
They are now exclusively reserved for its strategic partners. | ||||
* Dashboard: http://dev.viadeo.com/dashboard/ | ||||
* Docs: | ||||
http://dev.viadeo.com/documentation/authentication/oauth-authentication/ | ||||
* API reference: http://dev.viadeo.com/documentation/ | ||||
.. note:: | ||||
Viadeo doesn't support **credentials refreshment**. | ||||
As stated in their | ||||
`docs | ||||
<http://dev.viadeo.com/documentation/authentication/oauth-authentication/>`_: | ||||
"The access token has an infinite time to live." | ||||
""" | ||||
user_authorization_url = 'https://secure.viadeo.com/oauth-provider/' + \ | ||||
'authorize2' | ||||
access_token_url = 'https://secure.viadeo.com/oauth-provider/access_token2' | ||||
user_info_url = 'https://api.viadeo.com/me' | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer_token': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
@staticmethod | ||||
def _x_refresh_credentials_if(credentials): | ||||
# Never refresh. | ||||
return False | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.username = data.get('nickname') | ||||
user.picture = data.get('picture_large') | ||||
user.picture = data.get('picture_large') | ||||
user.locale = data.get('language') | ||||
user.email = data.get('') | ||||
user.email = data.get('') | ||||
user.country = data.get('location', {}).get('country') | ||||
user.city = data.get('location', {}).get('city') | ||||
user.postal_code = data.get('location', {}).get('zipcode') | ||||
user.timezone = data.get('location', {}).get('timezone') | ||||
return user | ||||
class VK(OAuth2): | ||||
""" | ||||
VK.com |oauth2| provider. | ||||
* Dashboard: http://vk.com/apps?act=manage | ||||
* Docs: http://vk.com/developers.php?oid=-17680044&p=Authorizing_Sites | ||||
* API reference: http://vk.com/developers.php?oid=-17680044&p=API_ | ||||
Method_Description | ||||
.. note:: | ||||
VK uses a | ||||
`bitmask scope | ||||
<http://vk.com/developers.php?oid=-17680044&p=Application_Rights>`_! | ||||
Use it like this: | ||||
.. code-block:: python | ||||
:emphasize-lines: 7 | ||||
CONFIG = { | ||||
'vk': { | ||||
'class_': oauth2.VK, | ||||
'consumer_key': '#####', | ||||
'consumer_secret': '#####', | ||||
'id': authomatic.provider_id(), | ||||
'scope': ['1024'] # Always a single item. | ||||
} | ||||
} | ||||
Supported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* id | ||||
* last_name | ||||
* location | ||||
* name | ||||
* picture | ||||
* timezone | ||||
Unsupported :class:`.User` properties: | ||||
* link | ||||
* locale | ||||
* nickname | ||||
* phone | ||||
* postal_code | ||||
* username | ||||
""" | ||||
user_authorization_url = 'http://api.vkontakte.ru/oauth/authorize' | ||||
access_token_url = 'https://api.vkontakte.ru/oauth/access_token' | ||||
user_info_url = 'https://api.vk.com/method/getProfiles?' + \ | ||||
'fields=uid,first_name,last_name,nickname,sex,bdate,' + \ | ||||
'city,country,timezone,photo_big' | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
birth_date=True, | ||||
city=True, | ||||
country=True, | ||||
first_name=True, | ||||
gender=True, | ||||
id=True, | ||||
last_name=True, | ||||
location=True, | ||||
name=True, | ||||
picture=True, | ||||
timezone=True, | ||||
) | ||||
def __init__(self, *args, **kwargs): | ||||
super(VK, self).__init__(*args, **kwargs) | ||||
if self.offline: | ||||
if 'offline' not in self.scope: | ||||
self.scope.append('offline') | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
_resp = data.get('response', [{}])[0] | ||||
_birth_date = _resp.get('bdate') | ||||
if _birth_date: | ||||
user.birth_date = datetime.datetime.strptime( | ||||
_birth_date, '%d.%m.%Y') | ||||
user.id = _resp.get('uid') | ||||
user.first_name = _resp.get('first_name') | ||||
user.gender = _resp.get('sex') | ||||
user.last_name = _resp.get('last_name') | ||||
user.nickname = _resp.get('nickname') | ||||
user.city = _resp.get('city') | ||||
user.country = _resp.get('country') | ||||
user.timezone = _resp.get('timezone') | ||||
user.picture = _resp.get('photo_big') | ||||
return user | ||||
class WindowsLive(OAuth2): | ||||
""" | ||||
Windows Live |oauth2| provider. | ||||
* Dashboard: https://account.live.com/developers/applications | ||||
* Docs: http://msdn.microsoft.com/en-us/library/hh243647.aspx | ||||
* API explorer: http://isdk.dev.live.com/?mkt=en-us | ||||
Supported :class:`.User` properties: | ||||
* first_name | ||||
* id | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* name | ||||
* picture | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* gender | ||||
* nickname | ||||
* location | ||||
* phone | ||||
* postal_code | ||||
* timezone | ||||
* username | ||||
""" | ||||
user_authorization_url = 'https://login.live.com/oauth20_authorize.srf' | ||||
access_token_url = 'https://login.live.com/oauth20_token.srf' | ||||
user_info_url = 'https://apis.live.net/v5.0/me' | ||||
user_info_scope = ['wl.basic', 'wl.emails', 'wl.photos'] | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
email=True, | ||||
first_name=True, | ||||
id=True, | ||||
last_name=True, | ||||
link=True, | ||||
locale=True, | ||||
name=True, | ||||
picture=True | ||||
) | ||||
def __init__(self, *args, **kwargs): | ||||
super(WindowsLive, self).__init__(*args, **kwargs) | ||||
if self.offline: | ||||
if 'wl.offline_access' not in self.scope: | ||||
self.scope.append('wl.offline_access') | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
user.email = data.get('emails', {}).get('preferred') | ||||
user.picture = 'https://apis.live.net/v5.0/{0}/picture'.format( | ||||
data.get('id')) | ||||
return user | ||||
class Yammer(OAuth2): | ||||
""" | ||||
Yammer |oauth2| provider. | ||||
* Dashboard: https://www.yammer.com/client_applications | ||||
* Docs: https://developer.yammer.com/authentication/ | ||||
* API reference: https://developer.yammer.com/restapi/ | ||||
Supported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* id | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* location | ||||
* name | ||||
* phone | ||||
* picture | ||||
* timezone | ||||
* username | ||||
Unsupported :class:`.User` properties: | ||||
* gender | ||||
* nickname | ||||
* postal_code | ||||
""" | ||||
user_authorization_url = 'https://www.yammer.com/dialog/oauth' | ||||
access_token_url = 'https://www.yammer.com/oauth2/access_token.json' | ||||
user_info_url = 'https://www.yammer.com/api/v1/users/current.json' | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
birth_date=True, | ||||
city=True, | ||||
country=True, | ||||
email=True, | ||||
first_name=True, | ||||
id=True, | ||||
last_name=True, | ||||
link=True, | ||||
locale=True, | ||||
location=True, | ||||
name=True, | ||||
phone=True, | ||||
picture=True, | ||||
timezone=True, | ||||
username=True | ||||
) | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
# import pdb; pdb.set_trace() | ||||
credentials.token_type = cls.BEARER | ||||
_access_token = data.get('access_token', {}) | ||||
credentials.token = _access_token.get('token') | ||||
_expire_in = _access_token.get('expires_at', 0) | ||||
if _expire_in: | ||||
credentials.expire_in = _expire_in | ||||
return credentials | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
# Yammer provides most of the user info in the access token request, | ||||
# but provides more on in user info request. | ||||
_user = data.get('user', {}) | ||||
if not _user: | ||||
# If there is "user key", it is token request. | ||||
_user = data | ||||
user.username = _user.get('name') | ||||
user.name = _user.get('full_name') | ||||
user.link = _user.get('web_url') | ||||
user.picture = _user.get('mugshot_url') | ||||
user.city, user.country = _user.get('location', ',').split(',') | ||||
user.city = user.city.strip() | ||||
user.country = user.country.strip() | ||||
user.locale = _user.get('web_preferences', {}).get('locale') | ||||
# Contact | ||||
_contact = _user.get('contact', {}) | ||||
user.phone = _contact.get('phone_numbers', [{}])[0].get('number') | ||||
_emails = _contact.get('email_addresses', []) | ||||
for email in _emails: | ||||
if email.get('type', '') == 'primary': | ||||
user.email = email.get('address') | ||||
break | ||||
try: | ||||
user.birth_date = datetime.datetime.strptime( | ||||
_user.get('birth_date'), "%B %d") | ||||
except ValueError: | ||||
user.birth_date = _user.get('birth_date') | ||||
return user | ||||
class Yandex(OAuth2): | ||||
""" | ||||
Yandex |oauth2| provider. | ||||
* Dashboard: https://oauth.yandex.com/client/my | ||||
* Docs: | ||||
http://api.yandex.com/oauth/doc/dg/reference/obtain-access-token.xml | ||||
* API reference: | ||||
Supported :class:`.User` properties: | ||||
* id | ||||
* name | ||||
* username | ||||
Unsupported :class:`.User` properties: | ||||
* birth_date | ||||
* city | ||||
* country | ||||
* first_name | ||||
* gender | ||||
* last_name | ||||
* link | ||||
* locale | ||||
* location | ||||
* nickname | ||||
* phone | ||||
* picture | ||||
* postal_code | ||||
* timezone | ||||
""" | ||||
user_authorization_url = 'https://oauth.yandex.com/authorize' | ||||
access_token_url = 'https://oauth.yandex.com/token' | ||||
user_info_url = 'https://login.yandex.ru/info' | ||||
supported_user_attributes = core.SupportedUserAttributes( | ||||
id=True, | ||||
name=True, | ||||
username=True | ||||
) | ||||
@classmethod | ||||
def _x_credentials_parser(cls, credentials, data): | ||||
if data.get('token_type') == 'bearer': | ||||
credentials.token_type = cls.BEARER | ||||
return credentials | ||||
@staticmethod | ||||
def _x_user_parser(user, data): | ||||
# http://api.yandex.ru/login/doc/dg/reference/response.xml | ||||
user.name = data.get('real_name') | ||||
user.nickname = data.get('display_name') | ||||
user.gender = data.get('Sex') | ||||
user.email = data.get('Default_email') | ||||
user.username = data.get('login') | ||||
try: | ||||
user.birth_date = datetime.datetime.strptime( | ||||
data.get('birthday'), "%Y-%m-%d") | ||||
except ValueError: | ||||
user.birth_date = data.get('birthday') | ||||
return user | ||||
# The provider type ID is generated from this list's indexes! | ||||
# Always append new providers at the end so that ids of existing providers | ||||
# don't change! | ||||
PROVIDER_ID_MAP = [ | ||||
Amazon, | ||||
Behance, | ||||
Bitly, | ||||
Bitbucket, | ||||
Cosm, | ||||
DeviantART, | ||||
Eventbrite, | ||||
Facebook, | ||||
Foursquare, | ||||
GitHub, | ||||
Google, | ||||
LinkedIn, | ||||
OAuth2, | ||||
PayPal, | ||||
Reddit, | ||||
Viadeo, | ||||
VK, | ||||
WindowsLive, | ||||
Yammer, | ||||
Yandex, | ||||
] | ||||