fix bug python3 decorator has not im_self

Author: legenove

swagger_py_codegen/templates/tornado/api.tpl

@@ -3,10 +3,10 @@ from __future__ import absolute_import
 
 from core import RequestHandler
 from .. import UserInfo
-from ..validators import validate_filter
+from ..validators import request_validate, response_filter
 
 class ApiHandler(RequestHandler):
-    on_initialize_decorators = [validate_filter]
+    on_initialize_decorators = [response_filter, request_validate]
 
     def get_current_user(self):
         authorization = self.request.headers.get('Authorization', '')

swagger_py_codegen/templates/tornado/core.tpl

@@ -45,7 +45,7 @@ class RequestHandler(tornado.web.RequestHandler):
         assert meth is not None, 'Unimplemented method %r' % request.method
 
         for decorator in self.on_initialize_decorators:
-            meth = decorator(meth)
+            meth = decorator(self)(meth)
 
         setattr(self, self.request.method.lower(), meth)
 

swagger_py_codegen/templates/tornado/validators.tpl

@@ -70,86 +70,86 @@ class ValidatorAdaptor(object):
         return normalize(self.validator.schema, value)[0], errors
 
 def request_validate(obj):
-    request = obj.request
-    endpoint = obj.endpoint
-    user_info = obj.current_user
-    if (endpoint, request.method) in scopes and not set(
-            scopes[(endpoint, request.method)]
-    ).issubset(set(user_info.scopes)):
-        raise tornado.web.HTTPError(403)
-
-    method = request.method
-    if method == 'HEAD':
-        method = 'GET'
-    locations = validators.get((endpoint, method), {})
-    for location, schema in six.iteritems(locations):
-        if location == 'json':
-            value = getattr(request, 'body', MultiDict())
-        elif location == 'args':
-            value = getattr(request, 'query_arguments', MultiDict())
-            for k,v in value.iteritems():
-                if isinstance(v, list) and len(v) == 1:
-                    value[k] = v[0]
-            value = MultiDict(value)
-        else:
-            value = getattr(request, location, MultiDict())
-        validator = ValidatorAdaptor(schema)
-        result, reasons = validator.validate(value)
-        if reasons:
-            raise tornado.web.HTTPError(422, message='Unprocessable Entity',
-                                        reason=json.dumps(reasons))
-        setattr(obj, location, result)
-
-
-def response_filter(obj, resp):
-    request = obj.request
-    endpoint = obj.endpoint
-    method = request.method
-    if method == 'HEAD':
-        method = 'GET'
-    headers = None
-    status = None
-    if isinstance(resp, tuple):
-        resp, status, headers = unpack(resp)
-    filter = filters.get((endpoint, method), None)
-    if filter:
-        if len(filter) == 1:
-            if six.PY3:
-                status = list(filter.keys())[0]
-            else:
-                status = filter.keys()[0]
-
-        schemas = filter.get(status)
-        if not schemas:
-            # return resp, status, headers
-            raise tornado.web.HTTPError(
-                500, message='`%d` is not a defined status code.' % status)
-
-        resp, errors = normalize(schemas['schema'], resp)
-        if schemas['headers']:
-            headers, header_errors = normalize(
-                {'properties': schemas['headers']}, headers)
-            errors.extend(header_errors)
-        if errors:
-            raise tornado.web.HTTPError(
-                500, message='Expectation Failed',
-                reason=json.dumps(errors))
-    obj.set_status(status)
-    obj.set_headers(headers)
-    obj.write(json.dumps(resp))
-
-
-def validate_filter(view):
-
-    @wraps(view)
-    def wrapper(*args, **kwargs):
-        self = view.im_self
-        request_validate(self)
-        before_request(self)
-        resp = view(*args, **kwargs)
-        after_request(self)
-        response_filter(self, resp)
-    return wrapper
+    def _request_validate(view):
+        @wraps(view)
+        def wrapper(*args, **kwargs):
+            request = obj.request
+            endpoint = obj.endpoint
+            user_info = obj.current_user
+            if (endpoint, request.method) in scopes and not set(
+                    scopes[(endpoint, request.method)]
+            ).issubset(set(user_info.scopes)):
+                raise tornado.web.HTTPError(403)
+
+            method = request.method
+            if method == 'HEAD':
+                method = 'GET'
+            locations = validators.get((endpoint, method), {})
+            for location, schema in six.iteritems(locations):
+                if location == 'json':
+                    value = getattr(request, 'body', MultiDict())
+                elif location == 'args':
+                    value = getattr(request, 'query_arguments', MultiDict())
+                    for k,v in six.iteritems(value):
+                        if isinstance(v, list) and len(v) == 1:
+                            value[k] = v[0]
+                    value = MultiDict(value)
+                else:
+                    value = getattr(request, location, MultiDict())
+                validator = ValidatorAdaptor(schema)
+                result, reasons = validator.validate(value)
+                if reasons:
+                    raise tornado.web.HTTPError(422, message='Unprocessable Entity',
+                                                reason=json.dumps(reasons))
+                setattr(obj, location, result)
+            return view(*args, **kwargs)
+        return wrapper
+    return _request_validate
+
+
+def response_filter(obj):
+    def _response_filter(view):
+        @wraps(view)
+        def wrapper(*args, **kwargs):
+            resp = view(*args, **kwargs)
+            request = obj.request
+            endpoint = obj.endpoint
+            method = request.method
+            if method == 'HEAD':
+                method = 'GET'
+            headers = None
+            status = None
+            if isinstance(resp, tuple):
+                resp, status, headers = unpack(resp)
+            filter = filters.get((endpoint, method), None)
+            if filter:
+                if len(filter) == 1:
+                    if six.PY3:
+                        status = list(filter.keys())[0]
+                    else:
+                        status = filter.keys()[0]
+
+                schemas = filter.get(status)
+                if not schemas:
+                    # return resp, status, headers
+                    raise tornado.web.HTTPError(
+                        500, message='`%d` is not a defined status code.' % status)
+
+                resp, errors = normalize(schemas['schema'], resp)
+                if schemas['headers']:
+                    headers, header_errors = normalize(
+                        {'properties': schemas['headers']}, headers)
+                    errors.extend(header_errors)
+                if errors:
+                    raise tornado.web.HTTPError(
+                        500, message='Expectation Failed',
+                        reason=json.dumps(errors))
+            obj.set_status(status)
+            obj.set_headers(headers)
+            obj.write(json.dumps(resp))
+            return
+        return wrapper
+    return _response_filter
 
 
 def unpack(value):

swagger_py_codegen/tornado.py

@@ -227,7 +227,7 @@ def _process(self):
             swagger.pop('schemes', None)
             yield Specification(dict(swagger=json.dumps(swagger, indent=2)))
 
-        yield Validator(dict(scopes_supported=self.swagger.scopes_supported))
+        yield Validator()
 
         yield Api()