Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add example to create Tx use golang native and use csdk config file #288

Merged
merged 3 commits into from
Dec 25, 2024
Merged

add example to create Tx use golang native and use csdk config file #288

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
59c304e
fix ci
bxq2011hust Jul 26, 2024
3f04d07
add csdk config file example
bxq2011hust Oct 19, 2024
cec73d4
add example to create Tx use golang native
bxq2011hust Dec 25, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .ci/integration_test.sh
View file
Open in desktop
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.1"
chain_version="v3.12.2"
start_time=15
macOS=
ldflags="-ldflags=\"-r /usr/local/lib/\""
Expand Down
9 changes: 9 additions & 0 deletions v3/examples/configFile/conf/clog.ini
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
[log]
enable=false
log_path=./log
; network statistics interval, unit is second, default is 60s
stat_flush_interval=60
; info debug trace
level=info
; MB
max_log_file_size=1024
26 changes: 26 additions & 0 deletions v3/examples/configFile/conf/config_sample.ini
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
[common]
; if ssl connection is disabled, default: false
; disable_ssl = true
; thread pool size for network message sending recving handing
thread_pool_size = 8
; send message timeout(ms)
message_timeout_ms = 10000
send_rpc_request_to_highest_block_node = true

; ssl cert config items,
[cert]
; ssl_type: ssl or sm_ssl, default: ssl
ssl_type = ssl
; directory the certificates located in, defaul: ./conf
ca_path=./conf
; the ca certificate file
ca_cert=ca.crt
; the node private key file
sdk_key=sdk.key
; the node certificate file
sdk_cert=sdk.crt

[peers]
# supported ipv4 and ipv6
node.0=127.0.0.1:20200
node.1=127.0.0.1:20201
29 changes: 29 additions & 0 deletions v3/examples/configFile/conf/sm_config_sample.ini
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
[common]
; if ssl connection is disabled, default: false
; disable_ssl = true
; thread pool size for network message sending recving handing
thread_pool_size = 8
; send message timeout(ms)
message_timeout_ms = 10000
send_rpc_request_to_highest_block_node = true

[cert]
; ssl_type: ssl or sm_ssl, default: ssl
ssl_type = sm_ssl
; directory the certificates located in, defaul: ./conf
ca_path=./conf
; the ca certificate file
sm_ca_cert=sm_ca.crt
; the node private key file
sm_sdk_key=sm_sdk.key
; the node certificate file
sm_sdk_cert=sm_sdk.crt
; the node private key file
sm_ensdk_key=sm_ensdk.key
; the node certificate file
sm_ensdk_cert=sm_ensdk.crt

[peers]
# supported ipv4 and ipv6
node.0=127.0.0.1:20200
node.1=127.0.0.1:20201
162 changes: 162 additions & 0 deletions v3/examples/configFile/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,162 @@
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"
)

// 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")
groupID := "group0"
// disable ssl of node rpc
configFile := "./conf/config_sample.ini"
client, err := client.Dial(configFile, groupID, privateKey)
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...)
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(txData, txHash, signature, 0, "")
if err != nil {
log.Fatalf("CreateEncodedTransaction error: %v", err)
}
// 4. send tx
receipt, err := client.SendEncodedTransaction(context.Background(), tx, true)
if err != nil {
log.Fatalf("SendEncodedTransaction error: %v", err)
}
if receipt.Status != 0 {
log.Fatalf("receipt status error: %v", receipt.Status)
}
// 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)
}
// 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(), tx, true)
if err != nil {
log.Fatalf("SendEncodedTransaction error: %v", err)
}
if receipt.Status != 0 {
log.Fatalf("receipt status error: %v", receipt.Status)
}
// call helloworld set async
input, err = parsed.Pack("set", "hello, world async")
if err != nil {
log.Fatalf("parsed.Pack error: %v", err)
}
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)
}
var wg sync.WaitGroup
err = client.AsyncSendEncodedTransaction(context.Background(), tx, 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: %v", receipt.Status)
}
wg.Done()
})
if err != nil {
log.Fatalf("SendEncodedTransaction error: %v", err)
}
wg.Add(1)
wg.Wait()
time.Sleep(3 * time.Second)
}
Loading
Loading