added gemini too

controller.py

@@ -25,6 +25,7 @@ import numpy as np
 import matplotlib.pyplot as plt
 import matplotlib
 import seaborn as sns
+from gemini_report_generator import generate_csv_report
 from intitial_q_handler import if_initial_chart_question, if_initial_chat_question
 from orchestrator_agent import csv_orchestrator_chat
 from supabase_service import upload_image_to_supabase
@@ -347,7 +348,10 @@ async def csv_chat(request: Dict, authorization: str = Header(None)):
         generate_report = request.get("generate_report")
         
         if generate_report is True:
-            return {"answer": jsonable_encoder(dummy_response)}
+            report_files = await asyncio.to_thread(
+                generate_csv_report, decoded_url, query
+            )
+            return {"answer": jsonable_encoder(report_files)}
 
         if if_initial_chat_question(query):
             answer = await asyncio.to_thread(
@@ -847,8 +851,13 @@ async def csv_chart(request: dict, authorization: str = Header(None)):
         detailed_answer = request.get("detailed_answer", False)
         conversation_history = request.get("conversation_history", [])
         generate_report = request.get("generate_report", False)
+        
         if generate_report is True:
-           return {"orchestrator_response": jsonable_encoder(dummy_response)}
+            report_files = await asyncio.to_thread(
+                generate_csv_report, csv_url, query
+            )
+            if report_files is not None:
+                return {"orchestrator_response": jsonable_encoder(report_files)}
 
         loop = asyncio.get_running_loop()
         # First, try the langchain-based method if the question qualifies