Update classifiers

Author: Thoradin89

build/lib/mailjet_rest/__init__.py

@@ -0,0 +1,8 @@
+#!/usr/bin/env python
+# coding=utf-8
+from mailjet_rest.client import Client
+from mailjet_rest.utils.version import get_version
+
+__version__ = get_version()
+
+__all__ = (Client, get_version)

build/lib/mailjet_rest/client.py

@@ -0,0 +1,181 @@
+#!/usr/bin/env python
+# coding=utf-8
+
+import json
+import logging
+
+import requests
+from requests.compat import urljoin
+from .utils.version import get_version
+
+requests.packages.urllib3.disable_warnings()
+
+
+class Config(object):
+    API_URL = 'https://api.mailjet.com/'
+    API_REF = 'http://dev.mailjet.com/email-api/v3/'
+    version = 'v3'
+    user_agent = 'mailjet-apiv3-python/v' + get_version()
+
+    def __init__(self, version=None):
+        if version is not None:
+            self.version = version
+
+    def __getitem__(self, key):
+        url = self.API_URL[0:]
+        # Append version to URL.
+        # Forward slash is ignored if present in self.version.
+        url = urljoin(url, self.version + '/')
+        headers = {'Content-type': 'application/json', 'User-agent': self.user_agent}
+        if key.lower() == 'contactslist_csvdata':
+            url = urljoin(url, 'DATA/')
+            headers['Content-type'] = 'text/plain'
+        elif key.lower() == 'batchjob_csverror':
+            url = urljoin(url, 'DATA/')
+            headers['Content-type'] = 'text/csv'
+        elif key.lower() != 'send':
+            url = urljoin(url, 'REST/')
+        url = url + key.split('_')[0].lower()
+        return url, headers
+
+
+class Endpoint(object):
+
+    def __init__(self, url, headers, auth, action=None):
+        self._url, self.headers, self._auth, self.action = url, headers, auth, action
+
+    def __doc__(self):
+        return self._doc
+
+    def _get(self, filters=None, action_id=None, id=None, **kwargs):
+        return api_call(self._auth, 'get', self._url, headers=self.headers, action=self.action, action_id=action_id, filters=filters, resource_id=id, **kwargs)
+
+    def get_many(self, filters=None, action_id=None, **kwargs):
+        return self._get(filters=filters, **kwargs)
+
+    def get(self, id=None, filters=None, action_id=None, **kwargs):
+        return self._get(id=id, filters=filters, **kwargs)
+
+    def create(self, data=None, filters=None, id=None, action_id=None, **kwargs):
+        if self.headers['Content-type'] == 'application/json':
+            data = json.dumps(data)
+        return api_call(self._auth, 'post', self._url, headers=self.headers, resource_id=id, data=data, action=self.action, action_id=action_id, filters=filters, **kwargs)
+
+    def update(self, id, data, filters=None, action_id=None, **kwargs):
+        if self.headers['Content-type'] == 'application/json':
+            data = json.dumps(data)
+        return api_call(self._auth, 'put', self._url, resource_id=id, headers=self.headers, data=data, action=self.action, action_id=action_id, filters=filters, **kwargs)
+
+    def delete(self, id, **kwargs):
+        return api_call(self._auth, 'delete', self._url, action=self.action, headers=self.headers, resource_id=id, **kwargs)
+
+
+class Client(object):
+
+    def __init__(self, auth=None, **kwargs):
+        self.auth = auth
+        version = kwargs.get('version', None)
+        self.config = Config(version=version)
+
+    def __getattr__(self, name):
+        split = name.split('_')
+        fname = split[0]
+        action = None
+        if (len(split) > 1):
+            action = split[1]
+            if action == 'csvdata':
+                action = 'csvdata/text:plain'
+            if action == 'csverror':
+                action = 'csverror/text:csv'
+        url, headers = self.config[name]
+        return type(fname, (Endpoint,), {})(url=url, headers=headers, action=action, auth=self.auth)
+
+
+def api_call(auth, method, url, headers, data=None, filters=None, resource_id=None,
+             timeout=60, debug=False, action=None, action_id=None, **kwargs):
+    url = build_url(url, method=method, action=action, resource_id=resource_id, action_id=action_id)
+    req_method = getattr(requests, method)
+
+    try:
+        response = req_method(url, data=data, params=filters, headers=headers, auth=auth,
+                              timeout=timeout, verify=True, stream=False)
+        return response
+
+    except requests.exceptions.Timeout:
+        raise TimeoutError
+    except requests.RequestException as e:
+        raise ApiError(e)
+    except Exception as e:
+        raise
+
+
+def build_headers(resource, action=None, extra_headers=None):
+    headers = {'Content-type': 'application/json'}
+
+    if resource.lower() == 'contactslist' and action.lower() == 'csvdata':
+        headers = {'Content-type': 'text/plain'}
+    elif resource.lower() == 'batchjob' and action.lower() == 'csverror':
+        headers = {'Content-type': 'text/csv'}
+
+    if extra_headers:
+        headers.update(extra_headers)
+
+    return headers
+
+
+def build_url(url, method, action=None, resource_id=None, action_id=None):
+    if resource_id:
+        url += '/%s' % str(resource_id)
+    if action:
+        url += '/%s' % action
+        if action_id:
+            url += '/%d' % action_id
+
+    return url
+
+
+def parse_response(response, debug=False):
+    data = response.json()
+
+    if debug:
+        logging.debug('REQUEST: %s' % response.request.url)
+        logging.debug('REQUEST_HEADERS: %s' % response.request.headers)
+        logging.debug('REQUEST_CONTENT: %s' % response.request.body)
+
+        logging.debug('RESPONSE: %s' % response.content)
+        logging.debug('RESP_HEADERS: %s' % response.headers)
+        logging.debug('RESP_CODE: %s' % response.status_code)
+
+    return data
+
+
+class ApiError(Exception):
+    pass
+
+
+class AuthorizationError(ApiError):
+    pass
+
+
+class ActionDeniedError(ApiError):
+    pass
+
+
+class CriticalApiError(ApiError):
+    pass
+
+
+class ApiRateLimitError(ApiError):
+    pass
+
+
+class TimeoutError(ApiError):
+    pass
+
+
+class DoesNotExistError(ApiError):
+    pass
+
+
+class ValidationError(ApiError):
+    pass

build/lib/mailjet_rest/utils/__init__.py

@@ -0,0 +1,13 @@
+VERSION = (1, 3, 0)
+
+
+def get_version(version=None):
+    '''
+    Calculate package version based on a 3 item tuple.
+    In addition verify that the tuple contains 3 items
+    '''
+    if version is None:
+        version = VERSION
+    else:
+        assert len(version) == 3
+    return '{0}.{1}.{2}'.format(*(x for x in version))

build/lib/mailjet_rest/utils/version.py

@@ -24,7 +24,7 @@
     url='https://github.com/mailjet/mailjet-apiv3-python',
     description=('Mailjet V3 API wrapper'),
     long_description=long_description,
-    classifiers=['Development Status :: 3',
+    classifiers=['Development Status :: 4',
                  'Environment :: Console',
                  'Intended Audience :: Developers',
                  'License :: OSI Approved :: GNU General Public License (GPL)',