How to use getConfig method of cmd Package

Best K6 code snippet using cmd.getConfig

main.go

Source:main.go

1package main2import (3	"bcXwallet/client"4	"bcXwallet/common"5	"bcXwallet/rpc"6	rpcserver "common/rpc/lib/server"7	"fmt"8	"github.com/spf13/cobra"9	"github.com/tendermint/go-amino"10	cmn "github.com/tendermint/tmlibs/common"11	"net/http"12	"os"13	"strconv"14	"strings"15)16const (17	usage = "bcbXwallet_rpc's url"18)19func main() {20	err := common.InitAll()21	if err != nil {22		panic(err)23	}24	if version() == "" {25		err = rpc.InitDB()26		if err != nil {27			panic(err)28		}29		rpcLogger := common.GetLogger()30		coreCodec := amino.NewCodec()31		mux := http.NewServeMux()32		rpcserver.RegisterRPCFuncs(mux, rpc.Routes, coreCodec, rpcLogger)33		if common.GetConfig().UseHttps {34			crtPath, keyPath := common.OutCertFileIsExist()35			_, err = rpcserver.StartHTTPAndTLSServer(serverAddr(common.GetConfig().ServerAddr, false), mux, crtPath, keyPath, rpcLogger)36			if err != nil {37				cmn.Exit(err.Error())38			}39		} else {40			_, err = rpcserver.StartHTTPServer(serverAddr(common.GetConfig().ServerAddr, false), mux, rpcLogger)41			if err != nil {42				cmn.Exit(err.Error())43			}44		}45	}46	err = Execute()47	if err != nil {48		fmt.Print(err)49		os.Exit(1)50	}51}52func serverAddr(address string, bRequest bool) string {53	splitAddr := strings.Split(address, ":")54	if len(splitAddr) != 3 {55		fmt.Println("invalid serverAddr=" + address)56		return ""57	}58	port, err := strconv.Atoi(splitAddr[2])59	if err != nil {60		fmt.Println("invalid serverAddr=" + address)61		return ""62	}63	if bRequest {64		if common.GetConfig().UseHttps {65			return fmt.Sprintf("https://127.0.0.1:%d", port)66		} else {67			return fmt.Sprintf("http://127.0.0.1:%d", port)68		}69	} else {70		return address71	}72}73func version() string {74	params := map[string]interface{}{}75	result := new(rpc.VersionResult)76	err := common.DoHttpRequestAndParseEx([]string{serverAddr(common.GetConfig().ServerAddr, true)}, "bcb_version", params, result)77	if err != nil {78		return ""79	}80	return result.Version81}82// flags83var (84	// global flags85	flagRpcUrl string86	// block flag87	flagHeight int6488	// transaction flag89	flagTxHash string90	// address flag91	flagAddress      string92	flagTokenAddress string93	flagTokenName    string94	// commitTx flag95	flagTx string96	// wallet flag97	flagName          string98	flagPassword      string99	flagAccessKey     string100	flagEncPrivateKey string101	flagSmcAddress    string102	flagGasLimit      string103	flagNote          string104	flagNonce         string105	flagTo            string106	flagValue         string107	flagPlainText     string108	flagPageNum       uint64109)110var RootCmd = &cobra.Command{111	Use:   "bcbXwallet",112	Short: "bcb exchange wallet console",113	Long:  "bcbXwallet client that it can perform the wallet operation, query chain information and so on.",114}115func Execute() error {116	addFlags()117	addCommands()118	return RootCmd.Execute()119}120func addFlags() {121	addWalletCreateFlag()122	addWalletExportFlag()123	addWalletImportFlag()124	addWalletListFlag()125	addTransferFlag()126	addTransferOfflineFlag()127	addBlockHeightFlag()128	addBlockFlag()129	addTransactionFlag()130	addBalanceFlag()131	addBalanceOfTokenFlag()132	addAllBalanceFlag()133	addNonceFlag()134	addCommitTxFlag()135}136func addCommands() {137	RootCmd.AddCommand(walletCreateCmd)138	RootCmd.AddCommand(walletExportCmd)139	RootCmd.AddCommand(walletImportCmd)140	RootCmd.AddCommand(walletListCmd)141	RootCmd.AddCommand(transferCmd)142	RootCmd.AddCommand(transferOfflineCmd)143	RootCmd.AddCommand(blockHeightCmd)144	RootCmd.AddCommand(blockCmd)145	RootCmd.AddCommand(transactionCmd)146	RootCmd.AddCommand(balanceCmd)147	RootCmd.AddCommand(balanceOfTokenCmd)148	RootCmd.AddCommand(allBalanceCmd)149	RootCmd.AddCommand(nonceCmd)150	RootCmd.AddCommand(commitTxCmd)151}152var walletCreateCmd = &cobra.Command{153	Use:   "walletCreate",154	Short: "Create wallet",155	Long:  "Create a new wallet",156	Args:  cobra.ExactArgs(0),157	RunE: func(cmd *cobra.Command, args []string) error {158		return client.WalletCreate(flagName, flagPassword, flagRpcUrl)159	},160}161func addWalletCreateFlag() {162	walletCreateCmd.PersistentFlags().StringVarP(&flagName, "name", "n", "", "wallet name")163	walletCreateCmd.PersistentFlags().StringVarP(&flagPassword, "password", "p", "", "wallet password")164	walletCreateCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)165}166var walletExportCmd = &cobra.Command{167	Use:   "walletExport",168	Short: "Export wallet",169	Long:  "Export the private key and walletAddr of wallet",170	Args:  cobra.ExactArgs(0),171	RunE: func(cmd *cobra.Command, args []string) error {172		return client.WalletExport(flagName, flagPassword, flagAccessKey, flagRpcUrl, flagPlainText)173	},174}175func addWalletExportFlag() {176	walletExportCmd.PersistentFlags().StringVarP(&flagName, "name", "n", "", "wallet name")177	walletExportCmd.PersistentFlags().StringVarP(&flagPassword, "password", "p", "", "wallet password")178	walletExportCmd.PersistentFlags().StringVarP(&flagAccessKey, "accessKey", "a", "", "wallet accessKey")179	walletExportCmd.PersistentFlags().StringVarP(&flagPlainText, "plainText", "t", "", "export plain text(default false)")180	walletExportCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)181}182var walletImportCmd = &cobra.Command{183	Use:   "walletImport",184	Short: "Import wallet",185	Long:  "Import the private key to a new wallet",186	Args:  cobra.ExactArgs(0),187	RunE: func(cmd *cobra.Command, args []string) error {188		return client.WalletImport(flagName, flagEncPrivateKey, flagPassword, flagAccessKey, flagRpcUrl, flagPlainText)189	},190}191func addWalletImportFlag() {192	walletImportCmd.PersistentFlags().StringVarP(&flagName, "name", "n", "", "wallet name")193	walletImportCmd.PersistentFlags().StringVarP(&flagEncPrivateKey, "privateKey", "k", "", "wallet privateKey")194	walletImportCmd.PersistentFlags().StringVarP(&flagPassword, "password", "p", "", "wallet password")195	walletImportCmd.PersistentFlags().StringVarP(&flagAccessKey, "accessKey", "a", "", "wallet accessKey")196	walletImportCmd.PersistentFlags().StringVarP(&flagPlainText, "plainText", "t", "", "import plain text(default false)")197	walletImportCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)198}199var walletListCmd = &cobra.Command{200	Use:   "walletList",201	Short: "Wallet list",202	Long:  "Query all wallet names and walletAddrs",203	Args:  cobra.ExactArgs(0),204	RunE: func(cmd *cobra.Command, args []string) error {205		return client.WalletList(flagPageNum, flagRpcUrl)206	},207}208func addWalletListFlag() {209	walletListCmd.PersistentFlags().Uint64VarP(&flagPageNum, "pageNum", "p", 1, "page index, default first page")210	walletListCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)211}212var transferCmd = &cobra.Command{213	Use:   "transfer",214	Short: "Transfer token",215	Long:  "Transfer token to someone with value",216	Args:  cobra.ExactArgs(0),217	RunE: func(cmd *cobra.Command, args []string) error {218		return client.Transfer(flagName, flagAccessKey, flagSmcAddress, flagGasLimit, flagNote, flagTo, flagValue, flagRpcUrl)219	},220}221func addTransferFlag() {222	transferCmd.PersistentFlags().StringVarP(&flagName, "name", "n", "", "wallet name")223	transferCmd.PersistentFlags().StringVarP(&flagAccessKey, "accessKey", "a", "", "wallet accessKey")224	transferCmd.PersistentFlags().StringVarP(&flagSmcAddress, "smcAddress", "s", "", "smart contract address")225	transferCmd.PersistentFlags().StringVarP(&flagGasLimit, "gasLimit", "g", "5000", "gas limit ")226	transferCmd.PersistentFlags().StringVarP(&flagNote, "note", "o", "", "note")227	transferCmd.PersistentFlags().StringVarP(&flagTo, "to", "t", "", "to address")228	transferCmd.PersistentFlags().StringVarP(&flagValue, "value", "v", "", "transfer value")229	transferCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)230}231var transferOfflineCmd = &cobra.Command{232	Use:   "transferOffline",233	Short: "Offline transaction",234	Long:  "Offline pack and sign transfer transaction",235	Args:  cobra.ExactArgs(0),236	RunE: func(cmd *cobra.Command, args []string) error {237		return client.TransferOffline(flagName, flagAccessKey, flagSmcAddress, flagGasLimit, flagNote, flagTo, flagValue, flagNonce, flagRpcUrl)238	},239}240func addTransferOfflineFlag() {241	transferOfflineCmd.PersistentFlags().StringVarP(&flagName, "name", "n", "", "wallet name")242	transferOfflineCmd.PersistentFlags().StringVarP(&flagAccessKey, "accessKey", "a", "", "wallet accessKey")243	transferOfflineCmd.PersistentFlags().StringVarP(&flagSmcAddress, "smcAddress", "s", "", "smart contract address")244	transferOfflineCmd.PersistentFlags().StringVarP(&flagGasLimit, "gasLimit", "g", "5000", "gas limit ")245	transferOfflineCmd.PersistentFlags().StringVarP(&flagNonce, "nonce", "c", "", "nonce")246	transferOfflineCmd.PersistentFlags().StringVarP(&flagNote, "note", "o", "", "note")247	transferOfflineCmd.PersistentFlags().StringVarP(&flagTo, "to", "t", "", "to address")248	transferOfflineCmd.PersistentFlags().StringVarP(&flagValue, "value", "v", "", "transfer value")249	transferOfflineCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)250}251var blockHeightCmd = &cobra.Command{252	Use:   "blockHeight",253	Short: "Get current block height",254	Long:  "Get BlockChain current block height",255	Args:  cobra.ExactArgs(0),256	RunE: func(cmd *cobra.Command, args []string) error {257		return client.BlockHeight(flagRpcUrl)258	},259}260func addBlockHeightFlag() {261	blockHeightCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)262}263var blockCmd = &cobra.Command{264	Use:   "block",265	Short: "Get block information",266	Long:  "Get block information with height, must great than zero",267	Args:  cobra.ExactArgs(0),268	RunE: func(cmd *cobra.Command, args []string) error {269		return client.Block(flagHeight, flagRpcUrl)270	},271}272func addBlockFlag() {273	blockCmd.PersistentFlags().Int64VarP(&flagHeight, "height", "t", 0, "block height")274	blockCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)275}276var transactionCmd = &cobra.Command{277	Use:   "transaction",278	Short: "Get transaction information",279	Long:  "Get transaction information with txHash and cannot be empty",280	Args:  cobra.ExactArgs(0),281	RunE: func(cmd *cobra.Command, args []string) error {282		return client.Transaction(flagTxHash, flagRpcUrl)283	},284}285func addTransactionFlag() {286	transactionCmd.PersistentFlags().StringVarP(&flagTxHash, "txHash", "t", "", "transaction's hash")287	transactionCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)288}289var balanceCmd = &cobra.Command{290	Use:   "balance",291	Short: "Get balance information",292	Long:  "Get balance of BCB token for specific address",293	Args:  cobra.ExactArgs(0),294	RunE: func(cmd *cobra.Command, args []string) error {295		return client.Balance(flagAddress, flagRpcUrl)296	},297}298func addBalanceFlag() {299	balanceCmd.PersistentFlags().StringVarP(&flagAddress, "address", "a", "", "account's address")300	balanceCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)301}302var balanceOfTokenCmd = &cobra.Command{303	Use:   "balanceOfToken",304	Short: "Get balance information of address",305	Long:  "Get balance of specific token for specific address",306	Args:  cobra.ExactArgs(0),307	RunE: func(cmd *cobra.Command, args []string) error {308		return client.BalanceOfToken(flagAddress, flagTokenAddress, flagTokenName, flagRpcUrl)309	},310}311func addBalanceOfTokenFlag() {312	balanceOfTokenCmd.PersistentFlags().StringVarP(&flagAddress, "address", "a", "", "account's address")313	balanceOfTokenCmd.PersistentFlags().StringVarP(&flagTokenAddress, "tokenAddress", "t", "", "token's address")314	balanceOfTokenCmd.PersistentFlags().StringVarP(&flagTokenName, "tokenName", "n", "", "token's address")315	balanceOfTokenCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)316}317var allBalanceCmd = &cobra.Command{318	Use:   "allBalance",319	Short: "Get all balance information",320	Long:  "Get balance of all tokens for specific address",321	Args:  cobra.ExactArgs(0),322	RunE: func(cmd *cobra.Command, args []string) error {323		return client.AllBalance(flagAddress, flagRpcUrl)324	},325}326func addAllBalanceFlag() {327	allBalanceCmd.PersistentFlags().StringVarP(&flagAddress, "address", "a", "", "account's address")328	allBalanceCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)329}330var nonceCmd = &cobra.Command{331	Use:   "nonce",332	Short: "Get account nonce",333	Long:  "Get the next usable nonce for specific address",334	Args:  cobra.ExactArgs(0),335	RunE: func(cmd *cobra.Command, args []string) error {336		return client.Nonce(flagAddress, flagRpcUrl)337	},338}339func addNonceFlag() {340	nonceCmd.PersistentFlags().StringVarP(&flagAddress, "address", "a", "", "account's address")341	nonceCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)342}343var commitTxCmd = &cobra.Command{344	Use:   "commitTx",345	Short: "Commit transaction",346	Long:  "Commit transaction with tx's data",347	Args:  cobra.ExactArgs(0),348	RunE: func(cmd *cobra.Command, args []string) error {349		return client.CommitTx(flagTx, flagRpcUrl)350	},351}352func addCommitTxFlag() {353	commitTxCmd.PersistentFlags().StringVarP(&flagTx, "tx", "t", "", "packed and signed transaction's data")354	commitTxCmd.PersistentFlags().StringVarP(&flagRpcUrl, "url", "u", serverAddr(common.GetConfig().ServerAddr, true), usage)355}...

system_test.go

Source:system_test.go

1package our_tests2import (3	"testing"4	"time"5	"fmt"6	"github.com/stretchr/testify/assert"7)8func TestLeaderDropAndRestart(t *testing.T) {9	// leader drops out, no nodes have any log entries10	cluster, err := NewRaftCluster(t, DoubleElectionTimeoutConfig())11	if err != nil {12		t.Errorf(err.Error())13		return14	}15	SetDebug(false)16	cluster.strictTests = false17	cluster.config.VerboseLog = true18	// election19	time.Sleep(cluster.GetConfig().ElectionTimeout * 4)20	// start client, execute some command21	client, _ := cluster.ClusterCmdClientRegister(nil)22	cluster.ClusterCmdClientCmdInit(client, "hello")23	cluster.ClusterCmdClientCmdHash(client)24	time.Sleep(cluster.GetConfig().ElectionTimeout * 4)25	leader, _ := cluster.GetSimpleLeader()26	cluster.ClusterCmdNodeShutdown(leader)27	Out.Printf("SHUTTING DOWN %v", leader)28	// re-election29	time.Sleep(time.Second * 5)30	Out.Printf("NEW LEADER ELECTED\n")31	// client needs to reconnect32	client, _ = cluster.ClusterCmdClientRegister(nil)33	time.Sleep(time.Second)34	Out.Printf("CLIENT CONNECTED\n")35	// send sequence of hashes w/o init and it should work36	for i := 0; i < 3; i++ {37		cluster.ClusterCmdClientCmdHash(client)38	}39	Out.Printf("CLIENT HASHES COMPLETED\n")40	time.Sleep(2)41}42func TestLeaderDropWithLargeLog(t *testing.T) {43	run := false44	if run {45		conf := SystemTestingConfig()46		conf.ClusterSize = 547		cluster, err := NewRaftCluster(t, conf)48		cluster.strictTests = false49		if err != nil {50			t.Errorf(err.Error())51			return52		}53		time.Sleep(cluster.GetConfig().ElectionTimeout * 10)54		leader, exists := cluster.GetLeader()55		if !exists {56			t.Errorf("No leader!")57			return58		}59		cluster.ClusterCmdClientStart()60		time.Sleep(cluster.GetConfig().ElectionTimeout * 5)61		// some NON-LEADER nodes shutdown62		nonLeaders := make([]*RaftNode, 0)63		cluster.mutex.Lock()64		for _, node := range cluster.nodes {65			if node.State != LEADER_STATE {66				nonLeaders = append(nonLeaders, node)67			}68		}69		cluster.mutex.Unlock()70		cluster.ClusterCmdNodeShutdown(nonLeaders[0])71		cluster.ClusterCmdNodeShutdown(nonLeaders[1])72		cluster.ClusterCmdNodeShutdown(nonLeaders[2])73		time.Sleep(cluster.GetConfig().ElectionTimeout * 10)74		go cluster.ClusterCmdClientCmdHash(nil)75		go cluster.ClusterCmdClientCmdHash(nil)76		go cluster.ClusterCmdClientCmdHash(nil)77		time.Sleep(cluster.GetConfig().ElectionTimeout * 10)78		// leader drops, has uncommitted log entries b/c cannot commit to a majority of nodes79		cluster.ClusterCmdNodeShutdown(leader)80		// nodes elect new leader and receive commits81		time.Sleep(cluster.GetConfig().ElectionTimeout * 10)82		cluster.ClusterCmdNodeRestart(nonLeaders[0])83		cluster.ClusterCmdNodeRestart(nonLeaders[1])84		cluster.ClusterCmdNodeRestart(nonLeaders[2])85		time.Sleep(cluster.GetConfig().ElectionTimeout * 10)86		go cluster.ClusterCmdClientStart()87		go cluster.ClusterCmdClientCmdHash(nil)88		go cluster.ClusterCmdClientCmdHash(nil)89		// old leader starts up again and its log is truncated to be up to date with the new leader90		cluster.ClusterCmdNodeRestart(leader)91		// stable running resumes92		time.Sleep(cluster.GetConfig().ElectionTimeout * 10)93		cluster.assertLeaderState()94		// DESCRIBED IN DETAIL IN README95	}96}97func TestSplitVotes(t *testing.T) {98	// all nodes start as followers99	// all nodes timeout AT THE SAME TIME100	// every candidate should timeout and become a follower again101	// leader should elect normally102	cluster, _ := NewRaftCluster(t, DoubleElectionTimeoutConfig())103	for _, node := range cluster.nodes {104		cluster.initNode(node)105	}106	time.Sleep(time.Second * 2)107	// waits for all functions to be waiting on the lock and releases them all simultaneously108	Out.Printf("RELEASING ALL NODES INTO CANDIDATE STATE")109	cluster.debugCond.L.Lock()110	cluster.debugCond.Broadcast()111	cluster.debugCond.L.Unlock()112	// re-election113	time.Sleep(time.Second * 10)114	// must be able to find a leader115	leader, _ := cluster.GetSimpleLeader()116	Out.Printf("Cluster elected %v as leader", leader.Id)117}118func TestLeaderUpdatesFollowerWithPrevTerm(t *testing.T) {119	cluster, _ := NewRaftCluster(t, DefaultConfig())120	cluster.strictTests = false121	// election takes place122	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)123	leader, _ := cluster.GetSimpleLeader()124	// followers both drop out125	for _, node := range cluster.nodes {126		if node.Id != leader.Id {127			cluster.ClusterCmdNodeShutdown(node)128		}129	}130	time.Sleep(time.Second * 3)131	// leader keeps going, increments term132	// adds entries to its log via client requests133	go cluster.ClusterCmdClientRegister(leader)134	time.Sleep(time.Second)135	go cluster.ClusterCmdClientRegister(leader)136	time.Sleep(time.Second)137	go cluster.ClusterCmdClientRegister(leader)138	time.Sleep(time.Second)139	lastTerm := leader.getLogEntry(leader.getLastLogIndex()).GetTermId()140	lastIndex := leader.getLastLogIndex()141	// followers restart and are updated to match leader's log142	for _, node := range cluster.nodes {143		if node.Id != leader.Id {144			cluster.ClusterCmdNodeRestart(node)145		}146	}147	time.Sleep(time.Second * 5)148	// check that all logs are consistent149	for _, node := range cluster.nodes {150		if node.Id != leader.Id {151			if node.getLogEntry(node.getLastLogIndex()).GetTermId() != lastTerm {152				t.Errorf("Last terms inconsistent")153			}154			if node.getLastLogIndex() != lastIndex {155				t.Errorf("Last index inconsistent")156			}157		}158	}159}160func TestLeaderUpdatesFollowerNextTermExtraEntries(t *testing.T) {161	conf := SystemTestingConfig()162	cluster, err := NewRaftCluster(t, conf)163	cluster.strictTests = false164	if err != nil {165		t.Errorf(err.Error())166		return167	}168	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)169	// A follower, B leader with term 1170	B, isLeader := cluster.GetLeader()171	if !isLeader {172		fmt.Errorf("No leader!")173	}174	// B crashes and new election occurs175	cluster.ClusterCmdNodeShutdown(B)176	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)177	// B restarts, all nodes in term 2178	cluster.ClusterCmdNodeRestart(B)179	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)180	// A is leader, receives two request and crashes immediately w/o duplication181	A, isLeader := cluster.GetLeader()182	if !isLeader {183		fmt.Errorf("No leader!")184	}185	cl, err := cluster.ClusterCmdClientRegister(A)186	if err != nil {187		fmt.Errorf("Client failure!")188	}189	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)190	aLogLen := A.getLastLogIndex() + 1191	go cluster.ClusterCmdClientCmdHash(cl)192	go cluster.ClusterCmdClientCmdHash(cl)193	go cluster.ClusterCmdClientCmdHash(cl)194	go cluster.ClusterCmdClientCmdHash(cl)195	for A.getLastLogIndex()+1 < aLogLen {196	}197	cluster.ClusterCmdNodeShutdown(A)198	// B is elected leader, in term 3199	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)200	// A restarts, is now a follower with entries that are not in B's log201	cluster.ClusterCmdNodeRestart(A)202	// A should update correctly and B should remain leader203	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)204	assert.Equal(t, LEADER_STATE, B.State)205}206// PARTITION TESTS207func TestSoloNodePartition(t *testing.T) {208	cluster, err := NewRaftCluster(t, SystemTestingConfig())209	cluster.strictTests = false210	if err != nil {211		t.Errorf(err.Error())212		return213	}214	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)215	// single node breaks off into partition and keeps running, continuously going into the candidate state216	// and incrementing its turn217	rightSideNodes, leftSideNodes := cluster.ClusterCmdRandPartitionSplit(1)218	time.Sleep(cluster.GetConfig().ElectionTimeout * 30)219	// the right side's single node's term should be larger than everyone's220	// on the left at this point221	rightIncrementerTerm := rightSideNodes[0].GetCurrentTerm()222	for _, node := range leftSideNodes {223		assert.True(t, rightIncrementerTerm > node.GetCurrentTerm(),224			"rightIncrementerTerm=%d, curTerm=%d, node=%v", rightIncrementerTerm, node.GetCurrentTerm(), node)225	}226	// when partition is healed, all other nodes will have lower term but nobody will vote for the solo node227	// because log is out of date228	// all other nodes will be brought to the term of the solo node and solo node will become follower229	// THIS ALSO TESTS THAT OUT OF DATE LOGS CANNOT BE ELECTED230	cluster.ClusterCmdResolvePartition()231	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)232	// everyone's should be equal now233	rightIncrementerTerm = rightSideNodes[0].GetCurrentTerm()234	for _, node := range leftSideNodes {235		assert.Equal(t, rightIncrementerTerm, node.GetCurrentTerm())236	}237	// NOTE: look at assertLogEntries and assertLeaderState for how these are tested238}239func TestTwoLeaderPartition(t *testing.T) {240	// RAFT HAS 5 NODES IN THIS TEST - A,B,C,D,E241	conf := SystemTestingConfig()242	conf.ClusterSize = 5243	cluster, err := NewRaftCluster(t, conf)244	cluster.strictTests = false245	if err != nil {246		t.Errorf(err.Error())247		return248	}249	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)250	// A (without loss of generality) is elected leader, partition is setup between A,B|C,D,E251	rightSideNodes, leftSideNodes := cluster.ClusterCmdRandPartitionSplit(2)252	time.Sleep(cluster.GetConfig().ElectionTimeout * 5)253	// A stays leader of its side of the partition, C,D,E reelect and become a greater term254	// We have two leaders on both sides of the partition255	var A = new(RaftNode)256	for _, node := range rightSideNodes {257		if node.State == LEADER_STATE {258			A = node259		}260	}261	if A == nil {262		t.Errorf("No leader election on side of A!")263	} else {264		// Add another client to the new side of the partition and update both sides with a different call265		leftClientEntry := cluster.GetRandomNodeFrom(leftSideNodes)266		cl, err := cluster.ClusterCmdClientRegister(leftClientEntry)267		if err != nil {268			t.Errorf("Couldn't create client on CDE side")269			return270		}271		cluster.ClusterCmdClientCmdInit(cl, "cats")272		cluster.ClusterCmdClientCmdHash(cl)273		cluster.ClusterCmdClientCmdHash(cl)274		cluster.ClusterCmdClientCmdHash(cl)275		cluster.ClusterCmdClientCmdHash(cl)276		cluster.ClusterCmdClientCmdHash(cl)277		time.Sleep(cluster.GetConfig().ElectionTimeout * 5)278		// Remove partition, A should step down (as it has no committed entries) and match C,D,E's log279		cluster.ClusterCmdResolvePartition()280		time.Sleep(cluster.GetConfig().ElectionTimeout * 5)281		assert.True(t, A.State != LEADER_STATE)282	}283}...

cmd.go

Source:cmd.go

1package x_gob_explorer2import (3	"aioz.io/go-aioz/x_gob_explorer/config"4	database "aioz.io/go-aioz/x_gob_explorer/domain/db"5	"aioz.io/go-aioz/x_gob_explorer/utils"6	"github.com/spf13/cobra"7	"github.com/spf13/viper"8	tcmd "github.com/tendermint/tendermint/cmd/tendermint/commands"9	"github.com/tendermint/tendermint/libs/cli"10)11const (12	flagResetDB      = "resetDB"13	flagResetNode    = "resetData"14	flagWithTendermint = "with-tendermint"15	flagAddress        = "address"16	flagTraceStore     = "trace-store"17	flagPruning        = "pruning"18	flagCPUProfile     = "cpu-profile"19	FlagMinGasPrices   = "minimum-gas-prices"20)21func GobCmd(start func() error) *cobra.Command {22	host := config.GetConfig().GetString("database.host")23	port := config.GetConfig().GetString("database.port")24	user := config.GetConfig().GetString("database.user")25	pwd := config.GetConfig().GetString("database.passwd")26	dbname := config.GetConfig().GetString("database.dbname")27	sslmode := config.GetConfig().GetString("database.sslmode")28	sslrootcert := config.GetConfig().GetString("database.sslrootcert")29	sslkey := config.GetConfig().GetString("database.sslkey")30	sslcert := config.GetConfig().GetString("database.sslcert")31	schema := config.GetConfig().GetString("database.schema")32	cmd := &cobra.Command{33		Use:   "gob",34		Short: "Run the full node with indexing",35		RunE: func(cmd *cobra.Command, args []string) error {36			resetDB := viper.GetBool(flagResetDB)37			resetNode := viper.GetBool(flagResetNode)38			if resetDB {39				db := database.NewCockroachDB(user, pwd, host, port,40					dbname, sslmode, sslrootcert, sslkey, sslcert)41				db.Reset(schema)42				return nil43			}44			if resetNode {45				homeDir := viper.GetString(cli.HomeFlag)46				if err := utils.ResetNodeDB(homeDir); err != nil {47					return err48				}49				return nil50			}51			return start()52		},53	}54	// core flags for the ABCI application55	cmd.Flags().Bool(flagResetDB, false, "Reset cockroach database")56	cmd.Flags().Bool(flagResetNode, false, "Delete node directory")57	cmd.Flags().Bool(flagWithTendermint, true, "Run abci app embedded in-process with tendermint")58	cmd.Flags().String(flagAddress, "tcp://0.0.0.0:26658", "Listen address")59	cmd.Flags().String(flagTraceStore, "", "Enable KVStore tracing to an output file")60	cmd.Flags().String(flagPruning, "syncable", "Pruning strategy: syncable, nothing, everything")61	cmd.Flags().String(flagCPUProfile, "", "Enable CPU profiling and write to the provided file")62	cmd.Flags().String(FlagMinGasPrices, "", "Minimum gas prices to accept for transactions; All fees in a tx must meet this minimum (e.g. 0.01photino,0.0001stake)")63	// add support for all Tendermint-specific command line options64	tcmd.AddNodeFlags(cmd)65	return cmd66}...

getConfig

Using AI Code Generation

1import "fmt"2func main() {3    cmd := cmd{}4    fmt.Println(cmd.getConfig())5}6import "fmt"7func main() {8    cmd := cmd{}9    fmt.Println(cmd.getConfig())10}11import "fmt"12func main() {13    cmd := cmd{}14    fmt.Println(cmd.getConfig())15}16import "fmt"17func main() {18    cmd := cmd{}19    fmt.Println(cmd.getConfig())20}21import "fmt"22func main() {23    cmd := cmd{}24    fmt.Println(cmd.getConfig())25}26import "fmt"27func main() {28    cmd := cmd{}29    fmt.Println(cmd.getConfig())30}31import "fmt"32func main() {33    cmd := cmd{}34    fmt.Println(cmd.getConfig())35}36import "fmt"37func main() {38    cmd := cmd{}39    fmt.Println(cmd.getConfig())40}41import "fmt"42func main() {43    cmd := cmd{}44    fmt.Println(cmd.getConfig())45}46import "fmt"47func main() {48    cmd := cmd{}49    fmt.Println(cmd.getConfig())50}51import "fmt"52func main() {53    cmd := cmd{}54    fmt.Println(cmd.getConfig())55}56import "fmt"57func main() {58    cmd := cmd{}59    fmt.Println(cmd.getConfig())60}61import "fmt"62func main() {63    cmd := cmd{}

getConfig

Using AI Code Generation

1func main() {2    cmd := Cmd{Config: getConfig()}3    cmd.Run()4}5func main() {6    cmd := Cmd{Config: getConfig()}7    cmd.Run()8}9func main() {10    cmd := Cmd{Config: getConfig()}11    cmd.Run()12}13func main() {14    cmd := Cmd{Config: getConfig()}15    cmd.Run()16}17func main() {18    cmd := Cmd{Config: getConfig()}19    cmd.Run()20}21func main() {22    cmd := Cmd{Config: getConfig()}23    cmd.Run()24}25func main() {26    cmd := Cmd{Config: getConfig()}27    cmd.Run()28}29func main() {30    cmd := Cmd{Config: getConfig()}31    cmd.Run()32}33func main() {34    cmd := Cmd{Config: getConfig()}35    cmd.Run()36}37func main() {38    cmd := Cmd{Config: getConfig()}39    cmd.Run()40}41func main() {42    cmd := Cmd{Config: getConfig()}43    cmd.Run()44}45func main() {46    cmd := Cmd{Config: getConfig()}47    cmd.Run()48}49func main() {50    cmd := Cmd{Config: getConfig()}51    cmd.Run()52}53func main() {54    cmd := Cmd{Config: getConfig()}55    cmd.Run()56}57func main() {

getConfig

Using AI Code Generation

1import (2type Command struct {3}4func (cmd *Command) getConfig() string {5}6func main() {7	cmd := Command{}8	fmt.Println(cmd.getConfig())9}10import (11func main() {12	cmd := Command{}13	fmt.Println(cmd.getConfig())14}15import (16type Command struct {17}18func (cmd *Command) getConfig() string {19}20func main() {21	cmd := Command{}22	fmt.Println(cmd.getConfig())23}24import (25func main() {26	cmd := Command{}27	fmt.Println(cmd.getConfig())28}29import (30type Command struct {31}32func (cmd *Command) getConfig() string {33}34func main() {35	cmd := Command{}36	fmt.Println(cmd.getConfig())37}38import (39func main() {40	cmd := Command{}41	fmt.Println(cmd.getConfig())42}43import (44type Command struct {45}46func (cmd *Command) getConfig() string {47}48func main() {49	cmd := Command{}50	fmt.Println(cmd.getConfig())51}52import (53func main() {54	cmd := Command{}55	fmt.Println(cmd.getConfig())56}57import (58type Command struct {59}60func (cmd *Command) getConfig() string {61}62func main() {63	cmd := Command{}64	fmt.Println(cmd.getConfig())65}66import (67func main() {68	cmd := Command{}69	fmt.Println(cmd.getConfig())70}71import (72type Command struct {73}74func (cmd *Command) getConfig() string {75}76func main() {77	cmd := Command{}78	fmt.Println(cmd.getConfig())79}80import (

getConfig

Using AI Code Generation

1import "fmt"2func main() {3  configObj.getConfig()4}5import "fmt"6func main() {7  configObj.getConfig()8}9import "fmt"10func main() {11  configObj.getConfig()12}13import "fmt"14func main() {15  configObj.getConfig()16}17import "fmt"18func main() {19  configObj.getConfig()20}21import "fmt"22func main() {23  configObj.getConfig()24}25import "fmt"26func main() {27  configObj.getConfig()28}29import "fmt"30func main() {31  configObj.getConfig()32}33import "fmt"34func main() {35  configObj.getConfig()36}37import "fmt"38func main() {39  configObj.getConfig()40}41import "fmt"42func main() {43  configObj.getConfig()44}45import "fmt"46func main() {47  configObj.getConfig()48}49import "fmt"50func main() {

getConfig

Using AI Code Generation

1cmd := exec.Command("go", "run", "1.go")2cmd.Env = os.Environ()3cmd.Env = append(cmd.Env, "GOPATH=/home/abhishek/Desktop/GoLang")4err := cmd.Run()5if err != nil {6    fmt.Println(fmt.Sprint(err) + ": " + stderr.String())7}8fmt.Println("Result: " + out.String())9cmd := exec.Command("go", "run", "1.go")10cmd.Env = os.Environ()11cmd.Env = append(cmd.Env, "GOPATH=/home/abhishek/Desktop/GoLang")12err := cmd.Run()13if err != nil {14    fmt.Println(fmt.Sprint(err) + ": " + stderr.String())15}16fmt.Println("Result: " + out.String())17cmd := exec.Command("go", "run", "1.go")18cmd.Env = os.Environ()19cmd.Env = append(cmd.Env, "GOPATH=/home/abhishek/Desktop/GoLang")20err := cmd.Run()21if err != nil {22    fmt.Println(fmt.Sprint(err) + ": " + stderr.String())23}24fmt.Println("Result: " + out.String())25cmd := exec.Command("go", "run", "1.go")26cmd.Env = os.Environ()27cmd.Env = append(cmd.Env, "GOPATH=/home/abhishek/Desktop/GoLang")28err := cmd.Run()29if err != nil {30    fmt.Println(fmt.Sprint(err)

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.