Mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2026-05-26 20:49:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: Fix errors in api/client/send.rs

Browse Source
This commit is contained in:
Ginger
2026-04-28 09:16:52 -04:00
parent 6cb3f909c9
commit cbf24a9483
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/api/client/send.rs
+6 -6
View File
@@ -40,7 +40,7 @@ pub(crate) async fn send_message_event_route(
return Err!(Request(Forbidden("Encryption has been disabled"))); return Err!(Request(Forbidden("Encryption has been disabled")));
} }
let state_lock = services.rooms.state.mutex.lock(&body.room_id).await; let state_lock = services.rooms.state.mutex.lock(body.room_id.as_str()).await;
if body.event_type == MessageLikeEventType::CallInvite if body.event_type == MessageLikeEventType::CallInvite
&& services.rooms.directory.is_public_room(&body.room_id).await && services.rooms.directory.is_public_room(&body.room_id).await
@@ -62,11 +62,11 @@ pub(crate) async fn send_message_event_route(
))); )));
} }
return Ok(send_message_event::v3::Response { let event_id = utils::string_from_bytes(&response)
event_id: utils::string_from_bytes(&response)
.map(TryInto::try_into) .map(TryInto::try_into)
.map_err(|e| err!(Database("Invalid event_id in txnid data: {e:?}")))??, .map_err(|e| err!(Database("Invalid event_id in txnid data: {e:?}")))??;
});
return Ok(send_message_event::v3::Response::new(event_id));
} }
let mut unsigned = BTreeMap::new(); let mut unsigned = BTreeMap::new();
@@ -101,5 +101,5 @@ pub(crate) async fn send_message_event_route(
drop(state_lock); drop(state_lock);
Ok(send_message_event::v3::Response { event_id }) Ok(send_message_event::v3::Response::new(event_id))
} }