eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-17 04:30:03 +02:00
Code Releases Activity

app/ship_processor.go: Log tx_id when processing trace.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-05-17 10:57:51 +02:00
parent 03ab664130
commit d9684fcceb
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
app/ship_processor.go
View file

@ -126,6 +126,8 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
if block.Traces != nil && len(block.Traces.Elem) > 0 {
for _, trace := range block.Traces.AsTransactionTracesV0() {
logger := log.WithField("tx_id", trace.ID.String())
processor.encodeQueue(api.TransactionChannel, trace)
// Actions
@ -156,7 +158,7 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
if act_trace.Act.Account == processor.syscontract && act_trace.Act.Name == eos.ActionName("setabi") {
err := processor.updateAbiFromAction(act_trace.Act)
if err != nil {
log.WithError(err).Warn("Failed to update abi")
logger.WithError(err).Warn("Failed to update abi")
}
}
@ -179,10 +181,10 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
ABI, err := processor.abi.GetAbi(act_trace.Act.Account)
if err == nil {
if err = decode(ABI, act_trace.Act, &act.Data); err != nil {
log.WithError(err).Warn("Failed to decode action")
logger.WithError(err).Warn("Failed to decode action")
}
} else {
log.WithError(err).Errorf("Failed to get abi for contract %s", act_trace.Act.Account)
logger.WithError(err).Errorf("Failed to get abi for contract %s", act_trace.Act.Account)
}
payload, err := processor.encode(act)