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

router = APIRouter(prefix="/process")

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