D5838.id.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D5838.id.diff
View Options

	diff --git a/services/commtest/src/tunnelbroker/new_session.rs b/services/commtest/src/tunnelbroker/new_session.rs
	--- a/services/commtest/src/tunnelbroker/new_session.rs
	+++ b/services/commtest/src/tunnelbroker/new_session.rs
	@@ -1,6 +1,8 @@
	+use super::tunnelbroker_utils::proto::new_session_request::DeviceTypes;
	use crate::tools::Error;
	use crate::tunnelbroker::tunnelbroker_utils::{
	- proto::SessionSignatureRequest, TunnelbrokerServiceClient,
	+ proto::NewSessionRequest, proto::SessionSignatureRequest,
	+ TunnelbrokerServiceClient,
	};
	use openssl::hash::MessageDigest;
	use openssl::pkey::PKey;
	@@ -28,3 +30,28 @@
	let signature = signer.sign_to_vec()?;
	Ok(base64::encode(signature))
	}
	+
	+pub async fn create_new_session(
	+ client: &mut TunnelbrokerServiceClient<tonic::transport::Channel>,
	+ device_id: &str,
	+ public_key: &str,
	+ signature: &str,
	+ notify_token: &str,
	+ device_type: DeviceTypes,
	+ device_app_version: &str,
	+ device_os: &str,
	+) -> Result<String, Error> {
	+ let response = client
	+ .new_session(Request::new(NewSessionRequest {
	+ device_id: device_id.to_string(),
	+ public_key: public_key.to_string(),
	+ signature: signature.to_string(),
	+ notify_token: Some(notify_token.to_string()),
	+ device_type: device_type as i32,
	+ device_app_version: device_app_version.to_string(),
	+ device_os: device_os.to_string(),
	+ }))
	+ .await?;
	+ let session_id = response.into_inner().session_id;
	+ Ok(session_id)
	+}