add more logs for transaction and pool

node/node.go

@@ -286,6 +286,9 @@ func addPendingTransactions(registry *registry.Registry, newTxs types.Transactio
 				continue
 			}
 		}
+		utils.Logger().Debug().
+			Str("tx_hash", tx.Hash().Hex()).
+			Msg("[addPendingTransactions] tx is added to the txs pool array")
 		poolTxs = append(poolTxs, tx)
 	}
 	errs = append(errs, registry.GetTxPool().AddRemotes(poolTxs)...)
@@ -305,6 +308,9 @@ func (node *Node) addPendingStakingTransactions(newStakingTxs staking.StakingTra
 		if node.Blockchain().Config().IsPreStaking(node.Blockchain().CurrentHeader().Epoch()) {
 			poolTxs := types.PoolTransactions{}
 			for _, tx := range newStakingTxs {
+				utils.Logger().Debug().
+					Str("tx_hash", tx.Hash().Hex()).
+					Msg("[addPendingStakingTransactions] tx is added to the txs pool array")
 				poolTxs = append(poolTxs, tx)
 			}
 			errs := node.TxPool.AddRemotes(poolTxs)

node/node_newblock.go

@@ -175,14 +175,17 @@ func (node *Node) ProposeNewBlock(commitSigs chan []byte) (*types.Block, error)
 			plainTxsPerAcc := types.Transactions{}
 			for _, tx := range poolTxs {
 				if plainTx, ok := tx.(*types.Transaction); ok {
+					utils.Logger().Info().Str("tx_hash", tx.Hash().Hex()).Msg("add transaction to proposing block")
 					plainTxsPerAcc = append(plainTxsPerAcc, plainTx)
 				} else if stakingTx, ok := tx.(*staking.StakingTransaction); ok {
 					// Only process staking transactions after pre-staking epoch happened.
 					if node.Blockchain().Config().IsPreStaking(node.Worker.GetCurrentHeader().Epoch()) {
+						utils.Logger().Info().Str("tx_hash", tx.Hash().Hex()).Msg("add staking transaction to proposing block")
 						pendingStakingTxs = append(pendingStakingTxs, stakingTx)
 					}
 				} else {
 					utils.Logger().Err(types.ErrUnknownPoolTxType).
+						Str("tx_hash", tx.Hash().Hex()).
 						Msg("Failed to parse pending transactions")
 					return nil, types.ErrUnknownPoolTxType
 				}