feat: support concurrent transaction handling

[MonikaCat]

Description

Fixes #64

Checklist

• Targeted PR against correct branch.
• Linked to Github issue with discussion and accepted design OR link to spec that describes this work.
• Wrote unit tests.
• Re-reviewed Files changed in the Github PR explorer.

[huichiaotsou]

tested Ack

[RiccardoM]

I believe this method can be updated to be more similar to handleTx. We just need to un pack the messages first

It would be something like

// inside ExportTxs
sdkMsgs := make(sdk.Msg[], len(tx.Body.Messages)
for i, stdMsg := range tx.Body.Messages {
  var stdMsg sdk.Msg
  err := w.codec.UnpackAny(msg, &stdMsg)
  if err != nil {
    return err 
  }
  sdkMsgs[i] = sdkMsg
}

for i, sdkMsg := range sdkMsgs {
  go w.handleMessage(i, sdkMsg, tx)
}

And then the handleMessage would be

func (w Woker) handleMessage(index int, tx *types.Tx, msg sdk.Msg) {
  for _, module := range w.modules {
    if messageModule, ok := module.(modules.MessageModule); ok {
      err = messageModule.HandleMsg(i, stdMsg, tx)
      if err != nil {
        w.logger.MsgError(module, tx, stdMsg, err)
      }
    }
  }
}

[MonikaCat]

Hey @RiccardoM thanks for that, I updated the code now 👍🏻 Can you review it again pls? thx

[RiccardoM]

Can someone test this code before finally approving it? Maybe @huichiaotsou

[RiccardoM]

Code looks good, we just need to test this to make sure it works properly