fix: remove transaction_id from pdus over federation
parent
b7ab57897b
commit
1bf614b0f5
|
@ -36,6 +36,12 @@ impl Sending {
|
||||||
let pdu_id = parts.next().ok_or_else(|| Error::bad_database("Invalid serverpduid in db."))?;
|
let pdu_id = parts.next().ok_or_else(|| Error::bad_database("Invalid serverpduid in db."))?;
|
||||||
let mut pdu_json = rooms.get_pdu_json_from_id(&pdu_id.into())?.ok_or_else(|| Error::bad_database("Event in serverpduids not found in db."))?;
|
let mut pdu_json = rooms.get_pdu_json_from_id(&pdu_id.into())?.ok_or_else(|| Error::bad_database("Event in serverpduids not found in db."))?;
|
||||||
|
|
||||||
|
if let Some(unsigned) = pdu_json
|
||||||
|
.as_object_mut()
|
||||||
|
.expect("json is object")
|
||||||
|
.get_mut("unsigned") {
|
||||||
|
unsigned.as_object_mut().expect("unsigned is object").remove("transaction_id");
|
||||||
|
}
|
||||||
pdu_json
|
pdu_json
|
||||||
.as_object_mut()
|
.as_object_mut()
|
||||||
.expect("json is object")
|
.expect("json is object")
|
||||||
|
|
|
@ -201,6 +201,9 @@ impl PduEvent {
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn to_outgoing_federation_event(&self) -> Raw<PduStub> {
|
pub fn to_outgoing_federation_event(&self) -> Raw<PduStub> {
|
||||||
|
let mut unsigned = self.unsigned.clone();
|
||||||
|
unsigned.remove("transaction_id");
|
||||||
|
|
||||||
let mut json = json!({
|
let mut json = json!({
|
||||||
"room_id": self.room_id,
|
"room_id": self.room_id,
|
||||||
"sender": self.sender,
|
"sender": self.sender,
|
||||||
|
@ -210,7 +213,7 @@ impl PduEvent {
|
||||||
"prev_events": self.prev_events,
|
"prev_events": self.prev_events,
|
||||||
"depth": self.depth,
|
"depth": self.depth,
|
||||||
"auth_events": self.auth_events,
|
"auth_events": self.auth_events,
|
||||||
"unsigned": self.unsigned,
|
"unsigned": unsigned,
|
||||||
"hashes": self.hashes,
|
"hashes": self.hashes,
|
||||||
"signatures": self.signatures,
|
"signatures": self.signatures,
|
||||||
});
|
});
|
||||||
|
|
Loading…
Reference in New Issue