Skip to content

Commit

Permalink
add example to create Tx use golang native
Browse files Browse the repository at this point in the history
  • Loading branch information
@bxq2011hust
bxq2011hust committed Dec 25, 2024
1 parent 3f04d07 commit cec73d4
Show file tree
Hide file tree
Showing 4 changed files with 224 additions and 14 deletions.
2 changes: 1 addition & 1 deletion .ci/integration_test.sh
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
set -e

c_sdk_version="v3.7.0"
chain_version="v3.7.3"
chain_version="v3.12.2"
start_time=15
macOS=
ldflags="-ldflags=\"-r /usr/local/lib/\""
Expand Down
211 changes: 211 additions & 0 deletions v3/examples/hello_world/manual_native/main.go
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,211 @@
package main

import (
"context"
"encoding/hex"
"fmt"
"log"
"math/big"
"strings"
"sync"
"time"

"github.com/FISCO-BCOS/go-sdk/v3/abi"
"github.com/FISCO-BCOS/go-sdk/v3/abi/bind"
"github.com/FISCO-BCOS/go-sdk/v3/client"
"github.com/FISCO-BCOS/go-sdk/v3/types"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/crypto"
"github.com/google/uuid"
)

// HelloWorldABI is the input ABI used to generate the binding from.
const HelloWorldABI = "[{\"inputs\":[{\"internalType\":\"string\",\"name\":\"initValue\",\"type\":\"string\"}],\"stateMutability\":\"nonpayable\",\"type\":\"constructor\"},{\"anonymous\":false,\"inputs\":[{\"indexed\":false,\"internalType\":\"string\",\"name\":\"v\",\"type\":\"string\"},{\"indexed\":true,\"internalType\":\"address\",\"name\":\"from\",\"type\":\"address\"},{\"indexed\":true,\"internalType\":\"address\",\"name\":\"to\",\"type\":\"address\"},{\"indexed\":false,\"internalType\":\"int256\",\"name\":\"value\",\"type\":\"int256\"}],\"name\":\"setValue\",\"type\":\"event\"},{\"inputs\":[],\"name\":\"get\",\"outputs\":[{\"internalType\":\"string\",\"name\":\"\",\"type\":\"string\"}],\"stateMutability\":\"view\",\"type\":\"function\"},{\"inputs\":[{\"internalType\":\"string\",\"name\":\"v\",\"type\":\"string\"}],\"name\":\"set\",\"outputs\":[{\"internalType\":\"string\",\"name\":\"\",\"type\":\"string\"}],\"stateMutability\":\"nonpayable\",\"type\":\"function\"},{\"inputs\":[],\"name\":\"version\",\"outputs\":[{\"internalType\":\"int256\",\"name\":\"\",\"type\":\"int256\"}],\"stateMutability\":\"view\",\"type\":\"function\"}]"

// HelloWorldBin is the compiled bytecode used for deploying new contracts.
var HelloWorldBin = "0x60806040523480156200001157600080fd5b50604051620009fd380380620009fd8339818101604052810190620000379190620002ac565b80600090805190602001906200004f9291906200005f565b5060006001819055505062000362565b8280546200006d906200032c565b90600052602060002090601f016020900481019282620000915760008555620000dd565b82601f10620000ac57805160ff1916838001178555620000dd565b82800160010185558215620000dd579182015b82811115620000dc578251825591602001919060010190620000bf565b5b509050620000ec9190620000f0565b5090565b5b808211156200010b576000816000905550600101620000f1565b5090565b6000604051905090565b600080fd5b600080fd5b600080fd5b600080fd5b6000601f19601f8301169050919050565b7f4e487b7100000000000000000000000000000000000000000000000000000000600052604160045260246000fd5b62000178826200012d565b810181811067ffffffffffffffff821117156200019a57620001996200013e565b5b80604052505050565b6000620001af6200010f565b9050620001bd82826200016d565b919050565b600067ffffffffffffffff821115620001e057620001df6200013e565b5b620001eb826200012d565b9050602081019050919050565b60005b8381101562000218578082015181840152602081019050620001fb565b8381111562000228576000848401525b50505050565b6000620002456200023f84620001c2565b620001a3565b90508281526020810184848401111562000264576200026362000128565b5b62000271848285620001f8565b509392505050565b600082601f83011262000291576200029062000123565b5b8151620002a38482602086016200022e565b91505092915050565b600060208284031215620002c557620002c462000119565b5b600082015167ffffffffffffffff811115620002e657620002e56200011e565b5b620002f48482850162000279565b91505092915050565b7f4e487b7100000000000000000000000000000000000000000000000000000000600052602260045260246000fd5b600060028204905060018216806200034557607f821691505b602082108114156200035c576200035b620002fd565b5b50919050565b61068b80620003726000396000f3fe608060405234801561001057600080fd5b50600436106100415760003560e01c80634ed3885e1461004657806354fd4d50146100765780636d4ce63c14610094575b600080fd5b610060600480360381019061005b9190610387565b6100b2565b60405161006d919061046d565b60405180910390f35b61007e6101dd565b60405161008b91906104a8565b60405180910390f35b61009c6101e3565b6040516100a9919061046d565b60405180910390f35b606060008080546100c2906104f2565b80601f01602080910402602001604051908101604052809291908181526020018280546100ee906104f2565b801561013b5780601f106101105761010080835404028352916020019161013b565b820191906000526020600020905b81548152906001019060200180831161011e57829003601f168201915b50505050509050838360009190610153929190610275565b50600180546101629190610553565b6001819055503373ffffffffffffffffffffffffffffffffffffffff163273ffffffffffffffffffffffffffffffffffffffff167fc3bf5911f8e0476e774566ef3fa1259f04156ba5c61ea5ff35c0201390381f9686866001546040516101cb93929190610623565b60405180910390a38091505092915050565b60015481565b6060600080546101f2906104f2565b80601f016020809104026020016040519081016040528092919081815260200182805461021e906104f2565b801561026b5780601f106102405761010080835404028352916020019161026b565b820191906000526020600020905b81548152906001019060200180831161024e57829003601f168201915b5050505050905090565b828054610281906104f2565b90600052602060002090601f0160209004810192826102a357600085556102ea565b82601f106102bc57803560ff19168380011785556102ea565b828001600101855582156102ea579182015b828111156102e95782358255916020019190600101906102ce565b5b5090506102f791906102fb565b5090565b5b808211156103145760008160009055506001016102fc565b5090565b600080fd5b600080fd5b600080fd5b600080fd5b600080fd5b60008083601f84011261034757610346610322565b5b8235905067ffffffffffffffff81111561036457610363610327565b5b6020830191508360018202830111156103805761037f61032c565b5b9250929050565b6000806020838503121561039e5761039d610318565b5b600083013567ffffffffffffffff8111156103bc576103bb61031d565b5b6103c885828601610331565b92509250509250929050565b600081519050919050565b600082825260208201905092915050565b60005b8381101561040e5780820151818401526020810190506103f3565b8381111561041d576000848401525b50505050565b6000601f19601f8301169050919050565b600061043f826103d4565b61044981856103df565b93506104598185602086016103f0565b61046281610423565b840191505092915050565b600060208201905081810360008301526104878184610434565b905092915050565b6000819050919050565b6104a28161048f565b82525050565b60006020820190506104bd6000830184610499565b92915050565b7f4e487b7100000000000000000000000000000000000000000000000000000000600052602260045260246000fd5b6000600282049050600182168061050a57607f821691505b6020821081141561051e5761051d6104c3565b5b50919050565b7f4e487b7100000000000000000000000000000000000000000000000000000000600052601160045260246000fd5b600061055e8261048f565b91506105698361048f565b9250817f7fffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff038313600083121516156105a4576105a3610524565b5b817f80000000000000000000000000000000000000000000000000000000000000000383126000831216156105dc576105db610524565b5b828201905092915050565b82818337600083830152505050565b600061060283856103df565b935061060f8385846105e7565b61061883610423565b840190509392505050565b6000604082019050818103600083015261063e8185876105f6565b905061064d6020830184610499565b94935050505056fea2646970667358221220f474bd1d28e84751caca4356bb3cca5453b846289fe3aed4ecbc8cd022fb484464736f6c634300080b0033"

func main() {
privateKey, _ := hex.DecodeString("145e247e170ba3afd6ae97e88f00dbc976c2345d511b0f6713355d19d8b80b58")
// disable ssl of node rpc
config := &client.Config{IsSMCrypto: false, GroupID: "group0", DisableSsl: true,
PrivateKey: privateKey, Host: "127.0.0.1", Port: 20200, TLSCaFile: "./conf/ca.crt", TLSKeyFile: "./conf/sdk.key", TLSCertFile: "./conf/sdk.crt"}
client, err := client.DialContext(context.Background(), config)
if err != nil {
log.Fatal(err)
}
// deploy helloworld contract
currentNumber, err := client.GetBlockNumber(context.Background())
if err != nil {
log.Fatalf("GetBlockNumber error: %v", err)
}
parsed, err := abi.JSON(strings.NewReader(HelloWorldABI))
if err != nil {
log.Fatalf("abi.JSON error: %v", err)
}
if client.SMCrypto() {
parsed.SetSMCrypto()
}
input, err := parsed.Pack("", "hello, world init")
if err != nil {
log.Fatalf("parsed.Pack error: %v", err)
}
blockLimit := currentNumber + 500
////////////
// 1. create txData
input = append(common.FromHex(HelloWorldBin), input...)

// 加载私钥
// 构造交易数据
priKey, err := crypto.ToECDSA(privateKey)
if err != nil {
fmt.Println("ToECDSA出现错误:", err)
return
}
sender := crypto.PubkeyToAddress(priKey.PublicKey)
transOpts := bind.NewKeyedTransactor(priKey)
// generate uuid as nonce
id, err := uuid.NewUUID()
if err != nil {
fmt.Println("生成UUID出现错误:", err)
return
}
nonce := id.String()
rawTx := types.NewTransaction(nil, big.NewInt(0), 30000000, big.NewInt(0), blockLimit, input, nonce, "chain0", "group0", "", false)
rawTx.Data.Abi = HelloWorldABI
signedTx, signErr := transOpts.Signer(types.NewEIP155Signer(nil), sender, rawTx)
// signedTx.Sender = &sender // 不调用会导致signedTx.Bytes() nil pointer
if signErr != nil {
log.Fatalf("failed to sign tx, %v", signErr)
}
////////////

// // 1. create txData
// input = append(common.FromHex(HelloWorldBin), input...)
// txData, txHash, err := client.CreateEncodedTransactionDataV1(nil, input, blockLimit, HelloWorldABI)
// if err != nil {
// log.Fatalf("CreateEncodedTransactionDataV1 error: %v", err)
// }
// log.Printf("txHash: %x\n", txHash)
// // 2. sign txData
// signature, err := client.CreateEncodedSignature(txHash)
// if err != nil {
// log.Fatalf("CreateEncodedSignature error: %v", err)
// }
// 3. create tx, tx include txData, txHash, signature, arrtibute, extraData
// tx, err := client.CreateEncodedTransaction(signedTx.Data.Bytes(), signedTx.Hash().Bytes(), signedTx.Signature, 0, "")
// if err != nil {
// log.Fatalf("CreateEncodedTransaction error: %v", err)
// }
// 4. send tx
fmt.Printf("send tx, hash: %s\n", signedTx.Hash().Hex())
receipt, err := client.SendEncodedTransaction(context.Background(), signedTx.Bytes(), true)
if err != nil {
log.Fatalf("SendEncodedTransaction error: %v", err)
}
fmt.Printf("contract address: %s\n", receipt.ContractAddress)
if receipt.Status != 0 {
log.Fatalf("receipt status error, status: %v, message: %s", receipt.Status, receipt.GetErrorMessage())
}
// call helloworld set
address := common.HexToAddress(receipt.ContractAddress)
// SubscribeEventLogs
hello := bind.NewBoundContract(address, parsed, client, client, client)
currentBlock, err := client.GetBlockNumber(context.Background())
if err != nil {
fmt.Printf("GetBlockNumber() failed: %v", err)
return
}
hello.WatchLogs(&currentBlock, func(ret int, logs []types.Log) {
setValue := &struct {
V string
From common.Address
To common.Address
Value *big.Int
Raw types.Log // Blockchain specific contextual infos
}{}
hello.UnpackLog(setValue, "setValue", logs[0])
if err != nil {
fmt.Printf("WatchAllSetValue() failed: %v", err)
panic("WatchAllSetValue failed")
}
fmt.Printf("receive setValue event: value:%s ,from:%s\n", setValue.V, setValue.From.Hex())
}, "setValue")

// call helloworld set
input, err = parsed.Pack("set", "hello, world")
if err != nil {
log.Fatalf("parsed.Pack error: %v", err)
}
// generate uuid as nonce
id, err = uuid.NewUUID()
if err != nil {
fmt.Println("生成UUID出现错误:", err)
return
}
nonce = id.String()
rawTx = types.NewTransaction(&address, big.NewInt(0), 30000000, big.NewInt(0), blockLimit, input, nonce, "chain0", "group0", "", false)
rawTx.Data.Abi = HelloWorldABI
signedTx, signErr = transOpts.Signer(types.NewEIP155Signer(nil), sender, rawTx)
// signedTx.Sender = &sender // 不调用会导致signedTx.Bytes() nil pointer
if signErr != nil {
log.Fatalf("failed to sign tx, %v", signErr)
}
// // create tx and send
// txData, txHash, err := client.CreateEncodedTransactionDataV1(&address, input, blockLimit, "")
// if err != nil {
// log.Fatalf("CreateEncodedTransactionDataV1 error: %v", err)
// }
// fmt.Printf("txHash: %x\n", txHash)
// signature, err := client.CreateEncodedSignature(txHash)
// if err != nil {
// log.Fatalf("CreateEncodedSignature error: %v", err)
// }
// tx, err := client.CreateEncodedTransaction(txData, txHash, signature, 0, "")
// if err != nil {
// log.Fatalf("CreateEncodedTransaction error: %v", err)
// }

receipt, err = client.SendEncodedTransaction(context.Background(), signedTx.Bytes(), true)
if err != nil {
log.Fatalf("SendEncodedTransaction error: %v", err)
}
if receipt.Status != 0 {
log.Fatalf("receipt status error, status: %v, message: %s", receipt.Status, receipt.GetErrorMessage())
}
// call helloworld set async
input, err = parsed.Pack("set", "hello, world async")
if err != nil {
log.Fatalf("parsed.Pack error: %v", err)
}
// generate uuid as nonce
id, err = uuid.NewUUID()
if err != nil {
fmt.Println("生成UUID出现错误:", err)
return
}
nonce = id.String()
rawTx = types.NewTransaction(&address, big.NewInt(0), 30000000, big.NewInt(0), blockLimit, input, nonce, "chain0", "group0", "", false)
rawTx.Data.Abi = HelloWorldABI
signedTx, signErr = transOpts.Signer(types.NewEIP155Signer(nil), sender, rawTx)
if signErr != nil {
log.Fatalf("failed to sign tx, %v", signErr)
}

var wg sync.WaitGroup
err = client.AsyncSendEncodedTransaction(context.Background(), signedTx.Bytes(), false, func(receipt *types.Receipt, err error) {
if err != nil {
log.Fatalf("AsyncSendEncodedTransaction error: %v", err)
}
if receipt.Status != 0 {
log.Fatalf("receipt status error, status: %v, message: %s", receipt.Status, receipt.GetErrorMessage())
}
wg.Done()
})
if err != nil {
log.Fatalf("SendEncodedTransaction error: %v", err)
}
wg.Add(1)
wg.Wait()
time.Sleep(3 * time.Second)
}
4 changes: 2 additions & 2 deletions v3/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,12 +10,14 @@ require (
github.com/TarsCloud/TarsGo v1.4.5
github.com/deckarep/golang-set/v2 v2.6.0
github.com/ethereum/go-ethereum v1.13.10
github.com/google/uuid v1.6.0
github.com/schollz/progressbar/v3 v3.14.1
github.com/sirupsen/logrus v1.9.3
github.com/spf13/cobra v1.5.0
github.com/spf13/pflag v1.0.5
github.com/urfave/cli/v2 v2.25.7
golang.org/x/crypto v0.18.0
golang.org/x/exp v0.0.0-20240119083558-1b970713d09a
golang.org/x/time v0.3.0
)

Expand Down Expand Up @@ -54,7 +56,6 @@ require (
github.com/golang-jwt/jwt/v4 v4.5.0 // indirect
github.com/golang/protobuf v1.5.3 // indirect
github.com/golang/snappy v0.0.5-0.20220116011046-fa5810519dcb // indirect
github.com/google/uuid v1.6.0 // indirect
github.com/gorilla/websocket v1.4.2 // indirect
github.com/graph-gophers/graphql-go v1.3.0 // indirect
github.com/hashicorp/go-bexpr v0.1.10 // indirect
Expand Down Expand Up @@ -99,7 +100,6 @@ require (
github.com/tklauser/numcpus v0.6.1 // indirect
github.com/tyler-smith/go-bip39 v1.1.0 // indirect
github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 // indirect
golang.org/x/exp v0.0.0-20240119083558-1b970713d09a // indirect
golang.org/x/mod v0.14.0 // indirect
golang.org/x/net v0.20.0 // indirect
golang.org/x/sync v0.6.0 // indirect
Expand Down
21 changes: 10 additions & 11 deletions v3/types/transaction.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -347,8 +347,8 @@ type Transaction struct {
}

// NewTransaction returns a new transaction
func NewTransaction(to common.Address, amount *big.Int, gasLimit int64, gasPrice *big.Int, blockLimit int64, data []byte, nonce, chainId, groupId, extraData string, smcrypto bool) *Transaction {
return newTransaction(&to, amount, gasLimit, gasPrice, blockLimit, data, nonce, chainId, groupId, extraData, smcrypto)
func NewTransaction(to *common.Address, amount *big.Int, gasLimit int64, gasPrice *big.Int, blockLimit int64, data []byte, nonce, chainId, groupId, extraData string, smcrypto bool) *Transaction {
return newTransaction(to, amount, gasLimit, gasPrice, blockLimit, data, nonce, chainId, groupId, extraData, smcrypto)
}

// NewSimpleTx creates a contract transaction, if nonce is empty string, the nonce will be auto generated
Expand Down Expand Up @@ -519,14 +519,14 @@ func (tx *Transaction) keccak256Hash() (h common.Hash) {
// WithSignature returns a new transaction with the given signature.
// This signature needs to be in the [R || S || V] format where V is 0 or 1.
func (tx *Transaction) WithSignature(signer Signer, sig []byte) (*Transaction, error) {
tx.Signature = make([]byte, len(sig))
r, s, v, err := signer.SignatureValues(tx, sig)
if err != nil {
return nil, err
}
cpy := &Transaction{Data: tx.Data}
cpy.R, cpy.S, cpy.V = r, s, v
cpy.SMCrypto = tx.SMCrypto
return cpy, nil
copy(tx.Signature, sig)
tx.R, tx.S, tx.V = r, s, v
return tx, nil
}

// WithSM2Signature returns a new transaction with the given signature.
Expand All @@ -538,10 +538,9 @@ func (tx *Transaction) WithSM2Signature(signer Signer, sig []byte) (*Transaction
r := new(big.Int).SetBytes(sig[:32])
s := new(big.Int).SetBytes(sig[32:64])
v := new(big.Int).SetBytes(sig[64:])
cpy := &Transaction{Data: tx.Data}
cpy.R, cpy.S, cpy.V = r, s, v
cpy.SMCrypto = tx.SMCrypto
return cpy, nil
copy(tx.Signature, sig)
tx.R, tx.S, tx.V = r, s, v
return tx, nil
}

// Cost returns amount + gasprice * gaslimit.
Expand Down Expand Up @@ -815,7 +814,7 @@ func (st *Transaction) WriteTo(buf *codec.Buffer) (err error) {
}
}

if len(st.Sender) > 0 {
if st.Sender != nil {
err = buf.WriteHead(codec.SimpleList, 7)
if err != nil {
return err
Expand Down

0 comments on commit cec73d4

Please sign in to comment.