diff --git a/src/n8n/n8n_client.py b/src/n8n/n8n_client.py
index ca93673..920753f 100644
--- a/src/n8n/n8n_client.py
+++ b/src/n8n/n8n_client.py
@@ -23,7 +23,7 @@ def _update_from_config(self):
         self.token = self._n8n_config.get("token", "")
         self.users = self._n8n_config.get("users", {})
 
-    def send_webhook(self, user_id: int, query: str) -> None:
+    def send_webhook(self, user_id: int, query: str) -> dict:
         """
         Send a webhook request to n8n with user and request information.
 
@@ -84,6 +84,8 @@ def send_webhook(self, user_id: int, query: str) -> None:
             logger.debug(f"N8n webhook response: status={response.status_code}")
             response.raise_for_status()
             logger.debug(f"N8n webhook sent successfully for user {user_id}")
+
+            return response.json()
         except requests.exceptions.HTTPError as e:
             # 404 means webhook endpoint doesn't exist (expected during setup)
             if e.response.status_code == 404:
diff --git a/src/tg/handlers/flow_handlers.py b/src/tg/handlers/flow_handlers.py
index b9e16b6..6d10485 100644
--- a/src/tg/handlers/flow_handlers.py
+++ b/src/tg/handlers/flow_handlers.py
@@ -80,7 +80,8 @@ def handle_stateless_message(update, tg_context):
             )
 
             query = update.message.text.strip()
-            app_context.n8n_client.send_webhook(user_id, query)
+            response = app_context.n8n_client.send_webhook(user_id, query)
+            reply(response["message"], update)
         except Exception as e:
             logger.error(
                 f"Failed to send message to n8n: {e}",