diff options
Diffstat (limited to 'build')
| -rwxr-xr-x | build/fullnode-test.sh | 55 | ||||
| -rw-r--r-- | build/testtool/testtool.go | 166 |
2 files changed, 221 insertions, 0 deletions
diff --git a/build/fullnode-test.sh b/build/fullnode-test.sh new file mode 100755 index 000000000..589e707bf --- /dev/null +++ b/build/fullnode-test.sh @@ -0,0 +1,55 @@ +#!/bin/bash + +sleep 20 + +tarAndUpload() +{ + name=travis-fail-$(date +%s).tar.gz + tar -zcvf $name test + echo "Verify fail and upload $name" + PKG_CONFIG_PATH=/usr/local/opt/openssl/lib/pkgconfig go run build/testtool/testtool.go upload $name dexon-builds +} + +endpoint=http://127.0.0.1:8545 + +for round in 0 1 2 +do + +echo "Start verify round $round" + for index in 0 1 2 3 + do + echo "Verify gov master public key round $round index $index" + cmd="PKG_CONFIG_PATH=/usr/local/opt/openssl/lib/pkgconfig go run build/testtool/testtool.go verifyGovMPK $endpoint $round $index" + eval $cmd + code=$? + + if [ $code == 1 ]; then + tarAndUpload + exit 1 + fi + done + +echo "Start verify CRS" +cmd="PKG_CONFIG_PATH=/usr/local/opt/openssl/lib/pkgconfig go run build/testtool/testtool.go verifyGovCRS $endpoint $round" +eval $cmd +code=$? + +if [ $code == 1 ]; then + tarAndUpload + exit 1 +fi + +if [ $round -lt 2 ]; then + cmd="PKG_CONFIG_PATH=/usr/local/opt/openssl/lib/pkgconfig go run build/testtool/testtool.go monkeyTest $endpoint" + eval $cmd + code=$? + + if [ $code == 1 ]; then + tarAndUpload + exit 1 + fi + + echo "Sleep 30 sec wait for next round" + sleep 30 +fi +done
\ No newline at end of file diff --git a/build/testtool/testtool.go b/build/testtool/testtool.go new file mode 100644 index 000000000..801c343b6 --- /dev/null +++ b/build/testtool/testtool.go @@ -0,0 +1,166 @@ +package main + +import ( + "bytes" + "context" + "log" + "math/big" + "os" + "path/filepath" + "strconv" + "strings" + "time" + + "github.com/dexon-foundation/dexon" + "github.com/dexon-foundation/dexon/accounts/abi" + "github.com/dexon-foundation/dexon/cmd/zoo/monkey" + "github.com/dexon-foundation/dexon/core/vm" + "github.com/dexon-foundation/dexon/crypto" + "github.com/dexon-foundation/dexon/ethclient" + "github.com/dexon-foundation/dexon/internal/build" +) + +func main() { + if len(os.Args) < 2 { + log.Fatal("need subcommand as first argument") + } + + switch os.Args[1] { + case "verifyGovCRS": + doVerifyGovCRS(os.Args[2:]) + case "verifyGovMPK": + doVerifyGovMPK(os.Args[2:]) + case "monkeyTest": + doMonkeyTest(os.Args[2:]) + case "upload": + doUpload(os.Args[2:]) + } +} + +func doVerifyGovCRS(args []string) { + if len(args) < 2 { + log.Fatal("arg length is not enough") + } + + client, err := ethclient.Dial(args[0]) + if err != nil { + log.Fatalf("new ethclient fail: %v", err) + } + + abiObject, err := abi.JSON(strings.NewReader(vm.GovernanceABIJSON)) + if err != nil { + log.Fatalf("read abi fail: %v", err) + } + + round, err := strconv.Atoi(args[1]) + if err != nil { + log.Fatalf("pasre round from arg 2 fail: %v", err) + } + + input, err := abiObject.Pack("crs", big.NewInt(int64(round))) + if err != nil { + log.Fatalf("pack input fail: %v", err) + } + + result, err := client.CallContract(context.Background(), ethereum.CallMsg{ + To: &vm.GovernanceContractAddress, + Data: input, + }, nil) + if err != nil { + log.Fatalf("call contract fail: %v", err) + } + + if bytes.Equal(make([]byte, 32), result) { + log.Fatalf("round %s crs not found", args[1]) + } + + log.Printf("get round %s crs %x", args[1], result) +} + +func doVerifyGovMPK(args []string) { + if len(args) < 3 { + log.Fatal("arg length is not enough") + } + + client, err := ethclient.Dial(args[0]) + if err != nil { + log.Fatalf("new ethclient fail: %v", err) + } + + abiObject, err := abi.JSON(strings.NewReader(vm.GovernanceABIJSON)) + if err != nil { + log.Fatalf("read abi fail: %v", err) + } + + round, err := strconv.Atoi(args[1]) + if err != nil { + log.Fatalf("pasre round from arg 2 fail: %v", err) + } + + index, err := strconv.Atoi(args[2]) + if err != nil { + log.Fatalf("pasre round from arg 2 fail: %v", err) + } + + input, err := abiObject.Pack("dkgMasterPublicKeys", big.NewInt(int64(round)), big.NewInt(int64(index))) + if err != nil { + log.Fatalf("pack input fail: %v", err) + } + + result, err := client.CallContract(context.Background(), ethereum.CallMsg{ + To: &vm.GovernanceContractAddress, + Data: input, + }, nil) + if err != nil { + log.Fatalf("call contract fail: %v", err) + } + + if bytes.Equal(make([]byte, 0), result) { + log.Fatalf("round %s index %s crs not found", args[1], args[2]) + } + + log.Printf("get round %s index %s master public key %x", args[1], args[2], result) +} + +func doUpload(args []string) { + auth := build.GCPOption{ + CredentialPath: os.Getenv("GCP_CREDENTIAL_PATH"), + } + + if err := build.GCPFileUpload(args[0], args[1], filepath.Base(args[0]), auth); err != nil { + log.Fatalf("upload fail: %v", err) + } +} + +func doMonkeyTest(args []string) { + if len(args) < 1 { + log.Fatal("arg length is not enough") + } + + client, err := ethclient.Dial(args[0]) + if err != nil { + log.Fatalf("new ethclient fail: %v", err) + } + + monkey.Init(&monkey.MonkeyConfig{ + Key: "test/keystore/monkey.key", + Endpoint: args[0], + N: 30, + Sleep: 3000, + Timeout: 60, + }) + m, nonce := monkey.Exec() + + time.Sleep(10 * time.Second) + + for _, key := range m.Keys() { + currentNonce, err := client.NonceAt(context.Background(), crypto.PubkeyToAddress(key.PublicKey), nil) + if err != nil { + log.Fatalf("get address nonce fail: %v", err) + } + + if currentNonce != nonce+1 { + log.Fatalf("expect nonce %v but %v", nonce, currentNonce) + } + } +} |