Changeset View
Changeset View
Standalone View
Standalone View
services/commtest/tests/tunnelbroker_integration_test.rs
Show All 14 Lines | async fn send_refresh_request() { | ||||
let (mut socket, _) = connect_async("ws://localhost:51001") | let (mut socket, _) = connect_async("ws://localhost:51001") | ||||
.await | .await | ||||
.expect("Can't connect"); | .expect("Can't connect"); | ||||
let session_request = r#"{ | let session_request = r#"{ | ||||
"type": "sessionRequest", | "type": "sessionRequest", | ||||
"accessToken": "xkdeifjsld", | "accessToken": "xkdeifjsld", | ||||
"deviceId": "foo", | "deviceId": "foo", | ||||
"userId": "alice", | |||||
"deviceType": "keyserver" | "deviceType": "keyserver" | ||||
}"#; | }"#; | ||||
socket | socket | ||||
.send(Message::Text(session_request.to_string())) | .send(Message::Text(session_request.to_string())) | ||||
.await | .await | ||||
.expect("Failed to send message"); | .expect("Failed to send message"); | ||||
Show All 31 Lines |