sdk: send out the to-device requests created by Room::share_history

Author: richvdh

crates/matrix-sdk-base/src/client.rs

@@ -24,6 +24,7 @@ use std::{
 use eyeball::{SharedObservable, Subscriber};
 use eyeball_im::{Vector, VectorDiff};
 use futures_util::Stream;
+use matrix_sdk_crypto::types::events::room_key_bundle::RoomKeyBundleContent;
 #[cfg(feature = "e2e-encryption")]
 use matrix_sdk_crypto::{
     store::DynCryptoStore, types::requests::ToDeviceRequest, CollectStrategy, DecryptionSettings,
@@ -1594,6 +1595,22 @@ impl BaseClient {
         }
     }
 
+    /// Get to-device requests that will share the details of a room key history
+    /// bundle with a user.
+    #[cfg(feature = "e2e-encryption")]
+    pub async fn share_room_key_bundle_data(
+        &self,
+        user_id: &UserId,
+        bundle_data: RoomKeyBundleContent,
+    ) -> Result<Vec<ToDeviceRequest>> {
+        let olm = self.olm_machine().await;
+        let olm = olm.as_ref().expect("Olm machine wasn't started");
+
+        Ok(olm
+            .share_room_key_bundle_data(&user_id, &self.room_key_recipient_strategy, bundle_data)
+            .await?)
+    }
+
     /// Get the room with the given room id.
     ///
     /// # Arguments

crates/matrix-sdk/src/encryption/futures.rs

@@ -17,7 +17,7 @@
 
 #![deny(unreachable_pub)]
 
-use std::{future::IntoFuture, io::Read};
+use std::{future::IntoFuture, io::Read, iter};
 
 use eyeball::SharedObservable;
 #[cfg(not(target_arch = "wasm32"))]
@@ -149,10 +149,11 @@ impl<'a> IntoFuture for ShareRoomHistory<'a> {
         let Self { room, user_id } = self;
         Box::pin(async move {
             tracing::info!("Sharing message history in {} with {}", room.room_id(), user_id);
+            let client = &room.client;
 
             // 1. Construct the key bundle
             let bundle = {
-                let olm_machine = room.client.olm_machine().await;
+                let olm_machine = client.olm_machine().await;
                 let olm_machine = olm_machine
                     .as_ref()
                     .expect("This should only be called once we have an OlmMachine");
@@ -178,9 +179,17 @@ impl<'a> IntoFuture for ShareRoomHistory<'a> {
                 "Uploaded encrypted key blob"
             );
 
-            // 3. Send to-device messages to the recipient to share the keys.
-            // TODO
+            // 3. Establish Olm seeions with all of the recipient's devices
+            client.claim_one_time_keys(iter::once(user_id.as_ref())).await?;
 
+            // 4. Send to-device messages to the recipient to share the keys.
+            let requests =
+                client.base_client().share_room_key_bundle_data(&user_id, upload).await?;
+
+            for request in requests {
+                let response = client.send_to_device(&request).await?;
+                client.mark_request_as_sent(&request.txn_id, &response).await?;
+            }
             Ok(())
         })
     }