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

add outgoing federation typing and conf items

Browse source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2024-03-29 18:35:02 -07:00 • committed by June
parent 4a57592378
commit 18c34434bc
5 changed files with 105 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/api/client_server/typing.rs
View file

@ -21,15 +21,16 @@ pub async fn create_typing_event_route(
}
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
.edus
.typing
.typing_add(
sender_user,
&body.room_id,
duration.as_millis() as u64 + utils::millis_since_unix_epoch(),
)
.typing_add(sender_user, &body.room_id, utils::millis_since_unix_epoch() + duration)
.await?;
} else {
services()

8
src/api/server_server.rs
View file

@ -956,17 +956,23 @@ pub async fn send_transaction_message_route(
}
},
Edu::Typing(typing) => {
if !services().globals.config.allow_incoming_typing {
continue;
}
if services()
.rooms
.state_cache
.is_joined(&typing.user_id, &typing.room_id)?
{
if typing.typing {
let timeout = utils::millis_since_unix_epoch()
+ services().globals.config.typing_federation_timeout_s * 1000;
services()
.rooms
.edus
.typing
.typing_add(&typing.user_id, &typing.room_id, 3000 + utils::millis_since_unix_epoch())
.typing_add(&typing.user_id, &typing.room_id, timeout)
.await?;
} else {
services()