Update modules/database/discourse_mongo_db.py

modules/database/discourse_mongo_db.py

@@ -100,48 +100,51 @@ def store_student_discourse_result(username, text1, text2, analysis_result):
 
 
 
-
-
-
+#################################################################################
 def get_student_discourse_analysis(username, limit=10):
     """
     Recupera los análisis del discurso de un estudiante.
-    Args:
-        username: Nombre del usuario
-        limit: Número máximo de análisis a retornar
-    Returns:
-        list: Lista de análisis del discurso
     """
     try:
+        # Obtener la colección
         collection = get_collection(COLLECTION_NAME)
-        if not collection:
+        if collection is None:  # Cambiado de if not collection a if collection is None
             logger.error("No se pudo obtener la colección discourse")
             return []
 
+        # Consulta
         query = {
             "username": username,
             "analysis_type": "discourse"
         }
         
-        # Definir los campos que queremos recuperar
+        # Campos a recuperar
         projection = {
             "timestamp": 1,
             "combined_graph": 1,
             "_id": 1
         }
         
-        cursor = collection.find(query, projection).sort("timestamp", -1)
-        
-        if limit:
-            cursor = cursor.limit(limit)
+        # Ejecutar consulta
+        try:
+            cursor = collection.find(query, projection).sort("timestamp", -1)
+            if limit:
+                cursor = cursor.limit(limit)
+            
+            # Convertir cursor a lista
+            results = list(cursor)
+            logger.info(f"Recuperados {len(results)} análisis del discurso para {username}")
+            return results
             
-        result = list(cursor)
-        logger.info(f"Recuperados {len(result)} análisis del discurso")
-        return result
+        except Exception as db_error:
+            logger.error(f"Error en la consulta a MongoDB: {str(db_error)}")
+            return []
         
     except Exception as e:
         logger.error(f"Error recuperando análisis del discurso: {str(e)}")
         return []
+#####################################################################################
+