• R/O
  • HTTP
  • SSH
  • HTTPS

vapor: Commit

Golang implemented sidechain for Bytom


Commit MetaInfo

Revision3ada9e64ef1536fcabc9b1c4a0a2053b8a974c5a (tree)
Time2019-07-05 05:17:37
AuthorChengcheng Zhang <943420582@qq.c...>
CommiterChengcheng Zhang

Log Message

update TestMemPoolTxQueryLoop

Change Summary

Incremental Difference

--- a/wallet/wallet_test.go
+++ b/wallet/wallet_test.go
@@ -157,92 +157,6 @@ func TestWalletVersion(t *testing.T) {
157157 // }
158158 // }
159159
160-// func TestMemPoolTxQueryLoop(t *testing.T) {
161-// dirPath, err := ioutil.TempDir(".", "")
162-// if err != nil {
163-// t.Fatal(err)
164-// }
165-// config.CommonConfig = config.DefaultConfig()
166-// testDB := dbm.NewDB("testdb", "leveldb", dirPath)
167-// defer func() {
168-// testDB.Close()
169-// os.RemoveAll(dirPath)
170-// }()
171-
172-// store := database.NewStore(testDB)
173-// // store := newMockStore(testDB)
174-// dispatcher := event.NewDispatcher()
175-// txPool := protocol.NewTxPool(store, dispatcher)
176-
177-// chain, err := protocol.NewChain(store, txPool, dispatcher)
178-// if err != nil {
179-// t.Fatal(err)
180-// }
181-
182-// accountStore := NewMockAccountStore(testDB)
183-// accountManager := account.NewManager(accountStore, chain)
184-// hsm, err := pseudohsm.New(dirPath)
185-// if err != nil {
186-// t.Fatal(err)
187-// }
188-
189-// xpub1, _, err := hsm.XCreate("test_pub1", "password", "en")
190-// if err != nil {
191-// t.Fatal(err)
192-// }
193-
194-// testAccount, err := accountManager.Create([]chainkd.XPub{xpub1.XPub}, 1, "testAccount", signers.BIP0044)
195-// if err != nil {
196-// t.Fatal(err)
197-// }
198-
199-// controlProg, err := accountManager.CreateAddress(testAccount.ID, false)
200-// if err != nil {
201-// t.Fatal(err)
202-// }
203-
204-// controlProg.KeyIndex = 1
205-
206-// reg := asset.NewRegistry(testDB, chain)
207-// asset := bc.AssetID{V0: 5}
208-
209-// utxos := []*account.UTXO{}
210-// btmUtxo := mockUTXO(controlProg, consensus.BTMAssetID)
211-// utxos = append(utxos, btmUtxo)
212-// OtherUtxo := mockUTXO(controlProg, &asset)
213-// utxos = append(utxos, OtherUtxo)
214-
215-// _, txData, err := mockTxData(utxos, testAccount)
216-// if err != nil {
217-// t.Fatal(err)
218-// }
219-
220-// tx := types.NewTx(*txData)
221-// //block := mockSingleBlock(tx)
222-// txStatus := bc.NewTransactionStatus()
223-// txStatus.SetStatus(0, false)
224-// walletStore := NewMockWalletStore(testDB)
225-// w, err := NewWallet(walletStore, accountManager, reg, hsm, chain, dispatcher, false)
226-// go w.MemPoolTxQueryLoop()
227-// w.EventDispatcher.Post(protocol.TxMsgEvent{TxMsg: &protocol.TxPoolMsg{TxDesc: &protocol.TxDesc{Tx: tx}, MsgType: protocol.MsgNewTx}})
228-// time.Sleep(time.Millisecond * 10)
229-// if _, err := w.GetUnconfirmedTxByTxID(tx.ID.String()); err != nil {
230-// t.Fatal("dispatch new tx msg error:", err)
231-// }
232-// w.EventDispatcher.Post(protocol.TxMsgEvent{TxMsg: &protocol.TxPoolMsg{TxDesc: &protocol.TxDesc{Tx: tx}, MsgType: protocol.MsgRemoveTx}})
233-// time.Sleep(time.Millisecond * 10)
234-// txs, err := w.GetUnconfirmedTxs(testAccount.ID)
235-// if err != nil {
236-// t.Fatal("get unconfirmed tx error:", err)
237-// }
238-
239-// if len(txs) != 0 {
240-// t.Fatal("dispatch remove tx msg error")
241-// }
242-
243-// w.EventDispatcher.Post(protocol.TxMsgEvent{TxMsg: &protocol.TxPoolMsg{TxDesc: &protocol.TxDesc{Tx: tx}, MsgType: 2}})
244-// }
245-
246160 func mockUTXO(controlProg *account.CtrlProgram, assetID *bc.AssetID) *account.UTXO {
247161 utxo := &account.UTXO{}
248162 utxo.OutputID = bc.Hash{V0: 1}
Show on old repository browser