Differential D8817 Diff 30413 services/identity/src/tunnelbroker.rs

Changeset View

Standalone View

Show All 18 Lines	.map_err(\|e\| {
error!("Unable able to connect to tunnelbroker: {:?}", e);		error!("Unable able to connect to tunnelbroker: {:?}", e);
e.into()		e.into()
})		})
}		}

pub async fn send_refresh_keys_request(		pub async fn send_refresh_keys_request(
device_id: &str,		device_id: &str,
) -> Result<Response<Empty>, Error> {		) -> Result<Response<Empty>, Error> {
use crate::constants::ONETIME_KEY_REFRESH_NUMBER;		use crate::constants::ONE_TIME_KEY_REFRESH_NUMBER;

let mut tunnelbroker_client = create_tunnelbroker_client().await?;		let mut tunnelbroker_client = create_tunnelbroker_client().await?;

let refresh_request = messages::RefreshKeyRequest {		let refresh_request = messages::RefreshKeyRequest {
device_id: device_id.to_string(),		device_id: device_id.to_string(),
number_of_keys: ONETIME_KEY_REFRESH_NUMBER,		number_of_keys: ONE_TIME_KEY_REFRESH_NUMBER,
};		};

let payload = serde_json::to_string(&refresh_request).unwrap();		let payload = serde_json::to_string(&refresh_request).unwrap();
let request = MessageToDevice {		let request = MessageToDevice {
device_id: device_id.to_string(),		device_id: device_id.to_string(),
payload,		payload,
};		};

let grpc_message = tonic::Request::new(request);		let grpc_message = tonic::Request::new(request);
Ok(		Ok(
tunnelbroker_client		tunnelbroker_client
.send_message_to_device(grpc_message)		.send_message_to_device(grpc_message)
.await?,		.await?,
)		)
}		}