transaction_test.go

package ethadaptor

import (
	"fmt"
	"github.com/stretchr/testify/assert"
	"testing"

	"github.com/palletone/adaptor"
)

func TestGetAddrTxHistoryHttp(t *testing.T) {
	input := &adaptor.GetAddrTxHistoryInput{FromAddress: "0x588eb98f8814aedb056d549c0bafd5ef4963069c", ToAddress: "0x5dcB84Ff1785579440f1b0F84b37f8B54204d5f3", AddressLogicAndOr: true}
	result, err := GetAddrTxHistoryHTTP("https://api-ropsten.etherscan.io/api?apikey=VYSBPQ383RJXM7HBQVTIK5NGIG8ZYVV6T6", input)
	if err != nil {
		fmt.Println(err.Error())
	} else {
		fmt.Println(result.Count)
		for i := range result.Txs {
			fmt.Print("from ", result.Txs[i].FromAddress)
			if result.Txs[i].ToAddress == "" {
				fmt.Print(" create ", result.Txs[i].TargetAddress)
			} else {
				fmt.Print(" to ", result.Txs[i].ToAddress)
			}
			fmt.Print(" value: ", result.Txs[i].Amount.Amount.String())
			fmt.Println(" gasused: ", result.Txs[i].Fee.Amount.String())
		}
	}
}
func TestGetAddrErc20TxHistoryHTTP(t *testing.T) {
	input := &adaptor.GetAddrTxHistoryInput{FromAddress: "0x588eb98f8814aedb056d549c0bafd5ef4963069c", ToAddress: "0x5dcB84Ff1785579440f1b0F84b37f8B54204d5f3", AddressLogicAndOr: true}
	result, err := GetAddrErc20TxHistoryHTTP("https://api-ropsten.etherscan.io/api?apikey=VYSBPQ383RJXM7HBQVTIK5NGIG8ZYVV6T6", input)
	if err != nil {
		fmt.Println(err.Error())
	} else {
		fmt.Println(result.Count)
		for i := range result.Txs {
			fmt.Print("from ", result.Txs[i].FromAddress)
			if result.Txs[i].ToAddress == "" {
				fmt.Print(" create ", result.Txs[i].TargetAddress)
			} else {
				fmt.Print(" to ", result.Txs[i].ToAddress)
			}
			fmt.Print(" value: ", result.Txs[i].Amount.Amount.String())
			fmt.Println(" gasused: ", result.Txs[i].Fee.Amount.String())
		}
	}
}

func TestGetTxBasicInfo(t *testing.T) {
	//input := &adaptor.GetTxBasicInfoInput{Hex2Bytes("61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df ")} //pannz transfer
	//input := &adaptor.GetTxBasicInfoInput{Hex2Bytes("51121d1124fb844132f994ef5067ec73f9bbe92b41c12720ae073401f746dc99")} //eth transfer
	input := &adaptor.GetTxBasicInfoInput{TxID: Hex2Bytes("c927dd7c9fe834575203cdf71bab89bdbaf39c1380f37fcc59ae30a38931881b")} //contract create
	//input := &adaptor.GetTxBasicInfoInput{Hex2Bytes("7e707df7c7ddaaef6f2314fc3cc601154488ed3be8fc9ccc508b87f9b0ab7558 ")} //pending not found

	rpcParams := RPCParams{
		//Rawurl: "https://ropsten.infura.io/", //"\\\\.\\pipe\\geth.ipc",//61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df
		Rawurl: "https://kovan.infura.io/", //"\\\\.\\pipe\\geth.ipc",//61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df
		//Rawurl: "https://mainnet.infura.io/", //"\\\\.\\pipe\\geth.ipc",//fb686ccee357012b8b8f338f8266a472f3c211c82f0a4c30a5d2e51176556546
	}
	result, err := GetTxBasicInfo(input, &rpcParams, NETID_TEST)
	if err != nil {
		fmt.Println(err.Error())
	} else {
		//fmt.Println(result)
		fmt.Println(result.Tx.CreatorAddress)
		fmt.Println(result.Tx.TargetAddress)
		fmt.Println(result.Tx.TxRawData)

		fmt.Println(result.Tx.IsInBlock)
		fmt.Println(result.Tx.IsSuccess)
		fmt.Println(result.Tx.TxIndex)
	}
}

func TestGetTransferTxErc20Transfer(t *testing.T) {
	//input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("51121d1124fb844132f994ef5067ec73f9bbe92b41c12720ae073401f746dc99")} //eth transfer
	//input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("498b634c39fbd19af340d66c8866623c124eb0e2160a45aa433644adc636bedb")} //eth pending transfer
	//input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df")} //pannz transfer
	input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("7d8bb81da859ed086ececda6fbc8a69a0d1264d6fb76790db5b7d617e8ca3eb2")} //pannz transfer
	//input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("0325d73d025a8c8aa73c88303a65b13898e88384f4e153c5bc6466e7f7581e35")} //pannz pending transfer
	//input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("4ef356ce0fc244ffb43cc0a941ca293c5b80e91254ad70474ba27acb9eb7b8fd")} //pannz approve

	//input := &adaptor.GetTransferTxInput{Hex2Bytes("7448307f010d968046bff8a03c6b493dd1b83c9ce6719eca94adb8f59f4a85ea")} //contract create
	//input := &adaptor.GetTransferTxInput{Hex2Bytes("7e707df7c7ddaaef6f2314fc3cc601154488ed3be8fc9ccc508b87f9b0ab7558 ")} //pending not found

	rpcParams := RPCParams{
		Rawurl: "https://ropsten.infura.io/", //"\\\\.\\pipe\\geth.ipc",//61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df
		//Rawurl: "https://mainnet.infura.io/", //"\\\\.\\pipe\\geth.ipc",//fb686ccee357012b8b8f338f8266a472f3c211c82f0a4c30a5d2e51176556546
	}
	result, err := GetTransferTx(input, &rpcParams, NETID_TEST, true)
	assert.Nil(t, err)
	if err != nil {
		fmt.Println(err.Error())
	} else {
		fmt.Println("result:")

		fmt.Println(result.Tx.CreatorAddress)
		fmt.Println(result.Tx.TargetAddress)
		fmt.Println(result.Tx.TxRawData)

		fmt.Println(result.Tx.FromAddress)
		if result.Tx.ToAddress == "" {
			fmt.Println("contract create")
		} else {
			fmt.Println(result.Tx.ToAddress)
		}
		fmt.Println(result.Tx.IsSuccess)
		fmt.Println(result.Tx.Amount.Amount.String())
		fmt.Println(result.Tx.BlockHeight)
	}
}

func TestGetContractInitialTx(t *testing.T) {
	input := &adaptor.GetContractInitialTxInput{TxID: Hex2Bytes("7448307f010d968046bff8a03c6b493dd1b83c9ce6719eca94adb8f59f4a85ea")} //contract create

	rpcParams := RPCParams{
		Rawurl: "https://ropsten.infura.io/", //"\\\\.\\pipe\\geth.ipc",//61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df
		//Rawurl: "https://mainnet.infura.io/", //"\\\\.\\pipe\\geth.ipc",//fb686ccee357012b8b8f338f8266a472f3c211c82f0a4c30a5d2e51176556546
	}
	result, err := GetContractInitialTx(input, &rpcParams, NETID_TEST)
	if err != nil {
		fmt.Println(err.Error())
	} else {
		//fmt.Println(result)

		fmt.Println(result.CreatorAddress)
		fmt.Println(result.TargetAddress)
		fmt.Println(result.TxRawData)

		fmt.Println(result.ContractAddress)
	}
}

func TestGetBlockInfo(t *testing.T) {
	rpcParams := RPCParams{
		Rawurl: "https://ropsten.infura.io/", //"\\\\.\\pipe\\geth.ipc",
	}
	input := &adaptor.GetBlockInfoInput{}

	//
	result, err := GetBlockInfo(input, &rpcParams)
	if err != nil {
		fmt.Println(err.Error())
	} else {
		fmt.Println(result)
	}
}
func TestGetTransferTxFromErc20ApproveMethod(t *testing.T) {
	input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("4ef356ce0fc244ffb43cc0a941ca293c5b80e91254ad70474ba27acb9eb7b8fd ")} //erc20 approve

	rpcParams := RPCParams{
		Rawurl: "https://ropsten.infura.io/", //"\\\\.\\pipe\\geth.ipc",//61cded704bd23d8ff7cbe0ac4b62b940bd76f3709f784db695c95efa8074b7df
	}
	result, err := GetTransferTx(input, &rpcParams, NETID_TEST, true)
	assert.NotNil(t, err)
	assert.Nil(t, result)
	t.Log(err.Error())
}

func TestGetTransferTxFromInvalidTx(t *testing.T) {
	input := &adaptor.GetTransferTxInput{TxID: Hex2Bytes("000000000000000000000000000 ")} //eth transfer

	rpcParams := RPCParams{
		Rawurl: "https://ropsten.infura.io/",
	}
	result, err := GetTransferTx(input, &rpcParams, NETID_TEST, false)
	assert.NotNil(t, err)
	assert.Nil(t, result)
	t.Log(err.Error())
}