fixed duplication

app.py

@@ -9,7 +9,6 @@ from utils.retriever import retrieve_paragraphs
 from utils.generator import generate
 
 # Sample questions for examples 
-
 SAMPLE_QUESTIONS = {
     "Análisis de la deforestación": [
         "¿Cuáles son los principales puntos críticos de deforestación en Ecuador?",
@@ -28,8 +27,10 @@ SAMPLE_QUESTIONS = {
     ]
 }
 
-# Initialize Chat
+# Global variable to cache API results and prevent double calls
+geojson_analysis_cache = {}
 
+# Initialize Chat
 def start_chat(query, history):
     """Start a new chat interaction"""
     history = history + [(query, None)]
@@ -42,6 +43,10 @@ def finish_chat():
 async def chat_response(query, history, method, country, uploaded_file):
     """Generate chat response based on method and inputs"""
     
+    # Skip processing if this is an auto-generated file analysis message
+    if query.startswith("📄 GeoJSON cargado"):
+        return
+    
     # Validate inputs
     if method == "Subir GeoJson":
         if uploaded_file is None:
@@ -56,20 +61,28 @@ async def chat_response(query, history, method, country, uploaded_file):
             yield history, ""
             return
     
-    # Handle GeoJSON upload → put formatted stats into chat
+    # Handle GeoJSON upload → use cached results
     if method == "Subir GeoJson" and uploaded_file:
         try:
-            # handle_geojson_upload returns a tuple (formatted_stats, gr.update(), gr.update())
-            stats_result = handle_geojson_upload(uploaded_file)
-            formatted_stats = stats_result[0]  # Extract just the formatted statistics
-            response = formatted_stats
+            # Check if we have cached results for this file
+            file_key = f"{uploaded_file.name}_{uploaded_file.size if hasattr(uploaded_file, 'size') else 'unknown'}"
+            
+            if file_key in geojson_analysis_cache:
+                # Use cached results
+                response = geojson_analysis_cache[file_key]
+            else:
+                # Call API and cache results
+                stats_result = handle_geojson_upload(uploaded_file)
+                formatted_stats = stats_result[0]
+                geojson_analysis_cache[file_key] = formatted_stats
+                response = formatted_stats
+                
         except Exception as e:
             response = f"Error processing file: {str(e)}"
     
     # Handle "Talk to Reports"
     else: 
         try: 
-            # response = f"Based on EUDR reports for {country}, I can help you understand deforestation patterns and compliance requirements. Your question: '{query}' is being analyzed..."
             retrieved_paragraphs = retrieve_paragraphs(query)
             response = await generate(query=query, context=retrieved_paragraphs)
             
@@ -87,26 +100,26 @@ async def chat_response(query, history, method, country, uploaded_file):
 def auto_analyze_file(file, history):
     """Automatically analyze uploaded GeoJSON file and add results to chat"""
     if file is not None:
-        # Add a system message indicating file upload
-        analysis_query = "📄 GeoJSON cargado - analizando..."
-        history = history + [(analysis_query, None)]
-        return history, analysis_query
-    return history, ""
-
-def auto_display_results(query, history, uploaded_file):
-    """Display analysis results automatically after file upload"""
-    if uploaded_file is not None and query.startswith("📄 GeoJSON cargado"):
         try:
-            # Get the analysis results
-            stats_result = handle_geojson_upload(uploaded_file)
-            formatted_stats = stats_result[0]  # Extract formatted statistics
+            # Call API immediately and cache results
+            file_key = f"{file.name}_{file.size if hasattr(file, 'size') else 'unknown'}"
+            
+            if file_key not in geojson_analysis_cache:
+                stats_result = handle_geojson_upload(file)
+                formatted_stats = stats_result[0]
+                geojson_analysis_cache[file_key] = formatted_stats
             
-            # Update the chat with results
-            history[-1] = (query, formatted_stats)
+            # Add analysis results directly to chat (no intermediate message)
+            analysis_query = "📄 Análisis del GeoJSON cargado"
+            cached_result = geojson_analysis_cache[file_key]
+            
+            # Add both query and response to history
+            history = history + [(analysis_query, cached_result)]
             return history, "**Sources:** WhispAPI Analysis Results"
+            
         except Exception as e:
             error_msg = f"❌ Error processing GeoJSON file: {str(e)}"
-            history[-1] = (query, error_msg)
+            history = history + [("📄 Error en análisis GeoJSON", error_msg)]
             return history, ""
     
     return history, ""
@@ -384,16 +397,12 @@ with gr.Blocks(title="EUDR Bot", theme=theme, css=custom_css) as demo:
         outputs=[geojson_section, reports_section, dropdown_country]
     )
     
-    # File upload - automatically analyze and display in chat
+    # File upload - automatically analyze and display in chat (SIMPLIFIED)
     uploaded_file.change(
         fn=auto_analyze_file,
         inputs=[uploaded_file, chatbot],
-        outputs=[chatbot, examples_hidden],
+        outputs=[chatbot, sources_textbox],
         queue=False
-    ).then(
-        fn=auto_display_results,
-        inputs=[examples_hidden, chatbot, uploaded_file],
-        outputs=[chatbot, sources_textbox]
     )
     
     # Chat functionality