|
|
@@ -1,4 +1,5 @@
|
|
|
import asyncio
|
|
|
+from logging import getLogger
|
|
|
from fastapi import WebSocket, WebSocketDisconnect, Query, status
|
|
|
from fastapi.routing import APIRouter
|
|
|
from services.data_service import UserDataService
|
|
|
@@ -7,7 +8,7 @@ from jose import jwt, JWTError
|
|
|
|
|
|
# Importar tus configuraciones y servicios existentes
|
|
|
# from security import SECRET_KEY, ALGORITHM, user_data_service (Ajusta según tu estructura)
|
|
|
-
|
|
|
+logger = getLogger(__name__)
|
|
|
debug_router = APIRouter()
|
|
|
user_data_service = UserDataService()
|
|
|
|
|
|
@@ -27,6 +28,7 @@ async def validate_ws_token(token: str):
|
|
|
|
|
|
@debug_router.websocket("/logs")
|
|
|
async def websocket_endpoint(websocket: WebSocket, token: str = Query(...)):
|
|
|
+ logger.info("WebSocket connection established")
|
|
|
# 1. Autenticación
|
|
|
user = await validate_ws_token(token)
|
|
|
|