diff --git a/app/ship_processor.go b/app/ship_processor.go index 4c6b8cc..44c916e 100644 --- a/app/ship_processor.go +++ b/app/ship_processor.go @@ -94,9 +94,9 @@ func (processor *ShipProcessor) processTraces(traces []*ship.TransactionTraceV0) act := message.ActionTrace{ TxID: trace.ID.String(), - Receiver: act_trace.Receiver.String(), + Name: act_trace.Act.Name.String(), Contract: act_trace.Act.Account.String(), - Action: act_trace.Act.Name.String(), + Receiver: act_trace.Receiver.String(), HexData: hex.EncodeToString(act_trace.Act.Data), } @@ -118,9 +118,9 @@ func (processor *ShipProcessor) processTraces(traces []*ship.TransactionTraceV0) channels := []transport.Channel{ transport.Action{}.Channel(), - transport.Action{Action: act.Action}.Channel(), + transport.Action{Action: act.Name}.Channel(), transport.Action{Contract: act.Contract}.Channel(), - transport.Action{Action: act.Action, Contract: act.Contract}.Channel(), + transport.Action{Action: act.Name, Contract: act.Contract}.Channel(), } for _, channel := range channels { diff --git a/transport/message/types.go b/transport/message/types.go index 9bb40c9..a12ccb1 100644 --- a/transport/message/types.go +++ b/transport/message/types.go @@ -7,10 +7,15 @@ type HearthBeat struct { } type ActionTrace struct { - TxID string `json:"tx_id"` + TxID string `json:"tx_id"` + + // Action name + Name string `json:"name"` + + // Contract account. + Contract string `json:"contract"` + Receiver string `json:"receiver"` - Contract string `json:"contract"` - Action string `json:"action"` Data interface{} `json:"data"` HexData string `json:"hex_data"` }