Auth in kwikapi.django

Author: RamanjaneyuluIdavalapati

.travis.yml

@@ -10,8 +10,8 @@ deploy:
   skip_cleanup: true
   api_key:
     secure: szU2C7KG3GzWO6x5RleHRf+/OpKvZWpN9Z+JPYb0xr+oSCQfms5/kMG8tTBUxjm5exv6xRsnknAa0vL+DqyeNEo8bPBYt3ZoDbB9pTqZhYuKSqDQnAP9N7xrmaXK7AVtuY07zDVToI6M0pWaqn+7A5YG0c9lqt3EuaCbSosqShzoDEZvO9bY1q4tsmjrP7hC28phsOuXCRzBBSabXEueyNeJInDTVFjfxp+yD1du3zIC1Qy4hi1rurTROSogKVWaChVcR9JJdAdawG/5J4QULtuma8fBvo2GhrJSH6ofTsLI1LXo64IixXqhb+FoAbABMjDkukjOXfOgiovGeay5n1PFuenFvQY3T3OscGJId16HeQPJ8BPd6U1k0b57Ij9Fl2nraUSIVpoC3tpBfyhMfXyF08ZEfXIJJwQl1BU96EZXt7PpgY7Mh9MwUnKh6SZ6E9ykwp1jVQ+YSS47u5nWpdAr6DYkjrCfwxw9hOWqH1tgyiSNw1u0xpA7qWUAl8JrEQrrq1EG9buGrH3aeF0p4eyTg38IdqQGhXNWLVJzo4U+QdVT930hDE6CCwhvc5otFiBKqED3ZAidAOJOq4ECZLPOGc8YIvd/4LXZTsaZEfQ1ovAqJnxTOvS5TnarAGI4CO8OvyqTN3nRdzrcMcYkdK5xyoG/jqHPD2jB3H/5Sls=
-  name: kwikapi.django-0.2.3
-  tag_name: 0.2.3
+  name: kwikapi.django-0.2.4
+  tag_name: 0.2.4
   on:
     repo: deep-compute/kwikapi.django
 - provider: pypi

kwikapi/django/__init__.py

@@ -1 +1,3 @@
-from .kwikapi_django import RequestHandler
+from .kwikapi_django import RequestHandler, \
+        BasicAuthenticator, \
+        SessionAuthenticator

kwikapi/django/kwikapi_django.py

@@ -2,15 +2,60 @@
 
 from django.http import HttpResponse
 from django.http import StreamingHttpResponse
+from django.contrib.auth import login, logout, authenticate
+from django.contrib.auth.models import User
 
-from kwikapi import BaseRequest, BaseResponse, BaseRequestHandler
+from requests.structures import CaseInsensitiveDict
+
+from kwikapi import BaseRequest, BaseResponse
+from kwikapi import BaseRequestHandler, BaseAuthAPI
+from kwikapi import BearerServerAuthenticator
+from kwikapi import BasicServerAuthenticator
+
+class BasicAuthenticator(BasicServerAuthenticator):
+    USER_ATTRS = ('id', 'email', 'first_name', 'last_name')
+
+    def authenticate(self, request):
+        auth = super().authenticate(request)
+        username = auth.username.decode('utf8')
+        password = auth.password.decode('utf8')
+
+        user = authenticate(request=request.raw_request,
+            username=username, password=password)
+
+        if not user:
+            return auth
+
+        auth.is_authenticated = True
+        auth.update({ a: getattr(user, a) for a in self.USER_ATTRS })
+        return auth
+
+class SessionAuthenticator(BearerServerAuthenticator):
+    # FIXME: this needs to be completed
+
+    def authenticate(self, request):
+        auth = super().authenticate(request)
+        session_id = auth.token
 
 class DjangoRequest(BaseRequest):
     def __init__(self, request):
         super().__init__()
         self.raw_request = self._request = request
+        self._headers = self._load_headers()
         self.response = DjangoResponse(self._request)
 
+    def _load_headers(self):
+        hdrs = CaseInsensitiveDict()
+
+        for k, v in self._request.META.items():
+            if not k.startswith('HTTP_'):
+                continue
+
+            k = '-'.join(k.split('_')[1:])
+            hdrs[k] = v
+
+        return hdrs
+
     @property
     def url(self):
         return self._request.get_full_path()
@@ -21,11 +66,11 @@ def method(self):
 
     @property
     def body(self):
-        return self._request
+        return self._request.body
 
     @property
     def headers(self):
-        return self._request.META
+        return self._headers
 
 class DjangoResponse(BaseResponse):
     def __init__(self, request):
@@ -61,10 +106,10 @@ class RequestHandler(BaseRequestHandler):
     PROTOCOL = BaseRequestHandler.DEFAULT_PROTOCOL
 
     def handle_request(self, request):
-        '''fn = lambda: super().handle_request(DjangoRequest(request))
+        fn = lambda: super(RequestHandler, self).handle_request(DjangoRequest(request))
 
         if self.api.threadpool:
-            self.api.threadpool.apply_async(fn)
+            f = self.api.threadpool.submit(fn)
+            return f.result()
         else:
-            fn()'''
-        return super().handle_request(DjangoRequest(request))
+            return fn()

setup.py

@@ -1,6 +1,6 @@
 from setuptools import setup, find_packages
 
-version = '0.2.3'
+version = '0.2.4'
 setup(
     name="kwikapi-django",
     version=version,