routers/websockets_new.py

from fastapi import APIRouter , Request ,HTTPException , WebSocket
from controllers import websocket_controller as wc
from controllers import ws_controller as w
import logging

router = APIRouter(prefix="/websockets")

@router.websocket("/ws")
async def get_data(websocket:WebSocket):
    await websocket.accept()
    access_token = await websocket.receive_text()
    logging.info(f"access_token : {access_token}")
    await w.websocket_main(access_token , websocket)