2024-07-16 08:05:25 +00:00
|
|
|
use axum::extract::State;
|
2025-01-24 07:02:56 +00:00
|
|
|
use conduwuit::{utils::math::Tried, Err};
|
2024-12-15 02:53:32 -05:00
|
|
|
use ruma::api::client::typing::create_typing_event;
|
2020-07-30 18:14:47 +02:00
|
|
|
|
2024-12-15 02:53:32 -05:00
|
|
|
use crate::{utils, Result, Ruma};
|
2024-03-05 19:48:54 -05:00
|
|
|
|
2021-08-31 19:14:37 +02:00
|
|
|
/// # `PUT /_matrix/client/r0/rooms/{roomId}/typing/{userId}`
|
|
|
|
///
|
|
|
|
/// Sets the typing state of the sender user.
|
2024-04-22 23:48:57 -04:00
|
|
|
pub(crate) async fn create_typing_event_route(
|
2024-12-15 00:05:47 -05:00
|
|
|
State(services): State<crate::State>,
|
|
|
|
body: Ruma<create_typing_event::v3::Request>,
|
2022-02-18 15:33:14 +01:00
|
|
|
) -> Result<create_typing_event::v3::Response> {
|
2024-03-05 19:48:54 -05:00
|
|
|
use create_typing_event::v3::Typing;
|
2024-12-15 02:53:32 -05:00
|
|
|
let sender_user = body.sender_user();
|
2022-02-18 15:33:14 +01:00
|
|
|
|
2024-12-15 02:53:32 -05:00
|
|
|
if sender_user != body.user_id && body.appservice_info.is_none() {
|
|
|
|
return Err!(Request(Forbidden("You cannot update typing status of other users.")));
|
|
|
|
}
|
2020-07-30 18:14:47 +02:00
|
|
|
|
2024-07-16 08:05:25 +00:00
|
|
|
if !services
|
2024-03-25 17:05:11 -04:00
|
|
|
.rooms
|
|
|
|
.state_cache
|
2024-08-08 17:18:30 +00:00
|
|
|
.is_joined(sender_user, &body.room_id)
|
|
|
|
.await
|
2024-03-25 17:05:11 -04:00
|
|
|
{
|
2024-12-15 02:53:32 -05:00
|
|
|
return Err!(Request(Forbidden("You are not in this room.")));
|
2024-03-05 19:48:54 -05:00
|
|
|
}
|
2022-03-23 11:05:41 +01:00
|
|
|
|
2024-03-05 19:48:54 -05:00
|
|
|
if let Typing::Yes(duration) = body.state {
|
2024-03-29 18:35:02 -07:00
|
|
|
let duration = utils::clamp(
|
2024-05-03 21:42:47 -04:00
|
|
|
duration.as_millis().try_into().unwrap_or(u64::MAX),
|
2024-07-16 08:05:25 +00:00
|
|
|
services
|
2025-01-24 07:02:56 +00:00
|
|
|
.server
|
2024-05-03 21:42:47 -04:00
|
|
|
.config
|
|
|
|
.typing_client_timeout_min_s
|
2025-01-24 07:02:56 +00:00
|
|
|
.try_mul(1000)?,
|
2024-07-16 08:05:25 +00:00
|
|
|
services
|
2025-01-24 07:02:56 +00:00
|
|
|
.server
|
2024-05-03 21:42:47 -04:00
|
|
|
.config
|
|
|
|
.typing_client_timeout_max_s
|
2025-01-24 07:02:56 +00:00
|
|
|
.try_mul(1000)?,
|
2024-03-29 18:35:02 -07:00
|
|
|
);
|
2024-07-16 08:05:25 +00:00
|
|
|
services
|
2024-03-08 10:05:48 -05:00
|
|
|
.rooms
|
|
|
|
.typing
|
2024-05-03 21:42:47 -04:00
|
|
|
.typing_add(
|
|
|
|
sender_user,
|
|
|
|
&body.room_id,
|
|
|
|
utils::millis_since_unix_epoch()
|
|
|
|
.checked_add(duration)
|
|
|
|
.expect("user typing timeout should not get this high"),
|
|
|
|
)
|
2024-03-08 10:05:48 -05:00
|
|
|
.await?;
|
2024-03-05 19:48:54 -05:00
|
|
|
} else {
|
2024-07-16 08:05:25 +00:00
|
|
|
services
|
2024-03-25 17:05:11 -04:00
|
|
|
.rooms
|
|
|
|
.typing
|
|
|
|
.typing_remove(sender_user, &body.room_id)
|
|
|
|
.await?;
|
2024-03-05 19:48:54 -05:00
|
|
|
}
|
2020-07-30 18:14:47 +02:00
|
|
|
|
2024-12-15 02:53:32 -05:00
|
|
|
// ping presence
|
|
|
|
if services.globals.allow_local_presence() {
|
|
|
|
services
|
|
|
|
.presence
|
|
|
|
.ping_presence(&body.user_id, &ruma::presence::PresenceState::Online)
|
|
|
|
.await?;
|
|
|
|
}
|
|
|
|
|
2024-03-05 19:48:54 -05:00
|
|
|
Ok(create_typing_event::v3::Response {})
|
2020-07-30 18:14:47 +02:00
|
|
|
}
|