From 87eefcd5dcb2a9b8ee1499fbfd6adbce90fc1a84 Mon Sep 17 00:00:00 2001
From: Mohammad Amin <dadgaramin96@gmail.com>
Date: Wed, 10 Jan 2024 17:03:10 +0330
Subject: [PATCH] update: Added hivemind-bot thinking process! We needed to let
 the discord-bot know if the hivemind-bot is working, else after two second
 the discord-bot would raise an error.

---
 celery_app/tasks.py | 24 ++++++++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/celery_app/tasks.py b/celery_app/tasks.py
index d4dc2d8..f5b6fd5 100644
--- a/celery_app/tasks.py
+++ b/celery_app/tasks.py
@@ -8,6 +8,7 @@
 from tc_messageBroker.rabbit_mq.payload.discord_bot.base_types.interaction_callback_data import (
     InteractionCallbackData,
 )
+from tc_messageBroker.rabbit_mq.payload.discord_bot.interaction_response import InteractionResponse
 from tc_messageBroker.rabbit_mq.payload.discord_bot.chat_input_interaction import (
     ChatInputCommandInteraction,
 )
@@ -36,6 +37,22 @@ def ask_question_auto_search(
         the information data that needed to be sent back to the bot again.
         This would be the `ChatInputCommandInteraction`.
     """
+    create_interaction_content = Payload.DISCORD_BOT.INTERACTION_RESPONSE.Create(
+        interaction=bot_given_info.to_dict(),
+        data=InteractionResponse(
+            type=4,
+            data=InteractionCallbackData(
+                content="Processing your question ...",
+                flags=64
+            ),
+        ),
+    ).to_dict()
+
+    job_send(
+        event=Event.DISCORD_BOT.INTERACTION_RESPONSE.CREATE,
+        queue_name=Queue.DISCORD_BOT,
+        content=create_interaction_content,
+    )
 
     # for now we have just the discord platform
     response, source_nodes = query_multiple_source(
@@ -55,14 +72,13 @@ def ask_question_auto_search(
         "source_nodes": source_nodes_dict,
     }
 
-    response_payload = Payload.DISCORD_BOT.INTERACTION_RESPONSE.Create(
-        type=19,
-        data=InteractionCallbackData(content=json.dumps(results)),
+    response_payload = Payload.DISCORD_BOT.INTERACTION_RESPONSE.Edit(
         interaction=bot_given_info.to_dict(),
+        data=InteractionCallbackData(content=json.dumps(results)),
     ).to_dict()
 
     job_send(
-        event=Event.DISCORD_BOT.INTERACTION_RESPONSE.CREATE,
+        event=Event.DISCORD_BOT.INTERACTION_RESPONSE.EDIT,
         queue_name=Queue.DISCORD_BOT,
         content=response_payload,
     )