git-mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-07-06 22:06:11 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

reference service

Browse source
This commit is contained in:
Jade Ellis 2025-01-03 20:15:02 +00:00
parent bd52d4c5b0
commit 95c556d5a7
No known key found for this signature in database
GPG key ID: 8705A2A3EBF77BD2
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/api/client/sync/v3.rs
View file

@ -124,7 +124,7 @@ pub(crate) async fn sync_events_route(
// Setup watchers, so if there's no response, we can wait for them // Setup watchers, so if there's no response, we can wait for them
let watcher = services.sync.watch(sender_user, sender_device); let watcher = services.sync.watch(sender_user, sender_device);
let response = build_sync_events(services, &body).await?; let response = build_sync_events(&services, &body).await?;
if body.body.full_state if body.body.full_state
|| !(response.rooms.is_empty() || !(response.rooms.is_empty()
&& response.presence.is_empty() && response.presence.is_empty()
@ -142,11 +142,11 @@ pub(crate) async fn sync_events_route(
_ = tokio::time::timeout(duration, watcher).await; _ = tokio::time::timeout(duration, watcher).await;
// Retry returning data // Retry returning data
build_sync_events(services, &body).await build_sync_events(&services, &body).await
} }
pub(crate) async fn build_sync_events( pub(crate) async fn build_sync_events(
services: crate::State, services: &Services,
body: &Ruma<sync_events::v3::Request>, body: &Ruma<sync_events::v3::Request>,
) -> Result<sync_events::v3::Response, RumaResponse<UiaaResponse>> { ) -> Result<sync_events::v3::Response, RumaResponse<UiaaResponse>> {
let (sender_user, sender_device) = body.sender(); let (sender_user, sender_device) = body.sender();