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: Post transaction message using message.Transaction struct.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-06-26 16:08:12 +02:00
parent 547d53a6a2
commit f7c3d30e8e
1 changed files with 17 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

18
app/ship_processor.go
View file

@ -128,7 +128,19 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
logger := log.WithField("tx_id", trace.ID.String())
processor.encodeQueue(api.TransactionChannel, trace)
transaction := message.TransactionTrace{
ID: trace.ID.String(),
BlockNum: block.Block.BlockNumber(),
Timestamp: block.Block.Timestamp.Time.UTC(),
Status: trace.Status.String(),
CPUUsageUS: trace.CPUUsageUS,
NetUsage: trace.NetUsage,
NetUsageWords: uint32(trace.NetUsageWords),
Elapsed: int64(trace.Elapsed),
Scheduled: trace.Scheduled,
Except: trace.Except,
Error: trace.ErrorCode,
}
// Actions
for _, actionTraceVar := range trace.ActionTraces {
@ -215,6 +227,8 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
continue
}
transaction.ActionTraces = append(transaction.ActionTraces, act)
channels := []api.Channel{
api.ActionChannel{}.Channel(),
api.ActionChannel{Name: act.Name}.Channel(),
@ -226,6 +240,8 @@ func (processor *ShipProcessor) processBlock(block *ship.GetBlocksResultV0) {
processor.queueMessage(channel, payload)
}
}
processor.encodeQueue(api.TransactionChannel, transaction)
}
}