first commit

Author: joamag

.gitignore

@@ -0,0 +1 @@
+*.pyc

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>appier</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.python.pydev.PyDevBuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.python.pydev.pythonNature</nature>
+	</natures>
+</projectDescription>

.pydevproject

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<?eclipse-pydev version="1.0"?><pydev_project>
+<pydev_pathproperty name="org.python.pydev.PROJECT_SOURCE_PATH">
+<path>/appier/src</path>
+</pydev_pathproperty>
+<pydev_property name="org.python.pydev.PYTHON_PROJECT_VERSION">python 2.6</pydev_property>
+<pydev_property name="org.python.pydev.PYTHON_PROJECT_INTERPRETER">Default</pydev_property>
+</pydev_project>

.settings/org.eclipse.core.resources.prefs

@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+encoding/<project>=utf-8

src/appier/__init__.py

@@ -0,0 +1,14 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+import base
+import exceptions
+import request
+import settings
+import util
+
+from base import *
+from exceptions import *
+from request import *
+from settings import *
+from util import *

src/appier/base.py

@@ -0,0 +1,14 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+class BotException(Exception):
+    """
+    Top level exception to be used as the root of
+    all the exceptions to be raised by the bot infra-
+    structure. Should be compatible with http status
+    codes for proper http serialization.
+    """
+
+    def __init__(self, *args, **kwargs):
+        Exception.__init__(self, *args)
+        self.error_code = kwargs.get("error_code", 500)

src/appier/exceptions.py

@@ -0,0 +1,87 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+import types
+
+import util
+
+class Request(object):
+
+    ALIAS = ("token",)
+    SESSIONS = {}
+
+    def __init__(self, method, path, params = {}, data_j = {}, environ = {}):
+        self.method = method
+        self.path = path
+        self.params = params
+        self.data_j = data_j
+        self.environ = environ
+        self.session = {}
+        self.cookies = {}
+        self.in_headers = {}
+        self.out_headers = {}
+        self.warnings = []
+
+    def warning(self, message):
+        message_t = type(message)
+
+        if message_t in types.StringTypes:
+            message = dict(message = message)
+        elif not message_t == types.DictType:
+            raise RuntimeError("Invalid message type '%s'", message_t)
+
+        self.warnings.append(message)
+
+    def get_param(self, name, default = None):
+        if not name in self.params: return default
+        value = self.params[name]
+        return value[0] if value else default
+
+    def set_params(self, params):
+        self.params = params
+
+    def set_json(self, data_j):
+        self.data_j = data_j
+
+    def set_header(self, name, value):
+        self.out_headers[name] = value
+
+    def resolve_params(self):
+        self.params = self._resolve_p(self.params)
+
+    def load_session(self):
+        self.load_cookies()
+        self.set_alias()
+        self.set_session()
+
+    def load_cookies(self):
+        cookie_s = self.environ.get("HTTP_COOKIE", "")
+
+        cookies = [cookie.strip() for cookie in cookie_s.split(";")]
+        for cookie in cookies:
+            if not "=" in cookie: cookie += "="
+            name, value = cookie.split("=", 1)
+            self.cookies[name] = value
+
+    def set_alias(self):
+        for alias in Request.ALIAS:
+            if not alias in self.params: continue
+            self.params["sid"] = self.params[alias]
+
+    def set_session(self, create = False):
+        sid = self.cookies.get("sid", None)
+        sid = self.params.get("sid", (None,))[0] or sid
+        self.session = Request.SESSIONS.get(sid, {})
+
+        if not self.session and create:
+            sid = util.gen_token()
+            self.session = dict(sid = sid)
+            Request.SESSIONS[sid] = self.session
+
+        return self.session
+
+    def get_warnings(self):
+        return self.warnings
+
+    def get_headers(self):
+        return self.out_headers.items()

src/appier/request.py

@@ -0,0 +1,6 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+DEBUG = True
+USERNAME = "admin"
+PASSWORD = "admin"

src/appier/settings.py

@@ -0,0 +1,33 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+import uuid
+import hashlib
+import inspect
+
+import exceptions
+
+def gen_token():
+    token_s = str(uuid.uuid4())
+    token = hashlib.sha256(token_s).hexdigest()
+    return token
+
+def private(function):
+    def _private(self, *args, **kwargs):
+        is_auth = self.request.session and "username" in self.request.session
+        if not is_auth: raise exceptions.BotException(
+            "Method '%s' requires authentication" % function.__name__,
+            error_code = 403
+        )
+
+        sanitize(function, kwargs)
+        return function(self, *args, **kwargs)
+    return _private
+
+def sanitize(function, kwargs):
+    removal = []
+    method_a = inspect.getargspec(function)[0]
+    for name in kwargs:
+        if name in method_a: continue
+        removal.append(name)
+    for name in removal: del kwargs[name]