diff --git a/services/identity/src/tunnelbroker.rs b/services/identity/src/tunnelbroker.rs --- a/services/identity/src/tunnelbroker.rs +++ b/services/identity/src/tunnelbroker.rs @@ -50,3 +50,23 @@ .await?, ) } + +pub async fn send_device_list_update( + device_id: &str, +) -> Result, Error> { + let mut tunnelbroker_client = create_tunnelbroker_client().await?; + + let update = messages::IdentityDeviceListUpdated {}; + let payload = serde_json::to_string(&update).unwrap(); + let request = MessageToDevice { + device_id: device_id.to_string(), + payload, + }; + + let grpc_message = tonic::Request::new(request); + Ok( + tunnelbroker_client + .send_message_to_device(grpc_message) + .await?, + ) +}