debug consensus tx

client_eth.go

@@ -6,11 +6,14 @@ import (
 	"math/big"
 
 	"github.com/ethereum/go-ethereum"
+	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/ethereum/go-ethereum/ethclient"
 
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/crypto"
+
+	"code.wuban.net.cn/multisend/internal/logging"
 )
 
 var toAddress common.Address = common.HexToAddress("0x0071B39fd266F8aeF392fb50F078A233b2218a0b")
@@ -31,6 +34,7 @@ type EthClient struct {
 	GasPrice   *big.Int
 	ChainId    *big.Int
 	GasLimit   uint64
+	logger     logging.Logger
 }
 
 var _ ClientFactory = (*EthClientFactory)(nil)
@@ -61,6 +65,7 @@ func (f *EthClientFactory) NewClient(cfg Config) (Client, error) {
 		PrivateKey: sendTxPrivatekeyAsECDSA,
 		FromAddr:   sendTxFromAddress,
 		NodeUrl:    "http://13.40.31.153:8545",
+		logger:     logging.NewLogrusLogger("EthClient"),
 	}
 
 	cli, err := ethclient.Dial(buildTxParam.NodeUrl)
@@ -117,6 +122,15 @@ func (c *EthClient) GenerateTx() (*types.Transaction, error) {
 			return nil, err
 		}
 
+		data, err := tx.MarshalBinary()
+		if err != nil {
+			return nil, err
+		}
+
+		args := hexutil.Encode(data)
+
+		c.logger.Info("build tx", "nonce", c.Nonce, "TxAsHex", args)
+
 		c.Nonce += 1
 
 		return tx, nil

transactor.go

@@ -285,7 +285,7 @@ func (t *Transactor) sendTransactions() error {
 			args := hexutil.Encode(data)
 			method := "eth_sendRawTransaction"
 
-			t.logger.Info("send tx", "idx", sent, "TxAsHex", args)
+			t.logger.Info("send tx", "idx", sent)
 
 			msg, err := t.newMessage(method, args)
 			if err != nil {