fix: wrong parameter name

Author: perzeuss

endpoints/chatflow.py

@@ -52,7 +52,9 @@ def _invoke(self, r: Request, values: Mapping, settings: Mapping) -> Response:
                 return Response(json.dumps({"error": "app_id is required"}),
                                 status=400, content_type="application/json")
 
-            if settings["explicit_inputs"]:
+            explicit_inputs = settings.get('explicit_inputs', True)
+
+            if explicit_inputs:
                 inputs = request_data.get("inputs", {})
                 if not isinstance(inputs, dict):
                     return Response(json.dumps({"error": "inputs must be an object"}),
@@ -63,12 +65,12 @@ def _invoke(self, r: Request, values: Mapping, settings: Mapping) -> Response:
                     return Response(json.dumps({"error": "inputs must be an object"}),
                                     status=400, content_type="application/json")
 
-            query = inputs.get("query") if settings["explicit_inputs"] else inputs.pop("query")
+            query = inputs.get("query") if explicit_inputs else inputs.pop("query")
             if not query or not isinstance(query, str):
                 return Response(json.dumps({"error": "query must be a string"}),
                                 status=400, content_type="application/json")
 
-            conversation_id = inputs.get("conversation_id") if settings["explicit_inputs"] else inputs.pop("conversation_id")
+            conversation_id = inputs.get("conversation_id") if explicit_inputs else inputs.pop("conversation_id")
             if conversation_id is not None and not isinstance(conversation_id, str):
                 return Response(json.dumps({"error": "conversation_id must be a string"}),
                                 status=400, content_type="application/json")

endpoints/workflow.py

@@ -7,7 +7,6 @@
 
 logger = logging.getLogger(__name__)
 
-
 class WorkflowEndpoint(Endpoint):
     """
     The WorkflowEndpoint is used to trigger a Dify workflow via an HTTP request.
@@ -62,7 +61,9 @@ def _invoke(self, r: Request, values: Mapping, settings: Mapping) -> Response:
                 return Response(json.dumps({"error": "app_id is required"}),
                                 status=400, content_type="application/json")
 
-            if settings["explicit_inputs"]:
+            explicit_inputs = settings.get('explicit_inputs', True)
+
+            if explicit_inputs:
                 inputs = request_data.get("inputs", {})
                 if not isinstance(inputs, dict):
                     logger.error(
@@ -83,7 +84,8 @@ def _invoke(self, r: Request, values: Mapping, settings: Mapping) -> Response:
                 app_id=app_id, inputs=inputs, response_mode="blocking"
             )
 
-            response = dify_response["data"]["outputs"] if settings["raw_data_only"] else dify_response
+            response = dify_response["data"]["outputs"] if settings.get(
+                'raw_data_output', False) else dify_response
 
             logger.debug("Workflow response: %s", response)
             return Response(json.dumps(response), status=200, content_type="application/json")

manifest.yaml

@@ -1,4 +1,4 @@
-version: 0.4.0
+version: 0.4.1
 type: plugin
 author: perzeuss
 name: webhook
@@ -22,7 +22,7 @@ plugins:
   endpoints:
     - group/webhook.yaml
 meta:
-  version: 0.4.0
+  version: 0.4.1
   arch:
     - amd64
     - arm64