1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-07-28 02:38:30 +00:00
continuwuity/src/api/client_server/typing.rs

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

44 lines
1.2 KiB
Rust
Raw Normal View History

2022-04-07 17:09:07 +02:00
use ruma::api::client::{error::ErrorKind, typing::create_typing_event};
2020-07-30 18:14:47 +02:00
2022-10-05 20:34:31 +02:00
use crate::{services, utils, Error, Result, Ruma};
2021-08-31 19:14:37 +02:00
/// # `PUT /_matrix/client/r0/rooms/{roomId}/typing/{userId}`
///
/// Sets the typing state of the sender user.
pub(crate) async fn create_typing_event_route(
2022-12-14 13:09:10 +01:00
body: Ruma<create_typing_event::v3::Request>,
2022-02-18 15:33:14 +01:00
) -> Result<create_typing_event::v3::Response> {
use create_typing_event::v3::Typing;
let sender_user = body.sender_user.as_ref().expect("user is authenticated");
2020-07-30 18:14:47 +02:00
if !services()
.rooms
.state_cache
.is_joined(sender_user, &body.room_id)?
{
return Err(Error::BadRequest(ErrorKind::forbidden(), "You are not in this room."));
}
2020-09-08 17:32:03 +02:00
if let Typing::Yes(duration) = body.state {
let duration = utils::clamp(
duration.as_millis() as u64,
services().globals.config.typing_client_timeout_min_s * 1000,
services().globals.config.typing_client_timeout_max_s * 1000,
);
services()
.rooms
.typing
.typing_add(sender_user, &body.room_id, utils::millis_since_unix_epoch() + duration)
.await?;
2020-07-30 18:14:47 +02:00
} else {
services()
.rooms
.typing
.typing_remove(sender_user, &body.room_id)
.await?;
2020-07-30 18:14:47 +02:00
}
2022-02-18 15:33:14 +01:00
Ok(create_typing_event::v3::Response {})
2020-07-30 18:14:47 +02:00
}