public
/
j7s-matrix-sdk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Adjust message types.

This commit is contained in:
James Pace 2025-02-16 09:19:26 -05:00
parent 71933d5827
commit b07d20cd64
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/bin/broadcaster.rs
View File

@ -6,8 +6,7 @@ async fn main() -> anyhow::Result<()> {
let broadcaster = j7s_matrix_sdk::MatrixBroadcaster::new(&url, &token, &device_name).await?; let broadcaster = j7s_matrix_sdk::MatrixBroadcaster::new(&url, &token, &device_name).await?;
let message = let message = matrix_sdk::ruma::events::room::message::MessageType::text_plain("Hi!");
matrix_sdk::ruma::events::room::message::RoomMessageEventContent::text_plain("Hi!");
loop { loop {
tokio::time::sleep(tokio::time::Duration::from_secs(2)).await; tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;
broadcaster.broadcast(&message).await?; broadcaster.broadcast(&message).await?;

10
src/broadcaster.rs
View File

@ -41,15 +41,17 @@ impl MatrixBroadcaster {
pub async fn broadcast( pub async fn broadcast(
self: &Self, self: &Self,
msg: &matrix_sdk::ruma::events::room::message::RoomMessageEventContent, msg: &matrix_sdk::ruma::events::room::message::MessageType,
) -> anyhow::Result<()> { ) -> anyhow::Result<()> {
let rooms_clone = self.rooms.clone(); let rooms_clone = self.rooms.clone();
let rooms = rooms_clone.read().await.clone(); let rooms = rooms_clone.read().await.clone();
for room in rooms { for room in rooms {
room.send(msg.clone()) room.send(
.await matrix_sdk::ruma::events::room::message::RoomMessageEventContent::new(msg.clone()),
.context("Failed to send message to room.")?; )
.await
.context("Failed to send message to room.")?;
} }
Ok(()) Ok(())