From 3f252ea6ab57ff9d1c7e71a43994fce55c927c12 Mon Sep 17 00:00:00 2001 From: dextmorgn Date: Wed, 11 Feb 2026 08:03:05 +0100 Subject: [PATCH] feat(core): progress on templates --- .../src/flowsint_core/core/template_enricher.py | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/flowsint-core/src/flowsint_core/core/template_enricher.py b/flowsint-core/src/flowsint_core/core/template_enricher.py index 5927825..9c84aa9 100644 --- a/flowsint-core/src/flowsint_core/core/template_enricher.py +++ b/flowsint-core/src/flowsint_core/core/template_enricher.py @@ -108,6 +108,7 @@ class TemplateEnricher(Enricher): self.OutputType = self._detect_type(self.template.output.type) self.request = self.template.request self._resolved_secrets: Dict[str, str] = {} + self.raw_response: Dict[str, Any] | None = None @staticmethod def _build_params_schema_from_template(template: Template) -> List[Dict[str, Any]]: @@ -332,7 +333,15 @@ class TemplateEnricher(Enricher): ) await asyncio.sleep(wait_time) continue - + try: + body = response.json() + except Exception: + body = response.text + self.raw_response = { + "status_code": response.status_code, + "headers": dict(response.headers), + "body": body, + } response.raise_for_status() return response @@ -536,6 +545,9 @@ class TemplateEnricher(Enricher): ) return results + def get_raw_response(self) -> Dict[str, Any] | None: + return self.raw_response + InputType = TemplateEnricher.InputType OutputType = TemplateEnricher.OutputType