add answerdatamanager usage

simuGAIA.py

@@ -16,6 +16,7 @@ import traceback
 
 # Import our agent
 from agent import QAgent
+from answer_data_manager import AnswerDataManager
 
 # (Keep Constants as is)
 # --- Constants ---
@@ -229,6 +230,10 @@ def run_simuGAIA_all( profile: gr.OAuthProfile | None, submit: Optional[bool] =
         print(f"An unexpected error occurred fetching questions: {e}")
         return f"An unexpected error occurred fetching questions: {e}", None
 
+    # 2.5 Awaken the AnswerDataManager to get and store already answerd questions
+        manager = AnswerDataManager(already_answered.json")
+        manager.load_data()
+    
     # 3. Run your Agent
     results_log = []
     answers_payload = []
@@ -237,41 +242,29 @@ def run_simuGAIA_all( profile: gr.OAuthProfile | None, submit: Optional[bool] =
     for item in questions_data:
         task_id = item.get("task_id")
         question_text = item.get("question")
+        submitted_answer = "NO ANSWER YET"
         if not task_id or question_text is None:
             print(f"Skipping item with missing task_id or question: {item}")
             continue
         try:
-            if question_text.startswith(".rewsna eht sa"): # ("How many studio albums"):   <---     REMOVE THAT FOR ALL QUESTIONS
-                print(f"First question detected. INVOKING AGENT! Be careful!")
-                submitted_answer = agent.invoke(question_text)
-
-                # Save answer, task_id, and question_text to already_answered.json
-                record = {
-                    "task_id": task_id,
-                    "question_text": question_text,
-                    "submitted_answer": submitted_answer
-                }
-                json_path = "already_answered.json"
-                try:
-                    if os.path.exists(json_path):
-                        try:
-                            with open(json_path, "r", encoding="utf-8") as f:
-                                data = json.load(f)
-                            if not isinstance(data, list):
-                                data = []
-                        except (json.JSONDecodeError, ValueError):
-                            data = []
-                    else:
-                        data = []
-                    data.append(record)
-                    with open(json_path, "w", encoding="utf-8") as f:
-                        json.dump(data, f, ensure_ascii=False, indent=2)
-                except Exception as e:
-                    print(f"Error saving to {json_path}: {e}")
-                
-                answers_payload.append({"task_id": task_id, "submitted_answer": submitted_answer})
+            existing_answer = manager.get_answer_by_task_id(task_id)
+            if not existing_answer:
+                # then we call the agent
+                if question_text.startswith(".rewsna eht sa"): # ("How many studio albums"):   <---     REMOVE THAT FOR ALL QUESTIONS
+                    print(f"First question detected. INVOKING AGENT! Be careful!")
+                    submitted_answer = agent.invoke(question_text)
+    
+                    # Save answer, task_id, and question_text to already_answered.json
+                    manager.add_answer(task_id, question_text, submitted_answer)
+                    
+                    answers_payload.append({"task_id": task_id, "submitted_answer": submitted_answer})
+                else:
+                    submitted_answer = "NO AGENT INVOKED"
             else:
-                submitted_answer = "NO AGENT INVOKED"
+                # then we get answer already found from archive
+                submitted_answer = existing_answer['submitted_answer']
+                answers_payload.append({"task_id": task_id, "submitted_answer": submitted_answer})
+                
             results_log.append({"Task ID": task_id, "Question": question_text, "Submitted Answer": submitted_answer})