python-openapi · larsderidder · Nov 21, 2019 · Nov 21, 2019 · Nov 28, 2019 · Dec 2, 2019
diff --git a/openapi_core/contrib/falcon/__init__.py b/openapi_core/contrib/falcon/__init__.py
@@ -0,0 +1,5 @@
+from openapi_core.contrib.falcon.requests import FalconOpenAPIRequestFactory
+from openapi_core.contrib.falcon.responses import FalconOpenAPIResponseFactory
+
+
+__all__ = ["FalconOpenAPIRequestFactory", "FalconOpenAPIResponseFactory"]
diff --git a/openapi_core/contrib/falcon/requests.py b/openapi_core/contrib/falcon/requests.py
@@ -0,0 +1,36 @@
+"""OpenAPI core contrib falcon responses module"""
+import json
+
+from openapi_core.validation.request.datatypes import OpenAPIRequest, RequestParameters
+from six.moves.urllib.parse import urljoin
+from werkzeug.datastructures import ImmutableMultiDict
+
+
+class FalconOpenAPIRequestFactory:
+    @classmethod
+    def create(cls, req, route_params):
+        """
+        Create OpenAPIRequest from falcon Request and route params.
+        """
+        method = req.method.lower()
+
+        # Convert keys to lowercase as that's what the OpenAPIRequest expects.
+        headers = {key.lower(): value for key, value in req.headers.items()}
+
+        parameters = RequestParameters(
+            path=route_params,
+            query=ImmutableMultiDict(req.params.items()),
+            header=headers,
+            cookie=req.cookies,
+        )
+        full_url_pattern = urljoin(req.host, req.uri_template)
+        return OpenAPIRequest(
+            full_url_pattern=full_url_pattern,
+            method=method,
+            parameters=parameters,
+            # Support falcon-jsonify.
+            body=json.dumps(req.json)
+            if getattr(req, "json", None)
+            else req.bounded_stream.read(),
+            mimetype=req.content_type.partition(";")[0] if req.content_type else "",
+        )
diff --git a/openapi_core/contrib/falcon/responses.py b/openapi_core/contrib/falcon/responses.py
@@ -0,0 +1,12 @@
+"""OpenAPI core contrib falcon responses module"""
+from openapi_core.validation.response.datatypes import OpenAPIResponse
+
+
+class FalconOpenAPIResponseFactory(object):
+    @classmethod
+    def create(cls, resp):
+        return OpenAPIResponse(
+            data=resp.body,
+            status_code=resp.status[:3],
+            mimetype=resp.content_type.partition(";")[0] if resp.content_type else '',
+        )