mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-09 16:34:32 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat(ffi): Make fetch_members, members and member async.

Browse Source 
This patch makes the following methods on `Room` async: `fetch_members`,
`members`, and `member`.
This commit is contained in:
Ivan Enderlin
2023-09-06 17:37:05 +02:00
parent 2787d058de
commit f3d33efa0f
1 changed files with 17 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
bindings/matrix-sdk-ffi/src/room.rs
View File

@@ -173,9 +173,11 @@ impl Room {
});
}
pub fn fetch_members(&self) -> Result<Arc<TaskHandle>, ClientError> {
let timeline = RUNTIME
.block_on(self.timeline.read())
pub async fn fetch_members(&self) -> Result<Arc<TaskHandle>, ClientError> {
let timeline = self
.timeline
.read()
.await
.clone()
.context("Timeline not set up, can't fetch members")?;
@@ -197,26 +199,20 @@ impl Room {
})
}
pub fn members(&self) -> Result<Vec<Arc<RoomMember>>, ClientError> {
let room = self.inner.clone();
RUNTIME.block_on(async move {
let members = room
.members(RoomMemberships::empty())
.await?
.iter()
.map(|m| Arc::new(RoomMember::new(m.clone())))
.collect();
Ok(members)
})
pub async fn members(&self) -> Result<Vec<Arc<RoomMember>>, ClientError> {
Ok(self
.inner
.members(RoomMemberships::empty())
.await?
.iter()
.map(|m| Arc::new(RoomMember::new(m.clone())))
.collect())
}
pub fn member(&self, user_id: String) -> Result<Arc<RoomMember>, ClientError> {
let room = self.inner.clone();
RUNTIME.block_on(async move {
let user_id = UserId::parse(&*user_id).context("Invalid user id.")?;
let member = room.get_member(&user_id).await?.context("No user found")?;
Ok(Arc::new(RoomMember::new(member)))
})
pub async fn member(&self, user_id: String) -> Result<Arc<RoomMember>, ClientError> {
let user_id = UserId::parse(&*user_id).context("Invalid user id.")?;
let member = self.inner.get_member(&user_id).await?.context("No user found")?;
Ok(Arc::new(RoomMember::new(member)))
}
pub fn member_avatar_url(&self, user_id: String) -> Result<Option<String>, ClientError> {