TudbuT/conduit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

handle GetRemotePdu response as backfilled PDU

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2024-03-13 23:45:37 -04:00 • committed by June
parent 6c9f47a968
commit f1507a4522
1 changed files with 4 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
src/service/admin/mod.rs
View file

@ -2020,40 +2020,21 @@ impl Service {
warn!("Could not fetch all signatures for PDUs from {server}: {e:?}");
});
info!("Attempting to handle event ID {event_id} as incoming PDU");
for (event_id, value, room_id) in parsed_pdu {
let mutex = Arc::clone(
services()
.globals
.roomid_mutex_federation
.write()
.await
.entry(room_id.clone())
.or_default(),
);
let mutex_lock = mutex.lock().await;
services()
.rooms
.event_handler
.handle_incoming_pdu(&server, &event_id, &room_id, value, false, &pub_key_map)
.await?;
drop(mutex_lock);
}
info!("Attempting to handle event ID {event_id} as backfilled PDU");
services().rooms.timeline.backfill_pdu(&server, response.pdu, &pub_key_map).await?;
let json_text = serde_json::to_string_pretty(&json).expect("canonical json is valid json");
return Ok(RoomMessageEventContent::text_html(
format!(
"{}\n```json\n{}\n```",
"Got PDU from specified server and handled as incoming PDU successfully. Event \
"Got PDU from specified server and handled as backfilled PDU successfully. Event \
body:",
json_text
),
format!(
"<p>{}</p>\n<pre><code class=\"language-json\">{}\n</code></pre>\n",
"Got PDU from specified server and handled as incoming PDU successfully. Event \
"Got PDU from specified server and handled as backfilled PDU successfully. Event \
body:",
HtmlEscape(&json_text)
),