magmaus3/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ping online presence on typing updates like synapse

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2024-12-15 02:53:32 -05:00
parent 6c96acc482
commit c8349988aa
No known key found for this signature in database
1 changed files with 16 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

20
src/api/client/typing.rs
View file

@ -1,7 +1,8 @@
use axum::extract::State; use axum::extract::State;
use ruma::api::client::{error::ErrorKind, typing::create_typing_event}; use conduwuit::Err;
use ruma::api::client::typing::create_typing_event;
use crate::{utils, Error, Result, Ruma}; use crate::{utils, Result, Ruma};
/// # `PUT /_matrix/client/r0/rooms/{roomId}/typing/{userId}` /// # `PUT /_matrix/client/r0/rooms/{roomId}/typing/{userId}`
/// ///
@ -11,8 +12,11 @@ pub(crate) async fn create_typing_event_route(
body: Ruma<create_typing_event::v3::Request>, body: Ruma<create_typing_event::v3::Request>,
) -> Result<create_typing_event::v3::Response> { ) -> Result<create_typing_event::v3::Response> {
use create_typing_event::v3::Typing; use create_typing_event::v3::Typing;
let sender_user = body.sender_user();
let sender_user = body.sender_user.as_ref().expect("user is authenticated"); if sender_user != body.user_id && body.appservice_info.is_none() {
return Err!(Request(Forbidden("You cannot update typing status of other users.")));
}
if !services if !services
.rooms .rooms
@ -20,7 +24,7 @@ pub(crate) async fn create_typing_event_route(
.is_joined(sender_user, &body.room_id) .is_joined(sender_user, &body.room_id)
.await .await
{ {
return Err(Error::BadRequest(ErrorKind::forbidden(), "You are not in this room.")); return Err!(Request(Forbidden("You are not in this room.")));
} }
if let Typing::Yes(duration) = body.state { if let Typing::Yes(duration) = body.state {
@ -58,5 +62,13 @@ pub(crate) async fn create_typing_event_route(
.await?; .await?;
} }
// ping presence
if services.globals.allow_local_presence() {
services
.presence
.ping_presence(&body.user_id, &ruma::presence::PresenceState::Online)
.await?;
}
Ok(create_typing_event::v3::Response {}) Ok(create_typing_event::v3::Response {})
} }