Update modules/database/current_situation_mongo_db.py

modules/database/current_situation_mongo_db.py

@@ -9,6 +9,10 @@ COLLECTION_NAME = 'student_current_situation'
 
 # En modules/database/current_situation_mongo_db.py
 def store_current_situation_result(username, text, metrics, feedback):
+    success = store_current_situation_result(username, text, metrics, feedback)
+    if success:
+        verify_storage(username) #Verificar que se guarda correctamente
+    return success
     """
     Guarda los resultados del análisis de situación actual.
     """
@@ -71,4 +75,38 @@ def store_current_situation_result(username, text, metrics, feedback):
         
     except Exception as e:
         logger.error(f"Error guardando análisis de situación actual: {str(e)}")
+        return False
+
+def verify_storage(username):
+    """
+    Verifica que los datos se están guardando correctamente.
+    """
+    try:
+        collection = get_collection(COLLECTION_NAME)
+        if collection is None:
+            return False
+            
+        # Buscar documentos recientes del usuario
+        recent_docs = collection.find({
+            'username': username,
+            'timestamp': {
+                '$gte': (datetime.now(timezone.utc) - timedelta(minutes=5)).isoformat()
+            }
+        }).sort('timestamp', -1).limit(1)
+
+        docs = list(recent_docs)
+        if docs:
+            logger.info(f"""
+                Último documento guardado:
+                - ID: {docs[0]['_id']}
+                - Timestamp: {docs[0]['timestamp']}
+                - Métricas guardadas: {bool(docs[0].get('metrics'))}
+            """)
+            return True
+        
+        logger.warning(f"No se encontraron documentos recientes para {username}")
+        return False
+
+    except Exception as e:
+        logger.error(f"Error verificando almacenamiento: {str(e)}")
         return False