Differential D7800 Diff 27356 services/commtest/tests/tunnelbroker_integration_test.rs

Changeset View

Standalone View

Show First 20 Lines • Show All 104 Lines • ▼ Show 20 Lines	let session_request = r#"{
}"#;		}"#;

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");

// Have keyserver receive any websocket messages		// Have keyserver receive any websocket messages
let response = socket.next().await.unwrap().unwrap();		if let Some(Ok(response)) = socket.next().await {

// Check that message received by keyserver matches what identity server		// Check that message received by keyserver matches what identity server
// issued		// issued
let serialized_response: RefreshKeyRequest =		let serialized_response: RefreshKeyRequest =
serde_json::from_str(&response.to_text().unwrap()).unwrap();		serde_json::from_str(&response.to_text().unwrap()).unwrap();
assert_eq!(serialized_response, refresh_request);		assert_eq!(serialized_response, refresh_request);
		};
}		}