Spaces:
Sleeping
Sleeping
Update routers/websockets_new.py
Browse files
routers/websockets_new.py
CHANGED
@@ -1,14 +1,14 @@
|
|
1 |
from fastapi import APIRouter , Request ,HTTPException , WebSocket
|
2 |
from controllers import websocket_controller as wc
|
|
|
3 |
import logging
|
4 |
|
5 |
-
router = APIRouter(prefix="/
|
6 |
|
7 |
-
@router.websocket("
|
8 |
async def get_data(websocket:WebSocket):
|
9 |
await websocket.accept()
|
10 |
-
logging.info("Connection accepted")
|
11 |
access_token = await websocket.receive_text()
|
12 |
logging.info(f"access_token : {access_token}")
|
13 |
-
await
|
14 |
|
|
|
1 |
from fastapi import APIRouter , Request ,HTTPException , WebSocket
|
2 |
from controllers import websocket_controller as wc
|
3 |
+
from controllers import ws_controller as w
|
4 |
import logging
|
5 |
|
6 |
+
router = APIRouter(prefix="/websockets")
|
7 |
|
8 |
+
@router.websocket("/ws")
|
9 |
async def get_data(websocket:WebSocket):
|
10 |
await websocket.accept()
|
|
|
11 |
access_token = await websocket.receive_text()
|
12 |
logging.info(f"access_token : {access_token}")
|
13 |
+
await w.websocket_main(access_token , websocket)
|
14 |
|