diff options
Diffstat (limited to 'pygithub3/core')
-rw-r--r-- | pygithub3/core/__init__.py | 0 | ||||
-rw-r--r-- | pygithub3/core/client.py | 96 | ||||
-rw-r--r-- | pygithub3/core/errors.py | 41 | ||||
-rw-r--r-- | pygithub3/core/resources/__init__.py | 87 | ||||
-rw-r--r-- | pygithub3/core/resources/users/__init__.py | 4 | ||||
-rw-r--r-- | pygithub3/core/resources/users/emails.py | 9 | ||||
-rw-r--r-- | pygithub3/core/resources/users/followers.py | 0 | ||||
-rw-r--r-- | pygithub3/core/resources/users/keys.py | 0 | ||||
-rw-r--r-- | pygithub3/core/resources/users/user.py | 25 |
9 files changed, 262 insertions, 0 deletions
diff --git a/pygithub3/core/__init__.py b/pygithub3/core/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/pygithub3/core/__init__.py diff --git a/pygithub3/core/client.py b/pygithub3/core/client.py new file mode 100644 index 0000000..d4247af --- /dev/null +++ b/pygithub3/core/client.py @@ -0,0 +1,96 @@ +#!/usr/bin/env python +# -*- encoding: utf-8 -*- + +import requests + +from .errors import GithubError + +VALID_REQUEST_ARGS = set(( + 'params', 'data', 'headers', 'cookies', 'files', 'auth', 'timeout', + 'allow_redirects', 'proxies', 'return_response', 'config', + 'prefetch', 'verify')) + + +class Client(object): + """ Client to send configurated requests""" + + def __init__(self, **kwargs): + """ + It can be configurated + + :login, :password, :user, :repo, :token, :per_page, :base_url + """ + + self.requester = requests.session() + self.config = { + 'per_page': 100, + 'base_url': 'https://api.github.com/' + } + self.config.update(kwargs) + self.set_credentials(self.config.get('login'), + self.config.get('password')) + self.set_token(self.config.get('token')) + self.__set_params(self.config) + + @property + def user(self): + return self.config.get('user') + + @user.setter + def set_user(self, user): + self.config['user'] = user + + @property + def repo(self): + return self.config.get('repo') + + @repo.setter + def set_repo(self, repo): + self.config['repo'] = repo + + def set_credentials(self, login, password): + if login and password: + self.requester.auth = (login, password) + + def set_token(self, token): + if token: + self.requester.params['access_token'] = token + + def __set_params(self, config): + self.requester.params['per_page'] = config.get('per_page') + + def __parse_kwargs(func): + """ Decorator to put extra args into requests.params """ + + def wrapper(self, verb, resource, **kwargs): + diffs = kwargs.viewkeys() - VALID_REQUEST_ARGS + new_params = kwargs.get('params') or {} + new_params.update({key: kwargs[key] for key in diffs}) + kwargs['params'] = new_params + return func(self, verb, resource, **kwargs) + return wrapper + + @__parse_kwargs + def request(self, verb, resource, **kwargs): + resource = "%s%s" % (self.config['base_url'], resource) + response = self.requester.request(verb, resource, **kwargs) + GithubError(response).process() + return response + + def get(self, resource, **kwargs): + return self.request('get', resource, **kwargs) + + def post(self, resource, **kwargs): + return self.request('post', resource, **kwargs) + + def patch(self, resource, **kwargs): + return self.request('patch', resource, **kwargs) + + def put(self, resource, **kwargs): + return self.request('put', resource, **kwargs) + + def delete(self, resource, **kwargs): + return self.request('delete', resource, **kwargs) + + def head(self, resource, **kwargs): + return self.request('head', resource, **kwargs) diff --git a/pygithub3/core/errors.py b/pygithub3/core/errors.py new file mode 100644 index 0000000..0d58c16 --- /dev/null +++ b/pygithub3/core/errors.py @@ -0,0 +1,41 @@ +#!/usr/bin/env python +# -*- encoding: utf-8 -*- + +import json + + +class BadRequest(Exception): + pass + + +class UnprocessableEntity(Exception): + pass + + +class GithubError(object): + """ Handler for API errors """ + + def __init__(self, response): + self.response = response + self.status_code = response.status_code + try: + self.debug = json.loads(response.content) + except (ValueError, TypeError): + self.debug = {'message': response.content} + + def error_400(self): + return BadRequest("400 - %s" % self.debug.get('message')) + + def error_422(self): + errors = self.debug.get('errors') + if errors: + errors = ['{resource}: {code} => {field}'.format(**error) + for error in errors] + return UnprocessableEntity( + '422 - %s %s' % (self.debug.get('message'), errors)) + + def process(self): + raise_error = getattr(self, 'error_%s' % self.status_code, False) + if raise_error: + raise raise_error() + self.response.raise_for_status() diff --git a/pygithub3/core/resources/__init__.py b/pygithub3/core/resources/__init__.py new file mode 100644 index 0000000..bca9607 --- /dev/null +++ b/pygithub3/core/resources/__init__.py @@ -0,0 +1,87 @@ +#!/usr/bin/env python +# -*- encoding: utf-8 -*- + +import re + +ABS_IMPORT_PREFIX = 'pygithub3.core.resources' + + +class UriNotFound(Exception): + pass + + +class UriInvalid(Exception): + pass + + +class Resource(object): + """ """ + + def __init__(self, args): + """ """ + self.args = args + self.validate() + self.uri = self.set_uri() + + def validate(self, args): + raise NotImplementedError + + def set_uri(self): + raise NotImplementedError + + def get_uri(self): + return str(self.uri).strip('/') + + def get_model(self): + return getattr(self, 'model', '') + + def __getattr__(self, name): + return self.args.get(name) + + def __str__(self): + return self.get_uri() + + +class Factory(object): + """ """ + + import_pattern = re.compile(r'^(\w+\.)+\w+$') + + def __init__(self, **kwargs): + self.args = kwargs + + def __validate(func): + """ """ + + def wrapper(self, resource_path): + if not Factory.import_pattern.match(resource_path): + raise UriInvalid("'%s' isn't valid form" % resource_path) + return func(self, resource_path.lower()) + return wrapper + + def __dispatch(func): + """ """ + + from importlib import import_module + + def wrapper(self, resource_path): + module_chunk, s, uri_chunk = resource_path.rpartition('.') + try: + # TODO: CamelCase and under_score support, now only Class Name + module = import_module('%s.%s' + % (ABS_IMPORT_PREFIX, module_chunk)) + uri = getattr(module, uri_chunk.capitalize()) + except ImportError: + raise UriNotFound("'%s' module does not exists" % module_chunk) + except AttributeError: + raise UriNotFound("'%s' uri doesn't exists into '%s' module" + % (uri_chunk.capitalize(), module_chunk)) + return func(self, uri) + return wrapper + + @__validate + @__dispatch + def __call__(self, resource_class=''): + resource = resource_class(self.args) + assert isinstance(resource, Resource) + return resource diff --git a/pygithub3/core/resources/users/__init__.py b/pygithub3/core/resources/users/__init__.py new file mode 100644 index 0000000..84759a2 --- /dev/null +++ b/pygithub3/core/resources/users/__init__.py @@ -0,0 +1,4 @@ +# -*- encoding: utf-8 -*- + +from pygithub3.core.resources import Resource +from user import * diff --git a/pygithub3/core/resources/users/emails.py b/pygithub3/core/resources/users/emails.py new file mode 100644 index 0000000..18d520c --- /dev/null +++ b/pygithub3/core/resources/users/emails.py @@ -0,0 +1,9 @@ +#!/usr/bin/env python +# -*- encoding: utf-8 -*- + +from . import Resource +#from pygithub3.models. + + +class List(Resource): + pass diff --git a/pygithub3/core/resources/users/followers.py b/pygithub3/core/resources/users/followers.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/pygithub3/core/resources/users/followers.py diff --git a/pygithub3/core/resources/users/keys.py b/pygithub3/core/resources/users/keys.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/pygithub3/core/resources/users/keys.py diff --git a/pygithub3/core/resources/users/user.py b/pygithub3/core/resources/users/user.py new file mode 100644 index 0000000..1399ff8 --- /dev/null +++ b/pygithub3/core/resources/users/user.py @@ -0,0 +1,25 @@ +#!/usr/bin/env python +# -*- encoding: utf-8 -*- + +from . import Resource +from pygithub3.models.users import User + +__all__ = ('Get', 'Update') + + +class Get(Resource): + + model = User + + def validate(self): + pass + + def set_uri(self): + if self.user: + return 'users/%s' % self.user + else: + return 'user' + + +class Update(Resource): + pass |