Merge pull request #25 from deep-compute/update_travis_via_gitkanban

updated the code and travis file with black formatter

Author: goutham9032

.travis.yml

@@ -1,5 +1,3 @@
-before_install:
-- pip3 install black
 deploy:
 - provider: releases
   skip_cleanup: true
@@ -33,5 +31,5 @@ language: python
 python:
 - '3.5'
 script:
-- black --check .
+- docker run -v $(pwd):/app deepcompute/black:python-black-latest --check .
 - echo "No tests as of now"

kwikapi/tornado/kwikapi_tornado.py

@@ -16,8 +16,8 @@
 
 DUMMY_LOG = Dummy()
 
-class TornadoRequest(BaseRequest):
 
+class TornadoRequest(BaseRequest):
     def __init__(self, req_hdlr):
         super().__init__()
         self._request = req_hdlr.request
@@ -39,6 +39,7 @@ def body(self):
     def headers(self):
         return self._request.headers
 
+
 class TornadoResponse(BaseResponse):
     def __init__(self, req_hdlr):
         super().__init__()
@@ -51,20 +52,22 @@ def write(self, data, proto, stream=False):
         if not stream:
             nbytes = n.value
 
-            accept_enc = self._req_hdlr.request.headers.get('Accept-Encoding', '')
-            accept_enc = set([e.strip().lower() for e in accept_enc.split(',') if e.strip()])
+            accept_enc = self._req_hdlr.request.headers.get("Accept-Encoding", "")
+            accept_enc = set(
+                [e.strip().lower() for e in accept_enc.split(",") if e.strip()]
+            )
 
-            if 'gzip' in accept_enc:
+            if "gzip" in accept_enc:
                 compressed = io.BytesIO()
-                gfile = gzip.GzipFile(fileobj=compressed, mode='w')
+                gfile = gzip.GzipFile(fileobj=compressed, mode="w")
                 gfile.write(self._data)
                 gfile.flush()
                 gfile.close()
                 self._data = compressed.getvalue()
                 nbytes = len(self._data)
-                self._headers['Content-Encoding'] = 'gzip'
+                self._headers["Content-Encoding"] = "gzip"
 
-            self._headers['Content-Length'] = nbytes
+            self._headers["Content-Length"] = nbytes
 
         self._stream = stream
 
@@ -80,25 +83,28 @@ def close(self):
     def headers(self):
         return self._headers
 
+
 class RequestHandler(TornadoRequestHandler):
     PROTOCOL = BaseRequestHandler.DEFAULT_PROTOCOL
 
     def __init__(self, *args, **kwargs):
-        self.api = kwargs.pop('api')
-        self.log = kwargs.pop('log', DUMMY_LOG)
+        self.api = kwargs.pop("api")
+        self.log = kwargs.pop("log", DUMMY_LOG)
 
-        default_version = kwargs.pop('default_version', None)
-        default_protocol = kwargs.pop('default_protocol', self.PROTOCOL)
+        default_version = kwargs.pop("default_version", None)
+        default_protocol = kwargs.pop("default_protocol", self.PROTOCOL)
 
-        pre_call_hook = kwargs.pop('pre_call_hook', None)
-        post_call_hook = kwargs.pop('post_call_hook', None)
+        pre_call_hook = kwargs.pop("pre_call_hook", None)
+        post_call_hook = kwargs.pop("post_call_hook", None)
 
-        self.kwik_req_hdlr = BaseRequestHandler(self.api,
-                default_version=default_version,
-                default_protocol=default_protocol,
-                pre_call_hook=pre_call_hook,
-                post_call_hook=post_call_hook,
-                log=self.log)
+        self.kwik_req_hdlr = BaseRequestHandler(
+            self.api,
+            default_version=default_version,
+            default_protocol=default_protocol,
+            pre_call_hook=pre_call_hook,
+            post_call_hook=post_call_hook,
+            log=self.log,
+        )
 
         super().__init__(*args, **kwargs)
 
@@ -132,7 +138,7 @@ def fn():
                     except tornado.iostream.StreamClosedError:
                         continue
         except Exception:
-            self.log.exception('unhandle_request_handling_exception')
+            self.log.exception("unhandle_request_handling_exception")
             raise
         finally:
             self.finish()

setup.py

@@ -1,32 +1,28 @@
 from setuptools import setup, find_packages
 
 # https://docs.djangoproject.com/en/1.11/intro/reusable-apps/
-version = '0.3.7'
+version = "0.3.7"
 setup(
     name="kwikapi-tornado",
     version=version,
-    packages=['kwikapi.tornado'],
+    packages=["kwikapi.tornado"],
     include_package_data=True,
-    license='MIT License',  # example license
-    description='Quickest way to build powerful HTTP APIs in Python',
-    url='https://github.com/deep-compute/kwikapi.tornado',
+    license="MIT License",  # example license
+    description="Quickest way to build powerful HTTP APIs in Python",
+    url="https://github.com/deep-compute/kwikapi.tornado",
     download_url="https://github.com/deep-compute/kwikapi.tornado/tarball/%s" % version,
-    author='Deep Compute, LLC',
-    author_email='contact@deepcompute.com',
-    install_requires=[
-        'tornado==5.0.2',
-        'deeputil==0.2.7',
-        'requests==2.20.0',
-    ],
+    author="Deep Compute, LLC",
+    author_email="contact@deepcompute.com",
+    install_requires=["tornado==5.0.2", "deeputil==0.2.7", "requests==2.20.0"],
     classifiers=[
-        'Environment :: Web Environment',
-        'Intended Audience :: Developers',
-        'License :: OSI Approved :: MIT License',
-        'Operating System :: OS Independent',
-        'Programming Language :: Python',
-        'Programming Language :: Python :: 3',
-        'Programming Language :: Python :: 3.5',
-        'Topic :: Internet :: WWW/HTTP',
-        'Topic :: Internet :: WWW/HTTP :: Dynamic Content',
+        "Environment :: Web Environment",
+        "Intended Audience :: Developers",
+        "License :: OSI Approved :: MIT License",
+        "Operating System :: OS Independent",
+        "Programming Language :: Python",
+        "Programming Language :: Python :: 3",
+        "Programming Language :: Python :: 3.5",
+        "Topic :: Internet :: WWW/HTTP",
+        "Topic :: Internet :: WWW/HTTP :: Dynamic Content",
     ],
 )