diff --git a/apps/poa/poa.go b/apps/poa/poa.go
index 4b9d6823..1f1e8f7c 100644
--- a/apps/poa/poa.go
+++ b/apps/poa/poa.go
@@ -245,6 +245,11 @@ func (h *Poa) AmILeader(blockHeight BlockNum) bool {
 	return h.CompeteLeader(blockHeight) == h.LocalAddress()
 }
 
+func (h *Poa) IsValidator(addr Address) bool {
+	_, ok := h.validatorsMap[addr]
+	return ok
+}
+
 func (h *Poa) useP2pOrSkip(localBlock *Block) bool {
 LOOP:
 	select {
diff --git a/apps/poa/poa_test.go b/apps/poa/poa_test.go
index ca5d09a6..074b37ac 100644
--- a/apps/poa/poa_test.go
+++ b/apps/poa/poa_test.go
@@ -29,15 +29,15 @@ var (
 
 func initGlobalVars() {
 	myPubkey1, myPrivkey1, validators = InitDefaultKeypairs(0)
-	node1 = newPoa(myPubkey1, myPrivkey1, validators)
+	node1 = newPoa(myPubkey1, myPrivkey1, validators, 3)
 	println("addr1 = ", myPubkey1.Address().String())
 
 	myPubkey2, myPrivkey2, validators = InitDefaultKeypairs(1)
-	node2 = newPoa(myPubkey2, myPrivkey2, validators)
+	node2 = newPoa(myPubkey2, myPrivkey2, validators, 3)
 	println("addr2 = ", myPubkey2.Address().String())
 
 	myPubkey3, myPrivkey3, validators = InitDefaultKeypairs(2)
-	node3 = newPoa(myPubkey3, myPrivkey3, validators)
+	node3 = newPoa(myPubkey3, myPrivkey3, validators, 3)
 	println("addr3 = ", myPubkey3.Address().String())
 }
 
@@ -116,14 +116,14 @@ func TestChainNet(t *testing.T) {
 
 	wg := &sync.WaitGroup{}
 	wg.Add(3)
-	go runNode("node1", node1, mockP2P, wg)
-	go runNode("node2", node2, mockP2P, wg)
-	go runNode("node3", node3, mockP2P, wg)
+	go runNode(node1, mockP2P, wg)
+	go runNode(node2, mockP2P, wg)
+	go runNode(node3, mockP2P, wg)
 	wg.Wait()
 }
 
-func runNode(cfgPath string, poaNode *Poa, mockP2P *p2p.MockP2p, wg *sync.WaitGroup) {
-	cfg := config.InitDefaultCfgWithDir(cfgPath)
+func runNode(poaNode *Poa, mockP2P *p2p.MockP2p, wg *sync.WaitGroup) {
+	cfg := config.InitDefaultCfg()
 
 	land := tripod.NewLand()
 	land.SetTripods(poaNode.Tripod)
@@ -136,21 +136,21 @@ func runNode(cfgPath string, poaNode *Poa, mockP2P *p2p.MockP2p, wg *sync.WaitGr
 		panic("init kvdb error: " + err.Error())
 	}
 
-	base := txdb.NewTxDB(kvdb)
-	chain := blockchain.NewBlockChain(&cfg.BlockChain, base)
+	base := txdb.NewTxDB(FullNode, kvdb)
+	chain := blockchain.NewBlockChain(FullNode, &cfg.BlockChain, base)
 	statedb := state.NewStateDB(kvdb)
 
 	env := &env.ChainEnv{
 		State:      statedb,
 		Chain:      chain,
 		TxDB:       base,
-		Pool:       txpool.WithDefaultChecks(&cfg.Txpool, base),
+		Pool:       txpool.WithDefaultChecks(FullNode, &cfg.Txpool, base),
 		Sub:        subscribe.NewSubscription(),
 		P2pNetwork: mockP2P,
 	}
 	poaNode.SetChainEnv(env)
 
-	k := kernel.NewKernel(&cfg, env, land)
+	k := kernel.NewKernel(cfg, env, land)
 	for i := 0; i < 10; i++ {
 		err := k.LocalRun()
 		if err != nil {
diff --git a/core/keypair/keypair_test.go b/core/keypair/keypair_test.go
index 0304f19c..68bf8d06 100644
--- a/core/keypair/keypair_test.go
+++ b/core/keypair/keypair_test.go
@@ -21,9 +21,9 @@ func testKey(t *testing.T, keyType string) {
 	t.Logf("public key is %s", pubkey.String())
 	t.Logf("private key is %s", privkey.String())
 	ecall := &WrCall{
-		TripodName:  "asset",
-		WritingName: "Transfer",
-		Params:      "params",
+		TripodName: "asset",
+		FuncName:   "Transfer",
+		Params:     "params",
 	}
 
 	hash, err := ecall.Hash()