fix: also return successful PDUs in /send/:txnId
@@ -628,7 +628,9 @@ pub async fn send_transaction_message_route<'a>(
};
let start_time = Instant::now();
- if let Err(e) = handle_incoming_pdu(
+ resolved_map.insert(
+ event_id.clone(),
+ handle_incoming_pdu(
&body.origin,
&event_id,
value,
@@ -638,9 +640,8 @@ pub async fn send_transaction_message_route<'a>(
&mut auth_cache,
)
.await
- {
- resolved_map.insert(event_id.clone(), Err(e));
- }
+ .map(|_| ()),
+ );
let elapsed = start_time.elapsed();
if elapsed > Duration::from_secs(1) {
