|
|
@ -35,6 +35,14 @@ async def routerindex2(websocket: WebSocket): |
|
|
await websocket.close() |
|
|
await websocket.close() |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@router.websocket("/router/{pathparam:path}") |
|
|
|
|
|
async def routerindexparams(websocket: WebSocket, pathparam: str, queryparam: str): |
|
|
|
|
|
await websocket.accept() |
|
|
|
|
|
await websocket.send_text(pathparam) |
|
|
|
|
|
await websocket.send_text(queryparam) |
|
|
|
|
|
await websocket.close() |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async def ws_dependency(): |
|
|
async def ws_dependency(): |
|
|
return "Socket Dependency" |
|
|
return "Socket Dependency" |
|
|
|
|
|
|
|
|
@ -106,3 +114,14 @@ def test_router_ws_depends_with_override(): |
|
|
app.dependency_overrides[ws_dependency] = lambda: "Override" |
|
|
app.dependency_overrides[ws_dependency] = lambda: "Override" |
|
|
with client.websocket_connect("/router-ws-depends/") as websocket: |
|
|
with client.websocket_connect("/router-ws-depends/") as websocket: |
|
|
assert websocket.receive_text() == "Override" |
|
|
assert websocket.receive_text() == "Override" |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def test_router_with_params(): |
|
|
|
|
|
client = TestClient(app) |
|
|
|
|
|
with client.websocket_connect( |
|
|
|
|
|
"/router/path/to/file?queryparam=a_query_param" |
|
|
|
|
|
) as websocket: |
|
|
|
|
|
data = websocket.receive_text() |
|
|
|
|
|
assert data == "path/to/file" |
|
|
|
|
|
data = websocket.receive_text() |
|
|
|
|
|
assert data == "a_query_param" |
|
|
|