Update modules/database/database_init.py

modules/database/database_init.py

@@ -46,7 +46,8 @@ def get_container(container_name):
     containers_status = {
         "users": user_container is not None,
         "users_sessions": user_sessions_container is not None,
-        "application_requests": application_requests_container is not None
+        "application_requests": application_requests_container is not None,
+        "user_feedback": application_user_feedback is not None,
     }
     
     logger.info(f"Estado actual de los contenedores: {containers_status}")
@@ -55,7 +56,8 @@ def get_container(container_name):
     containers = {
         "users": user_container,
         "users_sessions": user_sessions_container,
-        "application_requests": application_requests_container
+        "application_requests": application_requests_container,
+        "user_feedback": user_feedback_container
     }
     
     container = containers.get(container_name)
@@ -106,10 +108,10 @@ def get_container(container_name):
 
 def initialize_cosmos_sql_connection():
     """Inicializa la conexión a Cosmos DB SQL API"""
-    global cosmos_client, user_database, user_container, user_sessions_container, application_requests_container
+    global cosmos_client, user_database, user_container, user_sessions_container, application_requests_container, user_feedback_container
 
     try:
-        # Verificar conexión existente
+        # Verificar conexiones existentes
         if all([
             cosmos_client,
             user_database,
@@ -121,63 +123,21 @@ def initialize_cosmos_sql_connection():
             logger.debug("Todas las conexiones ya están inicializadas")
             return True
 
-        # Obtener credenciales
-        cosmos_endpoint = os.environ.get("COSMOS_ENDPOINT")
-        cosmos_key = os.environ.get("COSMOS_KEY")
-        
-        if not cosmos_endpoint or not cosmos_key:
-            raise ValueError("COSMOS_ENDPOINT y COSMOS_KEY deben estar configurados")
+        # ... código existente ...
 
-        # Inicializar cliente y base de datos
-        cosmos_client = CosmosClient(cosmos_endpoint, cosmos_key)
-        user_database = cosmos_client.get_database_client("user_database")
-        
-        # Inicializar cada contenedor individualmente con verificación
-        try:
-            user_container = user_database.get_container_client("users")
-            logger.info("Contenedor 'users' inicializado correctamente")
-        except Exception as e:
-            logger.error(f"Error inicializando contenedor 'users': {str(e)}")
-            user_container = None
-
-        try:
-            user_sessions_container = user_database.get_container_client("users_sessions")
-            logger.info("Contenedor 'users_sessions' inicializado correctamente")
-        except Exception as e:
-            logger.error(f"Error inicializando contenedor 'users_sessions': {str(e)}")
-            user_sessions_container = None
-
-        try:
-            application_requests_container = user_database.get_container_client("application_requests")
-            logger.info("Contenedor 'application_requests' inicializado correctamente")
-        except Exception as e:
-            logger.error(f"Error inicializando contenedor 'application_requests': {str(e)}")
-            application_requests_container = None
-
-        try:
-            user_feedback_container = user_database.get_container_client("user_feedback_container")
-            logger.info("Contenedor 'user_feedback_container' inicializado correctamente")
-        except Exception as e:
-            logger.error(f"Error inicializando contenedor 'user_feedback_container': {str(e)}")
-            application_requests_container = None
-
-        # Verificar el estado de los contenedores
-        containers_status = {
-            'users': user_container is not None,
-            'users_sessions': user_sessions_container is not None,
-            'application_requests': application_requests_container is not None,
-            'user_feedback': user_feedback_container is not None
-        }
-        
-        logger.info(f"Estado de los contenedores: {containers_status}")
+        # Inicializar contenedores
+        user_container = user_database.get_container_client("users")
+        user_sessions_container = user_database.get_container_client("users_sessions")
+        application_requests_container = user_database.get_container_client("application_requests")
+        user_feedback_container = user_database.get_container_client("user_feedback")
+
+        logger.info("Contenedores inicializados:")
+        logger.info(f"- users: {user_container is not None}")
+        logger.info(f"- users_sessions: {user_sessions_container is not None}")
+        logger.info(f"- application_requests: {application_requests_container is not None}")
+        logger.info(f"- user_feedback: {user_feedback_container is not None}")
         
-        # Solo retornar True si todos los contenedores se inicializaron correctamente
-        if all(containers_status.values()):
-            logger.info("Todos los contenedores inicializados correctamente")
-            return True
-        else:
-            logger.error("No se pudieron inicializar todos los contenedores")
-            return False
+        return True
 
     except Exception as e:
         logger.error(f"Error al conectar con Cosmos DB SQL API: {str(e)}")