feat(bindings): Add method for sending plain text replies

Author: stefanceriu

bindings/matrix-sdk-ffi/src/api.udl

@@ -103,8 +103,11 @@ interface Room {
     void stop_live_event_listener();
 
     [Throws=ClientError]
-    void send(MessageEventContent msg, string? txn_id);
-    
+    void send(RoomMessageEventContent msg, string? txn_id);
+
+    [Throws=ClientError]
+    void send_reply(string msg, string in_reply_to_event_id, string? txn_id);
+
     [Throws=ClientError]
     void redact(string event_id, string? reason, string? txn_id);
 };
@@ -113,7 +116,7 @@ interface BackwardsStream {
     sequence<AnyMessage> paginate_backwards(u64 count);
 };
 
-interface MessageEventContent {};
+interface RoomMessageEventContent {};
 
 interface AnyMessage {
     TextMessage? text_message();

bindings/matrix-sdk-ffi/src/lib.rs

@@ -66,7 +66,5 @@ fn setup_tracing(configuration: String) {
 }
 
 mod uniffi_types {
-    pub use matrix_sdk::ruma::events::room::{
-        message::RoomMessageEventContent as MessageEventContent, MediaSource,
-    };
+    pub use matrix_sdk::ruma::events::room::{message::RoomMessageEventContent, MediaSource};
 }

bindings/matrix-sdk-ffi/src/messages.rs

@@ -1,9 +1,7 @@
 use std::sync::Arc;
 
 use extension_trait::extension_trait;
-pub use matrix_sdk::ruma::events::room::{
-    message::RoomMessageEventContent as MessageEventContent, MediaSource,
-};
+pub use matrix_sdk::ruma::events::room::{message::RoomMessageEventContent, MediaSource};
 use matrix_sdk::{
     deserialized_responses::SyncTimelineEvent,
     ruma::events::{
@@ -241,8 +239,8 @@ pub fn media_source_from_url(url: String) -> Arc<MediaSource> {
 }
 
 #[uniffi::export]
-pub fn message_event_content_from_markdown(md: String) -> Arc<MessageEventContent> {
-    Arc::new(MessageEventContent::text_markdown(md))
+pub fn message_event_content_from_markdown(md: String) -> Arc<RoomMessageEventContent> {
+    Arc::new(RoomMessageEventContent::text_markdown(md))
 }
 
 #[extension_trait]

bindings/matrix-sdk-ffi/src/room.rs

@@ -1,10 +1,16 @@
-use std::sync::{Arc, RwLock};
+use std::{
+    convert::TryFrom,
+    sync::{Arc, RwLock},
+};
 
-use anyhow::{bail, Result};
+use anyhow::{bail, Context, Result};
 use futures_util::{pin_mut, StreamExt};
 use matrix_sdk::{
     room::Room as MatrixRoom,
-    ruma::{events::room::message::RoomMessageEventContent, EventId, UserId},
+    ruma::{
+        events::room::message::{RoomMessageEvent, RoomMessageEventContent},
+        EventId, UserId,
+    },
 };
 
 use super::{
@@ -157,10 +163,42 @@ impl Room {
         };
 
         RUNTIME.block_on(async move {
-            room.send((*msg).to_owned(), txn_id.as_deref().map(Into::into)).await
-        })?;
+            room.send((*msg).to_owned(), txn_id.as_deref().map(Into::into)).await?;
+            Ok(())
+        })
+    }
 
-        Ok(())
+    pub fn send_reply(
+        &self,
+        msg: String,
+        in_reply_to_event_id: String,
+        txn_id: Option<String>,
+    ) -> Result<()> {
+        let room = match &self.room {
+            MatrixRoom::Joined(j) => j.clone(),
+            _ => bail!("Can't send to a room that isn't in joined state"),
+        };
+
+        let event_id: &EventId =
+            in_reply_to_event_id.as_str().try_into().context("Failed to create EventId.")?;
+
+        RUNTIME.block_on(async move {
+            let timeline_event = room.event(event_id).await.context("Couldn't find event.")?;
+
+            let event_content = timeline_event
+                .event
+                .deserialize_as::<RoomMessageEvent>()
+                .context("Couldn't deserialise event")?;
+
+            let original_message =
+                event_content.as_original().context("Couldn't retrieve original message.")?;
+
+            let reply_content = RoomMessageEventContent::text_reply_plain(msg, original_message);
+
+            room.send(reply_content, txn_id.as_deref().map(Into::into)).await?;
+
+            Ok(())
+        })
     }
 
     /// Redacts an event from the room.