Update modules/database.py

modules/database.py

@@ -88,15 +88,26 @@ def create_user(user_data):
         logger.error(f"Error al crear usuario: {str(e)}")
         return False
 
+################################################################################
 # Funciones para Cosmos DB MongoDB API (análisis de texto)
+
 def get_student_data(username):
     if analysis_collection is None:
         logger.error("La conexión a MongoDB no está inicializada")
         return None
 
     try:
-        # Buscar los datos del estudiante
-        cursor = analysis_collection.find({"username": username}).sort("timestamp", -1)
+        logger.info(f"Buscando datos para el usuario: {username}")
+        # Obtener todos los documentos para el usuario sin ordenar
+        cursor = analysis_collection.find({"username": username})
+        
+        # Contar documentos
+        count = analysis_collection.count_documents({"username": username})
+        logger.info(f"Número de documentos encontrados para {username}: {count}")
+
+        if count == 0:
+            logger.info(f"No se encontraron datos para el usuario {username}")
+            return None
         
         # Formatear los datos
         formatted_data = {
@@ -109,12 +120,11 @@ def get_student_data(username):
         }
         
         for entry in cursor:
-            entry_data = {
-                "timestamp": entry["timestamp"].isoformat(),
-                "text": entry["text"],
-                "word_count": entry.get("word_count", {})
-            }
-            formatted_data["entries"].append(entry_data)
+            logger.debug(f"Procesando entrada: {entry}")
+            formatted_data["entries"].append({
+                "timestamp": entry["timestamp"],
+                "text": entry["text"]
+            })
             formatted_data["entries_count"] += 1
             
             # Agregar conteo de palabras
@@ -128,11 +138,19 @@ def get_student_data(username):
             formatted_data["arc_diagrams"].extend(entry.get("arc_diagrams", []))
             formatted_data["network_diagrams"].append(entry.get("network_diagram", ""))
         
-        logger.info(f"Datos obtenidos para {username}: {formatted_data}")
+        # Ordenar las entradas por timestamp después de obtenerlas
+        formatted_data["entries"].sort(key=lambda x: x["timestamp"], reverse=True)
+        
+        # Convertir los timestamps a formato ISO después de ordenar
+        for entry in formatted_data["entries"]:
+            entry["timestamp"] = entry["timestamp"].isoformat()
+        
+        logger.info(f"Datos formateados para {username}: {formatted_data}")
         return formatted_data if formatted_data["entries_count"] > 0 else None
     except Exception as e:
         logger.error(f"Error al obtener datos del estudiante {username}: {str(e)}")
         return None
+#######################################################################################################
 
 def store_analysis_result(username, text, repeated_words, arc_diagrams, network_diagram):
     if analysis_collection is None: