update balance of txs

modules/bank/handle_block.go

@@ -17,12 +17,13 @@ import (
 func (m *Module) HandleBlock(
 	block *tmctypes.ResultBlock, res *tmctypes.ResultBlockResults, _ []*juno.Transaction, _ *tmctypes.ResultValidators,
 ) error {
+	m.updateBalanceByTxEvent(block.Block.Height, res.TxsResults)
 
-	// Remove expired fee grant allowances
 	err := m.updateBalanceByEvent(block.Block.Height, res.FinalizeBlockEvents)
 	if err != nil {
-		fmt.Printf("Error when removing expired fee grant allowance, error: %s", err)
+		fmt.Printf("Error when update balance by end block: %s", err)
 	}
+
 	return nil
 }
 
@@ -76,13 +77,26 @@ func (m *Module) updateBalanceByEvent(height int64, events []abci.Event) error {
 	for address := range setAddr {
 		addresses = append(addresses, address)
 	}
-
 	if len(addresses) == 0 {
 		return nil
 	}
 	return m.UpdateBalance(addresses, height)
 }
 
+// removeExpiredFeeGrantAllowances removes fee grant allowances in database that have expired
+func (m *Module) updateBalanceByTxEvent(height int64, txs []*abci.ExecTxResult) {
+	log.Debug().Str("module", "bank").Int64("height", height).
+		Msg("updating balance by tx event")
+
+	for _, tx := range txs {
+		events := tx.Events
+		err := m.updateBalanceByEvent(height, events)
+		if err != nil {
+			fmt.Printf("Error when update balance inside tx events: %s", err)
+		}
+	}
+}
+
 func (m *Module) UpdateBalance(addresses []string, height int64) error {
 	log.Trace().Str("module", "bank").Str("operation", "account balance").
 		Msg("updating account balance")