update admin create user

modules/admin/admin_ui.py

@@ -14,7 +14,7 @@ from ..database.sql_db import (
     get_user_total_time
 )
 
-from ..database.morphosintax_mongo_db import get_student_morphosyntax_analysis
+#from ..database.morphosintax_mongo_db import get_student_morphosyntax_analysis
 from ..auth.auth import hash_password  # Agregar esta importación al inicio
 
 #######################################################################################

modules/database/mongo_db.py

@@ -3,6 +3,7 @@ import logging
 
 logger = logging.getLogger(__name__)
 
+############################################################
 def get_collection(collection_name):
     try:
         db = get_mongodb()
@@ -18,6 +19,7 @@ def get_collection(collection_name):
         logger.error(f"Error al obtener colección {collection_name}: {str(e)}")
         return None
 
+############################################################
 def insert_document(collection_name, document):
     collection = get_collection(collection_name)
     try:
@@ -28,6 +30,7 @@ def insert_document(collection_name, document):
         logger.error(f"Error al insertar documento en {collection_name}: {str(e)}")
         return None
 
+############################################################
 def find_documents(collection_name, query, sort=None, limit=None):
     collection = get_collection(collection_name)
     try:
@@ -41,6 +44,7 @@ def find_documents(collection_name, query, sort=None, limit=None):
         logger.error(f"Error al buscar documentos en {collection_name}: {str(e)}")
         return []
 
+############################################################
 def update_document(collection_name, query, update):
     collection = get_collection(collection_name)
     try:
@@ -51,6 +55,7 @@ def update_document(collection_name, query, update):
         logger.error(f"Error al actualizar documento en {collection_name}: {str(e)}")
         return 0
 
+############################################################
 def delete_document(collection_name, query):
     collection = get_collection(collection_name)
     try:

modules/database/sql_db.py

@@ -4,6 +4,7 @@ from .database_init import get_container
 from datetime import datetime, timezone
 import logging
 import bcrypt
+import bson import json_util
 import uuid
 
 logger = logging.getLogger(__name__)
@@ -47,13 +48,16 @@ def create_user(username, password, role, additional_info=None):
             'id': username,
             'password': password,
             'role': role,
-            'timestamp': datetime.now(timezone.utc), # Mejor práctica
+            'timestamp': datetime.now(timezone.utc),  # ← Se mantiene como datetime
             'additional_info': additional_info or {},
-            'partitionKey': username  # Agregar partition key
+            'partitionKey': username
         }
         
-        # Crear item sin especificar partition_key en el método
-        container.create_item(body=user_data)
+        # Convertir usando json_util antes de enviar a Cosmos DB
+        user_data_json = json.loads(json_util.dumps(user_data))
+        
+        # Crear item con los datos convertidos
+        container.create_item(body=user_data_json)
         logger.info(f"Usuario {role} creado: {username}")
         return True
         
@@ -87,12 +91,15 @@ def record_login(username):
             "id": session_id,
             "type": "session",
             "username": username,
-            "loginTime": datetime.now(timezone.utc),
+            "loginTime": datetime.now(timezone.utc),  # ← Se mantiene como datetime
             "additional_info": {},
             "partitionKey": username
         }
 
-        result = container.create_item(body=session_doc)
+        # Convertir usando json_util
+        session_json = json.loads(json_util.dumps(session_doc))
+        
+        result = container.create_item(body=session_json)
         logger.info(f"Sesión {session_id} registrada para {username}")
         return session_id
     except Exception as e: