Update modules/database/database_init.py

modules/database/database_init.py

@@ -36,116 +36,20 @@ def verify_container_partition_key(container, expected_path):
 ###################################################################
 def get_container(container_name):
     """Obtiene un contenedor específico"""
-    logger.info(f"Solicitando contenedor: {container_name}")
+    global user_container, user_sessions_container
     
     if not initialize_cosmos_sql_connection():
         logger.error("No se pudo inicializar la conexión")
         return None
     
-    # Verificar 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": application_user_feedback is not None,
-    }
-    
-    logger.info(f"Estado actual de los contenedores: {containers_status}")
-    
-    # Mapear nombres a contenedores
     containers = {
         "users": user_container,
-        "users_sessions": user_sessions_container,
-        "application_requests": application_requests_container,
-        "user_feedback": user_feedback_container
+        "users_sessions": user_sessions_container
     }
     
-    container = containers.get(container_name)
-    
-    if container is None:
-        logger.error(f"Contenedor '{container_name}' no encontrado o no inicializado")
-        logger.error(f"Contenedores disponibles: {[k for k, v in containers_status.items() if v]}")
-        return None
-        
-    logger.info(f"Contenedor '{container_name}' obtenido exitosamente")
-    return container
-
+    return containers.get(container_name)
 
 ###################################################################
-'''
-def get_container(container_name):
-    """Obtiene un contenedor específico"""
-    if not initialize_cosmos_sql_connection():
-        logger.error("No se pudo inicializar la conexión")
-        return None
-    
-    # Loggear los contenedores disponibles para debug
-    available_containers = {
-        "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.debug(f"Contenedores disponibles: {available_containers}")
-    
-    containers = {
-        "users": user_container,
-        "users_sessions": user_sessions_container,
-        "application_requests": application_requests_container,
-        "user_feedback": user_feedback_container
-    }
-    
-    container = containers.get(container_name)
-    if not container:
-        logger.error(f"Contenedor no encontrado: {container_name}")
-        logger.error(f"Contenedores disponibles: {list(containers.keys())}")
-        return None
-        
-    return container
-'''
-
-###################################################################
-
-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, user_feedback_container
-
-    try:
-        # Verificar conexiones existentes
-        if all([
-            cosmos_client,
-            user_database,
-            user_container,
-            user_sessions_container,
-            application_requests_container,
-            user_feedback_container
-        ]):
-            logger.debug("Todas las conexiones ya están inicializadas")
-            return True
-
-        # ... código existente ...
-
-        # 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}")
-        
-        return True
-
-    except Exception as e:
-        logger.error(f"Error al conectar con Cosmos DB SQL API: {str(e)}")
-        return False
-
-######################################################
-
-'''
 def initialize_cosmos_sql_connection():
     """Inicializa la conexión a Cosmos DB SQL API"""
     global cosmos_client, user_database, user_container, user_sessions_container
@@ -163,11 +67,9 @@ def initialize_cosmos_sql_connection():
         cosmos_client = CosmosClient(cosmos_endpoint, cosmos_key)
         user_database = cosmos_client.get_database_client("user_database")
         
-        
         # Inicializar contenedores manteniendo la estructura existente
         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")
         
         logger.info("Conexión a Cosmos DB SQL API exitosa")
         return True
@@ -175,7 +77,6 @@ def initialize_cosmos_sql_connection():
     except Exception as e:
         logger.error(f"Error al conectar con Cosmos DB SQL API: {str(e)}")
         return False
-'''        
         
 ###################################################################
 def initialize_mongodb_connection():