Update modules/database/sql_db.py

modules/database/sql_db.py

@@ -33,17 +33,19 @@ def get_teacher_user(username):
     return get_user(username, role='Profesor')
 
 def create_user(username, password, role, additional_info=None):
-    user_container, _, _ = get_sql_containers()
+    container = get_container("users")
     try:
-        hashed_password = bcrypt.hashpw(password.encode('utf-8'), bcrypt.gensalt()).decode('utf-8')
         user_data = {
             'id': username,
-            'password': hashed_password,
+            'password': password,  # Ya viene hasheado
             'role': role,
             'timestamp': datetime.now(timezone.utc).isoformat(),
             'additional_info': additional_info or {}
         }
-        user_container.create_item(body=user_data)
+        container.create_item(
+            body=user_data,
+            partition_key=username
+        )
         logger.info(f"Usuario {role} creado: {username}")
         return True
     except Exception as e:
@@ -67,10 +69,12 @@ def record_login(username):
     try:
         container = get_container("users_sessions")
         if not container:
+            logger.error("No se pudo obtener el contenedor users_sessions")
             return None
 
+        session_id = str(uuid.uuid4())
         session_doc = {
-            "id": str(uuid.uuid4()),
+            "id": session_id,
             "type": "session",
             "username": username,
             "loginTime": datetime.now(timezone.utc).isoformat()
@@ -80,8 +84,8 @@ def record_login(username):
             body=session_doc,
             partition_key=username
         )
-        logger.info(f"Sesión registrada para {username}")
-        return result['id']
+        logger.info(f"Sesión {session_id} registrada para {username}")
+        return session_id
     except Exception as e:
         logger.error(f"Error registrando login: {str(e)}")
         return None
@@ -90,15 +94,17 @@ def record_login(username):
 def record_logout(username, session_id):
     """Registra el cierre de sesión y calcula la duración"""
     try:
-        _, _, session_container = get_sql_containers()
-        
-        # Consulta usando la partition key correctamente
-        items = list(session_container.query_items(
+        container = get_container("users_sessions")
+        if not container:
+            logger.error("No se pudo obtener el contenedor users_sessions")
+            return False
+
+        items = list(container.query_items(
             query="SELECT * FROM c WHERE c.id = @id",
             parameters=[{"name": "@id", "value": session_id}],
-            partition_key=username  # Usar la partition key correcta
+            partition_key=username
         ))
-        
+
         if not items:
             logger.warning(f"Sesión no encontrada: {session_id}")
             return False
@@ -113,12 +119,11 @@ def record_logout(username, session_id):
             "sessionDuration": duration
         })
 
-        # Actualizar usando la partition key
-        session_container.upsert_item(
+        container.upsert_item(
             body=session,
             partition_key=username
         )
-        logger.info(f"Sesión cerrada para {username}, duración: {duration}s")
+        logger.info(f"Sesión {session_id} cerrada para {username}, duración: {duration}s")
         return True
     except Exception as e:
         logger.error(f"Error registrando logout: {str(e)}")
@@ -152,7 +157,7 @@ def get_recent_sessions(limit=10):
 def get_user_total_time(username):
     """Obtiene el tiempo total que un usuario ha pasado en la plataforma"""
     try:
-        container = get_sql_container("users_sessions")
+        container = get_container("users_sessions")
         if not container:
             return None
 
@@ -164,12 +169,10 @@ def get_user_total_time(username):
         AND c.logoutTime != null
         """
         
-        params = [{"name": "@username", "value": username}]
-        
         result = list(container.query_items(
             query=query,
-            parameters=params,
-            enable_cross_partition_query=True
+            parameters=[{"name": "@username", "value": username}],
+            partition_key=username
         ))
 
         return result[0] if result else 0