Mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2026-05-26 20:49:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Instrument process_inbound_transaction

Browse Source
This commit is contained in:
nexy7574
2026-02-23 16:36:45 +00:00
committed by timedout
parent 0d8cafc329
commit 470c9b52dd
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/api/server/send.rs
+9
View File
@@ -40,6 +40,7 @@ use ruma::{
}; };
use service::transaction_ids::{TxnKey, WrappedTransactionResponse}; use service::transaction_ids::{TxnKey, WrappedTransactionResponse};
use tokio::sync::watch::{Receiver, Sender}; use tokio::sync::watch::{Receiver, Sender};
use tracing::instrument;
use crate::Ruma; use crate::Ruma;
@@ -118,6 +119,14 @@ async fn wait_for_result(
Ok(value.clone().expect("channel returned with no value?")) Ok(value.clone().expect("channel returned with no value?"))
} }
#[instrument(
level = "info",
skip_all,
fields(
id = ?body.transaction_id.as_str(),
origin = ?body.origin()
)
)]
async fn process_inbound_transaction( async fn process_inbound_transaction(
services: crate::State, services: crate::State,
body: Ruma<send_transaction_message::v1::Request>, body: Ruma<send_transaction_message::v1::Request>,