codestyle

Author: sjanssen2

qiita_pet/handlers/cloud_handlers/file_transfer_handlers.py

@@ -1,14 +1,13 @@
 import os
 
-from tornado.web import authenticated, HTTPError, RequestHandler
-from tornado import iostream
+from tornado.web import HTTPError, RequestHandler
 from tornado.gen import coroutine
 
 from qiita_core.util import execute_as_transaction
-from qiita_pet.handlers.download import BaseHandlerDownload
-from qiita_db.handlers.oauth2 import OauthBaseHandler, authenticate_oauth
+from qiita_db.handlers.oauth2 import authenticate_oauth
 from qiita_core.qiita_settings import qiita_config
 
+
 class FetchFileFromCentralHandler(RequestHandler):
     @authenticate_oauth
     @coroutine
@@ -22,8 +21,8 @@ def get(self, requested_filepath):
         # canonic version of base_data_dir
         basedatadir = os.path.abspath(qiita_config.base_data_dir)
 
-        # TODO: can we somehow check, if the requesting client (which should be 
-        #       one of the plugins) was started from a user that actually has 
+        # TODO: can we somehow check, if the requesting client (which should be
+        #       one of the plugins) was started from a user that actually has
         #       access to the requested file?
 
         if not filepath.startswith(basedatadir):
@@ -38,11 +37,11 @@ def get(self, requested_filepath):
             raise HTTPError(403, reason=(
                 "The requested file is not present in Qiita's BASE_DATA_DIR!"))
 
-        # delivery of the file via nginx requires replacing the basedatadir 
-        # with the prefix defined in the nginx configuration for the 
+        # delivery of the file via nginx requires replacing the basedatadir
+        # with the prefix defined in the nginx configuration for the
         # base_data_dir, '/protected/' by default
         protected_filepath = filepath.replace(basedatadir, '/protected')
-        
+
         self.set_header('Content-Type', 'application/octet-stream')
         self.set_header('Content-Transfer-Encoding', 'binary')
         self.set_header('X-Accel-Redirect', protected_filepath)
@@ -54,6 +53,7 @@ def get(self, requested_filepath):
                             protected_filepath))
         self.finish()
 
+
 class PushFileToCentralHandler(RequestHandler):
     @authenticate_oauth
     @coroutine
@@ -74,7 +74,7 @@ def post(self):
                 filepath = os.path.join(filespath, file['filename'])
                 # remove leading /
                 if filepath.startswith(os.sep):
-                    filepath = filepath[len(os.sep):] 
+                    filepath = filepath[len(os.sep):]
                 filepath = os.path.abspath(os.path.join(basedatadir, filepath))
 
                 if os.path.exists(filepath):
@@ -88,7 +88,7 @@ def post(self):
                     stored_files.append(filepath)
 
         self.write("Stored %i files into BASE_DATA_DIR of Qiita:\n%s\n" % (
-            len(stored_files), 
+            len(stored_files),
             '\n'.join(map(lambda x: ' - %s' % x, stored_files))))
 
         self.finish()