Commit ec3bd2ee authored by vipwzw's avatar vipwzw

auto ci

parent c8a9694d
...@@ -62,7 +62,7 @@ func getMiners(detail *pt.ParacrossStatusDetails, blockHash []byte) []string { ...@@ -62,7 +62,7 @@ func getMiners(detail *pt.ParacrossStatusDetails, blockHash []byte) []string {
// //
func mergeReceipt(receipt1, receipt2 *types.Receipt) *types.Receipt { func mergeReceipt(receipt1, receipt2 *types.Receipt) *types.Receipt {
if receipt2 != nil{ if receipt2 != nil {
receipt1.KV = append(receipt1.KV, receipt2.KV...) receipt1.KV = append(receipt1.KV, receipt2.KV...)
receipt1.Logs = append(receipt1.Logs, receipt2.Logs...) receipt1.Logs = append(receipt1.Logs, receipt2.Logs...)
} }
......
...@@ -463,14 +463,14 @@ func (a *action) nodeVote(config *pt.ParaNodeAddrConfig) (*types.Receipt, error) ...@@ -463,14 +463,14 @@ func (a *action) nodeVote(config *pt.ParaNodeAddrConfig) (*types.Receipt, error)
if err != nil { if err != nil {
return nil, err return nil, err
} }
receipt = mergeReceipt(receipt,r) receipt = mergeReceipt(receipt, r)
stat.Status = pt.ParacrossNodeQuited stat.Status = pt.ParacrossNodeQuited
if !types.IsPara() { if !types.IsPara() {
r, err := a.nodeGroupCoinsActive(stat.FromAddr, stat.CoinsFrozen, 1) r, err := a.nodeGroupCoinsActive(stat.FromAddr, stat.CoinsFrozen, 1)
if err != nil { if err != nil {
return nil, err return nil, err
} }
receipt = mergeReceipt(receipt,r) receipt = mergeReceipt(receipt, r)
} }
} }
} else { } else {
...@@ -480,29 +480,29 @@ func (a *action) nodeVote(config *pt.ParaNodeAddrConfig) (*types.Receipt, error) ...@@ -480,29 +480,29 @@ func (a *action) nodeVote(config *pt.ParaNodeAddrConfig) (*types.Receipt, error)
return nil, err return nil, err
} }
stat.Status = pt.ParacrossNodeJoined stat.Status = pt.ParacrossNodeJoined
receipt = mergeReceipt(receipt,r) receipt = mergeReceipt(receipt, r)
} else if stat.Status == pt.ParacrossNodeQuiting { } else if stat.Status == pt.ParacrossNodeQuiting {
r, err := unpdateNodeGroup(a.db, config.Title, stat.TargetAddr, false) r, err := unpdateNodeGroup(a.db, config.Title, stat.TargetAddr, false)
if err != nil { if err != nil {
return nil, err return nil, err
} }
stat.Status = pt.ParacrossNodeQuited stat.Status = pt.ParacrossNodeQuited
receipt = mergeReceipt(receipt,r) receipt = mergeReceipt(receipt, r)
if !types.IsPara() { if !types.IsPara() {
r, err := a.nodeGroupCoinsActive(stat.FromAddr, stat.CoinsFrozen, 1) r, err := a.nodeGroupCoinsActive(stat.FromAddr, stat.CoinsFrozen, 1)
if err != nil { if err != nil {
return nil, err return nil, err
} }
receipt = mergeReceipt(receipt,r) receipt = mergeReceipt(receipt, r)
} }
} }
} }
r := makeNodeConfigReceipt(a.fromaddr, config, &copyStat, stat) r := makeNodeConfigReceipt(a.fromaddr, config, &copyStat, stat)
receipt = mergeReceipt(receipt,r) receipt = mergeReceipt(receipt, r)
receiptDone := makeVoteDoneReceipt(stat, len(nodes), len(stat.Votes.Addrs), most, pt.ParaNodeVoteStr[vote], stat.Status) receiptDone := makeVoteDoneReceipt(stat, len(nodes), len(stat.Votes.Addrs), most, pt.ParaNodeVoteStr[vote], stat.Status)
receipt = mergeReceipt(receipt,receiptDone) receipt = mergeReceipt(receipt, receiptDone)
return receipt, nil return receipt, nil
} }
......
...@@ -125,7 +125,6 @@ func checkGroupApproveReceipt(suite *NodeManageTestSuite, receipt *types.Receipt ...@@ -125,7 +125,6 @@ func checkGroupApproveReceipt(suite *NodeManageTestSuite, receipt *types.Receipt
len := len(receipt.KV) len := len(receipt.KV)
var stat pt.ParaNodeIdStatus var stat pt.ParaNodeIdStatus
err := types.Decode(receipt.KV[len-1].Value, &stat) err := types.Decode(receipt.KV[len-1].Value, &stat)
assert.Nil(suite.T(), err, "decode ParaNodeAddrStatus failed") assert.Nil(suite.T(), err, "decode ParaNodeAddrStatus failed")
...@@ -179,8 +178,7 @@ func checkVoteDoneReceipt(suite *NodeManageTestSuite, receipt *types.Receipt, co ...@@ -179,8 +178,7 @@ func checkVoteDoneReceipt(suite *NodeManageTestSuite, receipt *types.Receipt, co
suite.NotNil(receipt) suite.NotNil(receipt)
assert.Equal(suite.T(), receipt.Ty, int32(types.ExecOk)) assert.Equal(suite.T(), receipt.Ty, int32(types.ExecOk))
suite.T().Log("checkVoteDoneReceipt", "kvlen", len(receipt.KV))
suite.T().Log("checkVoteDoneReceipt","kvlen",len(receipt.KV))
_, arry, err := getParacrossNodes(suite.stateDB, Title) _, arry, err := getParacrossNodes(suite.stateDB, Title)
suite.Suite.Nil(err) suite.Suite.Nil(err)
...@@ -192,10 +190,10 @@ func checkVoteDoneReceipt(suite *NodeManageTestSuite, receipt *types.Receipt, co ...@@ -192,10 +190,10 @@ func checkVoteDoneReceipt(suite *NodeManageTestSuite, receipt *types.Receipt, co
} }
func voteTest(suite *NodeManageTestSuite, id string, join bool) { func voteTest(suite *NodeManageTestSuite, id string, join bool) {
var count int=1 var count int = 1
config := &pt.ParaNodeAddrConfig{ config := &pt.ParaNodeAddrConfig{
Op: pt.ParaNodeVote, Op: pt.ParaNodeVote,
Id: id, Id: id,
Value: pt.ParaNodeVoteYes, Value: pt.ParaNodeVoteYes,
} }
tx, err := pt.CreateRawNodeConfigTx(config) tx, err := pt.CreateRawNodeConfigTx(config)
...@@ -209,7 +207,7 @@ func voteTest(suite *NodeManageTestSuite, id string, join bool) { ...@@ -209,7 +207,7 @@ func voteTest(suite *NodeManageTestSuite, id string, join bool) {
checkVoteReceipt(suite, receipt, count) checkVoteReceipt(suite, receipt, count)
count++ count++
if !join{ if !join {
receipt = nodeCommit(suite, PrivKey14K, tx) receipt = nodeCommit(suite, PrivKey14K, tx)
checkVoteReceipt(suite, receipt, count) checkVoteReceipt(suite, receipt, count)
count++ count++
...@@ -230,14 +228,14 @@ func (suite *NodeManageTestSuite) testNodeGroupConfigQuit() { ...@@ -230,14 +228,14 @@ func (suite *NodeManageTestSuite) testNodeGroupConfigQuit() {
receipt := nodeCommit(suite, PrivKeyB, tx) receipt := nodeCommit(suite, PrivKeyB, tx)
checkGroupApplyReceipt(suite, receipt) checkGroupApplyReceipt(suite, receipt)
suite.Equal(int32(pt.TyLogParaNodeGroupConfig),receipt.Logs[0].Ty) suite.Equal(int32(pt.TyLogParaNodeGroupConfig), receipt.Logs[0].Ty)
var g pt.ReceiptParaNodeGroupConfig var g pt.ReceiptParaNodeGroupConfig
err = types.Decode(receipt.Logs[0].Log, &g) err = types.Decode(receipt.Logs[0].Log, &g)
suite.Nil(err) suite.Nil(err)
config = &pt.ParaNodeGroupConfig{ config = &pt.ParaNodeGroupConfig{
Id: g.Current.Id, Id: g.Current.Id,
Op: pt.ParacrossNodeGroupQuit, Op: pt.ParacrossNodeGroupQuit,
} }
tx, err = pt.CreateRawNodeGroupApplyTx(config) tx, err = pt.CreateRawNodeGroupApplyTx(config)
suite.Nil(err) suite.Nil(err)
...@@ -260,15 +258,14 @@ func (suite *NodeManageTestSuite) testNodeGroupConfig() { ...@@ -260,15 +258,14 @@ func (suite *NodeManageTestSuite) testNodeGroupConfig() {
receipt := nodeCommit(suite, PrivKeyB, tx) receipt := nodeCommit(suite, PrivKeyB, tx)
checkGroupApplyReceipt(suite, receipt) checkGroupApplyReceipt(suite, receipt)
suite.Equal(int32(pt.TyLogParaNodeGroupConfig),receipt.Logs[0].Ty) suite.Equal(int32(pt.TyLogParaNodeGroupConfig), receipt.Logs[0].Ty)
var g pt.ReceiptParaNodeGroupConfig var g pt.ReceiptParaNodeGroupConfig
err = types.Decode(receipt.Logs[0].Log, &g) err = types.Decode(receipt.Logs[0].Log, &g)
suite.Nil(err) suite.Nil(err)
config = &pt.ParaNodeGroupConfig{ config = &pt.ParaNodeGroupConfig{
Id: g.Current.Id, Id: g.Current.Id,
Op: pt.ParacrossNodeGroupApprove, Op: pt.ParacrossNodeGroupApprove,
} }
tx, err = pt.CreateRawNodeGroupApplyTx(config) tx, err = pt.CreateRawNodeGroupApplyTx(config)
suite.Nil(err) suite.Nil(err)
...@@ -290,7 +287,7 @@ func (suite *NodeManageTestSuite) testNodeConfig() { ...@@ -290,7 +287,7 @@ func (suite *NodeManageTestSuite) testNodeConfig() {
receipt := nodeCommit(suite, PrivKey14K, tx) receipt := nodeCommit(suite, PrivKey14K, tx)
checkJoinReceipt(suite, receipt) checkJoinReceipt(suite, receipt)
suite.Equal(int32(pt.TyLogParaNodeConfig),receipt.Logs[0].Ty) suite.Equal(int32(pt.TyLogParaNodeConfig), receipt.Logs[0].Ty)
var g pt.ReceiptParaNodeConfig var g pt.ReceiptParaNodeConfig
err = types.Decode(receipt.Logs[0].Log, &g) err = types.Decode(receipt.Logs[0].Log, &g)
suite.Nil(err) suite.Nil(err)
...@@ -300,7 +297,7 @@ func (suite *NodeManageTestSuite) testNodeConfig() { ...@@ -300,7 +297,7 @@ func (suite *NodeManageTestSuite) testNodeConfig() {
//Quit test //Quit test
config = &pt.ParaNodeAddrConfig{ config = &pt.ParaNodeAddrConfig{
Op: pt.ParaNodeQuit, Op: pt.ParaNodeQuit,
Id: g.Current.Id, Id: g.Current.Id,
} }
tx, err = pt.CreateRawNodeConfigTx(config) tx, err = pt.CreateRawNodeConfigTx(config)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment