netsync/chainmgr/tool_test.go

   1 package chainmgr
   2
   3 import (
   4         "errors"
   5         "math/rand"
   6         "net"
   7
   8         "github.com/tendermint/go-wire"
   9         "github.com/tendermint/tmlibs/flowrate"
  10
  11         "github.com/vapor/consensus"
  12         "github.com/vapor/netsync/peers"
  13         "github.com/vapor/protocol/bc"
  14         "github.com/vapor/protocol/bc/types"
  15         "github.com/vapor/test/mock"
  16 )
  17
  18 type P2PPeer struct {
  19         id   string
  20         ip   *net.IPAddr
  21         flag consensus.ServiceFlag
  22
  23         srcPeer    *P2PPeer
  24         remoteNode *Manager
  25         msgCh      chan []byte
  26         async      bool
  27 }
  28
  29 func NewP2PPeer(addr, id string, flag consensus.ServiceFlag) *P2PPeer {
  30         return &P2PPeer{
  31                 id:    id,
  32                 ip:    &net.IPAddr{IP: net.ParseIP(addr)},
  33                 flag:  flag,
  34                 msgCh: make(chan []byte),
  35                 async: false,
  36         }
  37 }
  38
  39 func (p *P2PPeer) Addr() net.Addr {
  40         return p.ip
  41 }
  42
  43 func (p *P2PPeer) ID() string {
  44         return p.id
  45 }
  46
  47 func (p *P2PPeer) IsLAN() bool {
  48         return false
  49 }
  50
  51 func (p *P2PPeer) RemoteAddrHost() string {
  52         return ""
  53 }
  54
  55 func (p *P2PPeer) ServiceFlag() consensus.ServiceFlag {
  56         return p.flag
  57 }
  58
  59 func (p *P2PPeer) SetConnection(srcPeer *P2PPeer, node *Manager) {
  60         p.srcPeer = srcPeer
  61         p.remoteNode = node
  62 }
  63
  64 func (p *P2PPeer) TrafficStatus() (*flowrate.Status, *flowrate.Status) {
  65         return nil, nil
  66 }
  67
  68 func (p *P2PPeer) TrySend(b byte, msg interface{}) bool {
  69         msgBytes := wire.BinaryBytes(msg)
  70         if p.async {
  71                 p.msgCh <- msgBytes
  72         } else {
  73                 msgType, msg, _ := decodeMessage(msgBytes)
  74                 p.remoteNode.processMsg(p.srcPeer, msgType, msg)
  75         }
  76         return true
  77 }
  78
  79 func (p *P2PPeer) setAsync(b bool) {
  80         p.async = b
  81 }
  82
  83 func (p *P2PPeer) postMan() {
  84         for msgBytes := range p.msgCh {
  85                 msgType, msg, _ := decodeMessage(msgBytes)
  86                 p.remoteNode.processMsg(p.srcPeer, msgType, msg)
  87         }
  88 }
  89
  90 type PeerSet struct{}
  91
  92 func NewPeerSet() *PeerSet {
  93         return &PeerSet{}
  94 }
  95
  96 func (ps *PeerSet) IsBanned(ip string, level byte, reason string) bool {
  97         return false
  98 }
  99
 100 func (ps *PeerSet) StopPeerGracefully(string) {}
 101
 102 type NetWork struct {
 103         nodes map[*Manager]P2PPeer
 104 }
 105
 106 func NewNetWork() *NetWork {
 107         return &NetWork{map[*Manager]P2PPeer{}}
 108 }
 109
 110 func (nw *NetWork) Register(node *Manager, addr, id string, flag consensus.ServiceFlag) {
 111         peer := NewP2PPeer(addr, id, flag)
 112         nw.nodes[node] = *peer
 113 }
 114
 115 func (nw *NetWork) HandsShake(nodeA, nodeB *Manager) (*P2PPeer, *P2PPeer, error) {
 116         B2A, ok := nw.nodes[nodeA]
 117         if !ok {
 118                 return nil, nil, errors.New("can't find nodeA's p2p peer on network")
 119         }
 120         A2B, ok := nw.nodes[nodeB]
 121         if !ok {
 122                 return nil, nil, errors.New("can't find nodeB's p2p peer on network")
 123         }
 124
 125         A2B.SetConnection(&B2A, nodeB)
 126         B2A.SetConnection(&A2B, nodeA)
 127
 128         nodeA.AddPeer(&A2B)
 129         nodeB.AddPeer(&B2A)
 130         nodeA.SendStatus(B2A.srcPeer)
 131         nodeB.SendStatus(A2B.srcPeer)
 132         A2B.setAsync(true)
 133         B2A.setAsync(true)
 134         return &B2A, &A2B, nil
 135 }
 136
 137 func mockBlocks(startBlock *types.Block, height uint64) []*types.Block {
 138         blocks := []*types.Block{}
 139         indexBlock := &types.Block{}
 140         if startBlock == nil {
 141                 indexBlock = &types.Block{BlockHeader: types.BlockHeader{Version: uint64(rand.Uint32())}}
 142                 blocks = append(blocks, indexBlock)
 143         } else {
 144                 indexBlock = startBlock
 145         }
 146
 147         for indexBlock.Height < height {
 148                 block := &types.Block{
 149                         BlockHeader: types.BlockHeader{
 150                                 Height:            indexBlock.Height + 1,
 151                                 PreviousBlockHash: indexBlock.Hash(),
 152                                 Version:           uint64(rand.Uint32()),
 153                         },
 154                 }
 155                 blocks = append(blocks, block)
 156                 indexBlock = block
 157         }
 158         return blocks
 159 }
 160
 161 func mockSync(blocks []*types.Block, mempool *mock.Mempool) *Manager {
 162         chain := mock.NewChain(mempool)
 163         peers := peers.NewPeerSet(NewPeerSet())
 164         chain.SetBestBlockHeader(&blocks[len(blocks)-1].BlockHeader)
 165         for _, block := range blocks {
 166                 chain.SetBlockByHeight(block.Height, block)
 167         }
 168
 169         return &Manager{
 170                 chain:       chain,
 171                 blockKeeper: newBlockKeeper(chain, peers),
 172                 peers:       peers,
 173                 mempool:     mempool,
 174                 txSyncCh:    make(chan *txSyncMsg),
 175         }
 176 }
 177
 178 func mockTxs(txCount int) ([]*types.Tx, []*bc.Tx) {
 179         var txs []*types.Tx
 180         var bcTxs []*bc.Tx
 181         trueProg := mockControlProgram(60)
 182         assetID := bc.AssetID{V0: 9999}
 183         for i := uint64(0); i < uint64(txCount); i++ {
 184                 tx := types.NewTx(types.TxData{
 185                         Version: 1,
 186                         Inputs:  []*types.TxInput{types.NewSpendInput(nil, bc.Hash{V0: i + 1}, assetID, i, i, trueProg)},
 187                         Outputs: []*types.TxOutput{types.NewIntraChainOutput(assetID, 1, trueProg)},
 188                 })
 189                 txs = append(txs, tx)
 190                 bcTxs = append(bcTxs, tx.Tx)
 191         }
 192         return txs, bcTxs
 193 }
 194
 195 func mockControlProgram(length int) []byte {
 196         var cp []byte
 197         for i := 0; i < length; i++ {
 198                 cp = append(cp, byte(rand.Intn(1<<8)))
 199         }
 200         return cp
 201 }