Skip to content

Commit 05ed1c9

Browse files
committed
(experimental) dispatcher: diagnostic logs
1 parent 9a86431 commit 05ed1c9

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

runtime-sdk/src/dispatcher.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,9 @@ impl<R: Runtime> Dispatcher<R> {
342342
data: &IncomingMessageData,
343343
tx: &Option<Transaction>,
344344
) -> Result<(), RuntimeError> {
345+
warn!(ctx.get_logger("dispatcher"), "incoming message executing"; "id" => in_msg.id); // %%%
345346
R::Modules::execute_in_msg(ctx, in_msg, data, tx)?;
347+
warn!(ctx.get_logger("dispatcher"), "incoming message modules done"; "id" => in_msg.id); // %%%
346348
if let Some(tx) = tx {
347349
let tx_size = match data
348350
.ut
@@ -360,7 +362,11 @@ impl<R: Runtime> Dispatcher<R> {
360362
// Use the ID as index.
361363
let index = in_msg.id.try_into().unwrap();
362364
// todo: put result tags in block
363-
Self::execute_tx(ctx, tx_size, tx.clone(), index)?;
365+
let result = Self::execute_tx(ctx, tx_size, tx.clone(), index)?;
366+
let result_parsed = cbor::from_slice::<crate::types::transaction::CallResult>(&result.output).unwrap();
367+
warn!(ctx.get_logger("dispatcher"), "incoming message transaction done"; "id" => in_msg.id, "result_parsed" => ?result_parsed); // %%%
368+
} else {
369+
warn!(ctx.get_logger("dispatcher"), "incoming message no transaction"; "id" => in_msg.id); // %%%
364370
}
365371
Ok(())
366372
}

0 commit comments

Comments
 (0)