|
|
|
@ -130,6 +130,7 @@ pub async fn sync_events_route( |
|
|
|
result |
|
|
|
result |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#[tracing::instrument(skip(db, tx))] |
|
|
|
async fn sync_helper_wrapper( |
|
|
|
async fn sync_helper_wrapper( |
|
|
|
db: Arc<DatabaseGuard>, |
|
|
|
db: Arc<DatabaseGuard>, |
|
|
|
sender_user: UserId, |
|
|
|
sender_user: UserId, |
|
|
|
@ -176,6 +177,7 @@ async fn sync_helper_wrapper( |
|
|
|
|
|
|
|
|
|
|
|
const THIRTY_SECONDS: Duration = Duration::from_secs(30); |
|
|
|
const THIRTY_SECONDS: Duration = Duration::from_secs(30); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#[tracing::instrument(skip(db))] |
|
|
|
async fn sync_helper( |
|
|
|
async fn sync_helper( |
|
|
|
db: &Database, |
|
|
|
db: &Database, |
|
|
|
sender_user: &UserId, |
|
|
|
sender_user: &UserId, |
|
|
|
@ -230,6 +232,7 @@ async fn sync_helper( |
|
|
|
Ok((response, since != next_batch)) |
|
|
|
Ok((response, since != next_batch)) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#[tracing::instrument(skip(db))] |
|
|
|
fn collect_response( |
|
|
|
fn collect_response( |
|
|
|
db: &Database, |
|
|
|
db: &Database, |
|
|
|
since: u64, |
|
|
|
since: u64, |
|
|
|
|