initial commit

Author: dakra

.gitignore

@@ -0,0 +1,14 @@
+*.pyc
+*.cache
+*#*
+*.egg-info
+*.egg
+*.iml
+.DS_Store
+.ropeproject
+.idea
+build
+_build
+dist
+env
+.venv

CHANGES.txt

@@ -0,0 +1,4 @@
+0.1.0
+-----
+
+-  Initial version

LICENSE

@@ -0,0 +1,13 @@
+Copyright (c) 2015, Spot Media Solutions Sdn. Bhd. <daniel@atomx.com>
+
+Permission to use, copy, modify, and/or distribute this software for any
+purpose with or without fee is hereby granted, provided that the above
+copyright notice and this permission notice appear in all copies.
+
+THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.

MANIFEST.in

@@ -0,0 +1,2 @@
+include *.txt *.ini *.cfg *.rst
+recursive-include atomx

README.rst

@@ -0,0 +1,15 @@
+atomx api README
+================
+
+This module let's you easlily
+
+
+Installation
+------------
+
+To install the python atomx api, simply:
+
+.. code-block:: bash
+
+    $ pip install atomx
+

atomx/__init__.py

@@ -0,0 +1,70 @@
+# -*- coding: utf-8 -*-
+
+import requests
+from .version import API_VERSION, VERSION
+from . import models
+from .exceptions import (
+    APIError,
+    ModelNotFoundError,
+    InvalidCredentials,
+)
+
+
+__title__ = 'atomx'
+__version__ = VERSION
+__author__ = 'Spot Media Solutions Sdn. Bhd.'
+__copyright__ = 'Copyright 2015 Spot Media Solutions Sdn. Bhd.'
+
+
+class Atomx(object):
+    def __init__(self, email, password, api_endpoint='http://api.atomx.com/{}/'.format(API_VERSION)):
+        self.email = email
+        self.password = password
+        self.api_endpoint = api_endpoint
+        self.session = requests.Session()
+        self.login()
+
+    def login(self, email=None, password=None):
+        if email:
+            self.email = email
+        if password:
+            self.password = password
+
+        r = self.session.post(self.api_endpoint + 'login',
+                              json={'email': self.email, 'password': self.password})
+        if not r.ok:
+            if r.status_code == 401:
+                raise InvalidCredentials
+            raise APIError(r.json()['error'])
+        self.auth_tk = r.json()['auth_tkt']
+
+    def logout(self):
+        self.session.get(self.api_endpoint + 'logout')
+
+    def search(self, query):
+        r = self.session.get(self.api_endpoint + 'search', params={'q': query})
+        if not r.ok:
+            raise APIError(r.json()['error'])
+        return r.json()['search']
+
+    def get(self, model, **kwargs):
+        if model not in dir(models):
+            raise ModelNotFoundError()
+        r = self.session.get(self.api_endpoint + model, params=kwargs)
+        if not r.ok:
+            raise APIError(r.json()['error'])
+
+        r_json = r.json()
+        model_name = model.lower()
+        if model_name in r_json:
+            return getattr(models, model)(self, **r_json[model_name])
+        return [getattr(models, model)(self, **m) for m in r_json[model_name + 's']]
+
+    def post(self, model, json, **kwargs):
+        return self.session.post(self.api_endpoint + model, json=json, params=kwargs)
+
+    def put(self, model, id, json, **kwargs):
+        return self.session.put(self.api_endpoint + model + '/' + str(id), json=json, params=kwargs)
+
+    def delete(self, model, id, json, **kwargs):
+        return self.session.put(self.api_endpoint + model + '/' + str(id), json=json, params=kwargs)

atomx/exceptions.py

@@ -0,0 +1,11 @@
+class NoSessionError(Exception):
+    pass
+
+class InvalidCredentials(Exception):
+    pass
+
+class APIError(Exception):
+    pass
+
+class ModelNotFoundError(Exception):
+    pass

atomx/models.py

@@ -0,0 +1,52 @@
+# -*- coding: utf-8 -*-
+
+from .exceptions import NoSessionError
+
+
+__all__ = ['Advertiser', 'Campaign', 'Creative', 'Fallback', 'Network', 'Placement', 'Profile',
+           'Publisher', 'Segment', 'Site', 'User']
+
+
+class AtomxModel(object):
+    def __init__(self, session=None, **attributes):
+        super(AtomxModel, self).__setattr__('session', session)
+        super(AtomxModel, self).__setattr__('_attributes', attributes)
+        super(AtomxModel, self).__setattr__('_dirty', set())  # list of changed attributes
+
+    def __getattr__(self, item):
+        return self._attributes.get(item)
+
+    def __setattr__(self, key, value):
+        if self._attributes[key] != value:
+            self._attributes[key] = value
+            self._dirty.add(key)
+
+    def __repr__(self):
+        return '{}({})'.format(self.__class__.__name__, self._attributes)
+
+    @property
+    def _dirty_json(self):
+        return {k: self._attributes[k] for k in self._dirty}
+
+    @property
+    def json(self):
+        return self._attributes
+
+    def save(self, session=None):
+        if not session and not self.session:
+            raise NoSessionError
+        return self.session.post(self.__class__.__name__, json=self._dirty_json)
+
+    def update(self, session=None):
+        if not session and not self.session:
+            raise NoSessionError
+        return self.session.put(self.__class__.__name__, self.id, json=self._dirty_json)
+
+    def delete(self, session=None):
+        if not session and not self.session:
+            raise NoSessionError
+        return self.session.delete(self.__class__.__name__, self.id, json=self._dirty_json)
+
+
+for m in __all__:
+    locals()[m] = type(m, (AtomxModel,), {})

atomx/version.py

@@ -0,0 +1,2 @@
+VERSION = '0.1.0'
+API_VERSION = 'v1'

setup.cfg

@@ -0,0 +1,2 @@
+[bdist_wheel]
+universal = 1