1package txselector
  2
  3import (
  4	"io/ioutil"
  5	"os"
  6	"strconv"
  7	"testing"
  8	"time"
  9
 10	ethCommon "github.com/ethereum/go-ethereum/common"
 11	"github.com/hermeznetwork/hermez-node/common"
 12	dbUtils "github.com/hermeznetwork/hermez-node/db"
 13	"github.com/hermeznetwork/hermez-node/db/historydb"
 14	"github.com/hermeznetwork/hermez-node/db/l2db"
 15	"github.com/hermeznetwork/hermez-node/db/statedb"
 16	"github.com/hermeznetwork/hermez-node/test"
 17	"github.com/hermeznetwork/hermez-node/test/til"
 18	"github.com/jmoiron/sqlx"
 19	"github.com/stretchr/testify/assert"
 20	"github.com/stretchr/testify/require"
 21)
 22
 23func initTest(t *testing.T, chainID uint16, testSet string) *TxSelector {
 24	pass := os.Getenv("POSTGRES_PASS")
 25	db, err := dbUtils.InitSQLDB(5432, "localhost", "hermez", pass, "hermez")
 26	require.NoError(t, err)
 27	l2DB := l2db.NewL2DB(db, 10, 100, 24*time.Hour)
 28
 29	dir, err := ioutil.TempDir("", "tmpdb")
 30	require.NoError(t, err)
 31	defer assert.NoError(t, os.RemoveAll(dir))
 32	sdb, err := statedb.NewStateDB(dir, 128, statedb.TypeTxSelector, 0, chainID)
 33	require.NoError(t, err)
 34
 35	txselDir, err := ioutil.TempDir("", "tmpTxSelDB")
 36	require.NoError(t, err)
 37	defer assert.NoError(t, os.RemoveAll(dir))
 38
 39	coordAccount := &CoordAccount{ // TODO TMP
 40		Addr:                ethCommon.HexToAddress("0xc58d29fA6e86E4FAe04DDcEd660d45BCf3Cb2370"),
 41		BJJ:                 common.EmptyBJJComp,
 42		AccountCreationAuth: nil,
 43	}
 44
 45	txsel, err := NewTxSelector(coordAccount, txselDir, sdb, l2DB)
 46	require.NoError(t, err)
 47
 48	return txsel
 49}
 50func addL2Txs(t *testing.T, txsel *TxSelector, poolL2Txs []common.PoolL2Tx) {
 51	for i := 0; i < len(poolL2Txs); i++ {
 52		err := txsel.l2db.AddTxTest(&poolL2Txs[i])
 53		require.NoError(t, err)
 54	}
 55}
 56
 57func addTokens(t *testing.T, tokens []common.Token, db *sqlx.DB) {
 58	hdb := historydb.NewHistoryDB(db)
 59	test.WipeDB(hdb.DB())
 60	assert.NoError(t, hdb.AddBlock(&common.Block{
 61		Num: 1,
 62	}))
 63	assert.NoError(t, hdb.AddTokens(tokens))
 64}
 65
 66func TestCoordIdxsDB(t *testing.T) {
 67	chainID := uint16(0)
 68	txsel := initTest(t, chainID, til.SetPool0)
 69	test.WipeDB(txsel.l2db.DB())
 70
 71	coordIdxs := make(map[common.TokenID]common.Idx)
 72	coordIdxs[common.TokenID(0)] = common.Idx(256)
 73	coordIdxs[common.TokenID(1)] = common.Idx(257)
 74	coordIdxs[common.TokenID(2)] = common.Idx(258)
 75
 76	err := txsel.AddCoordIdxs(coordIdxs)
 77	assert.NoError(t, err)
 78
 79	r, err := txsel.GetCoordIdxs()
 80	assert.NoError(t, err)
 81	assert.Equal(t, coordIdxs, r)
 82}
 83
 84func TestGetL2TxSelection(t *testing.T) {
 85	chainID := uint16(0)
 86	txsel := initTest(t, chainID, til.SetPool0)
 87	test.WipeDB(txsel.l2db.DB())
 88
 89	tc := til.NewContext(chainID, common.RollupConstMaxL1UserTx)
 90	// generate test transactions
 91	blocks, err := tc.GenerateBlocks(til.SetBlockchain0)
 92	assert.NoError(t, err)
 93	// poolL2Txs, err := tc.GeneratePoolL2Txs(til.SetPool0)
 94	// assert.NoError(t, err)
 95
 96	coordIdxs := make(map[common.TokenID]common.Idx)
 97	coordIdxs[common.TokenID(0)] = common.Idx(256)
 98	coordIdxs[common.TokenID(1)] = common.Idx(257)
 99	coordIdxs[common.TokenID(2)] = common.Idx(258)
100	coordIdxs[common.TokenID(3)] = common.Idx(259)
101	err = txsel.AddCoordIdxs(coordIdxs)
102	assert.NoError(t, err)
103
104	// add tokens to HistoryDB to avoid breaking FK constrains
105	var tokens []common.Token
106	for i := 0; i < int(tc.LastRegisteredTokenID); i++ {
107		tokens = append(tokens, common.Token{
108			TokenID:     common.TokenID(i + 1),
109			EthBlockNum: 1,
110			EthAddr:     ethCommon.BytesToAddress([]byte{byte(i + 1)}),
111			Name:        strconv.Itoa(i),
112			Symbol:      strconv.Itoa(i),
113			Decimals:    18,
114		})
115	}
116	addTokens(t, tokens, txsel.l2db.DB())
117
118	ptc := statedb.ProcessTxsConfig{
119		NLevels:  32,
120		MaxFeeTx: 64,
121		MaxTx:    512,
122		MaxL1Tx:  64,
123	}
124	selectionConfig := &SelectionConfig{
125		MaxL1UserTxs:        32,
126		MaxL1CoordinatorTxs: 32,
127		ProcessTxsConfig:    ptc,
128	}
129
130	// Process the 1st batch, which contains the L1CoordinatorTxs necessary
131	// to create the Coordinator accounts to receive the fees
132	_, err = txsel.localAccountsDB.ProcessTxs(ptc, nil, nil, blocks[0].Rollup.Batches[0].L1CoordinatorTxs, nil)
133	require.NoError(t, err)
134
135	// add the 1st batch of transactions to the TxSelector
136	addL2Txs(t, txsel, common.L2TxsToPoolL2Txs(blocks[0].Rollup.Batches[0].L2Txs))
137
138	_, _, l1CoordTxs, l2Txs, err := txsel.GetL2TxSelection(selectionConfig, 0)
139	assert.NoError(t, err)
140	assert.Equal(t, 0, len(l2Txs))
141	assert.Equal(t, 0, len(l1CoordTxs))
142
143	_, _, _, _, _, err = txsel.GetL1L2TxSelection(selectionConfig, 0, blocks[0].Rollup.L1UserTxs)
144	assert.NoError(t, err)
145
146	// TODO once L2DB is updated to return error in case that AddTxTest
147	// fails, and the Til is updated, update this test, checking that the
148	// selected PoolL2Tx are correctly sorted by Nonce
149
150	// TODO once L2DB is updated to store the parameter AbsoluteFee (which
151	// is used by TxSelector to sort L2Txs), uncomment this next lines of
152	// test, and put the expected value for
153	// l2Txs[len(l2Txs)-1].AbsoluteFee, which is the Tx which has the
154	// Fee==192.
155	/*
156		// add the 3rd batch of transactions to the TxSelector
157		addL2Txs(t, txsel, common.L2TxsToPoolL2Txs(blocks[0].Batches[2].L2Txs))
158
159		_, l2Txs, err = txsel.GetL2TxSelection(coordIdxs, 0)
160		assert.NoError(t, err)
161		for _, tx := range l2Txs {
162			fmt.Println(tx.FromIdx, tx.ToIdx, tx.AbsoluteFee)
163		}
164		require.Equal(t, 10, len(l2Txs))
165		assert.Equal(t, float64(0), l2Txs[0].AbsoluteFee)
166
167		fmt.Println(l2Txs[len(l2Txs)-1].Amount)
168		assert.Equal(t, float64(4), l2Txs[len(l2Txs)-1].AbsoluteFee)
169	*/
170}