aboutsummaryrefslogtreecommitdiffstats
path: root/pygithub3/core
diff options
context:
space:
mode:
Diffstat (limited to 'pygithub3/core')
-rw-r--r--pygithub3/core/__init__.py0
-rw-r--r--pygithub3/core/client.py96
-rw-r--r--pygithub3/core/errors.py41
-rw-r--r--pygithub3/core/resources/__init__.py87
-rw-r--r--pygithub3/core/resources/users/__init__.py4
-rw-r--r--pygithub3/core/resources/users/emails.py9
-rw-r--r--pygithub3/core/resources/users/followers.py0
-rw-r--r--pygithub3/core/resources/users/keys.py0
-rw-r--r--pygithub3/core/resources/users/user.py25
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