1package debugapi
  2
  3import (
  4	"crypto/ecdsa"
  5	"fmt"
  6	"io/ioutil"
  7	"math/big"
  8	"net/http"
  9	"strconv"
 10	"testing"
 11
 12	"github.com/dghubble/sling"
 13	ethCrypto "github.com/ethereum/go-ethereum/crypto"
 14	"github.com/hermeznetwork/hermez-node/common"
 15	"github.com/hermeznetwork/hermez-node/db/statedb"
 16	"github.com/iden3/go-iden3-crypto/babyjub"
 17	"github.com/stretchr/testify/assert"
 18	"github.com/stretchr/testify/require"
 19	"golang.org/x/net/context"
 20)
 21
 22func newAccount(t *testing.T, i int) *common.Account {
 23	var sk babyjub.PrivateKey
 24	copy(sk[:], []byte(strconv.Itoa(i))) // only for testing
 25	pk := sk.Public()
 26
 27	var key ecdsa.PrivateKey
 28	key.D = big.NewInt(int64(i + 1)) // only for testing
 29	key.PublicKey.X, key.PublicKey.Y = ethCrypto.S256().ScalarBaseMult(key.D.Bytes())
 30	key.Curve = ethCrypto.S256()
 31	address := ethCrypto.PubkeyToAddress(key.PublicKey)
 32
 33	return &common.Account{
 34		Idx:       common.Idx(256 + i),
 35		TokenID:   common.TokenID(i),
 36		Nonce:     common.Nonce(i),
 37		Balance:   big.NewInt(1000),
 38		PublicKey: pk.Compress(),
 39		EthAddr:   address,
 40	}
 41}
 42
 43func TestDebugAPI(t *testing.T) {
 44	dir, err := ioutil.TempDir("", "tmpdb")
 45	require.Nil(t, err)
 46
 47	chainID := uint16(0)
 48	sdb, err := statedb.NewStateDB(dir, statedb.TypeSynchronizer, 32, chainID)
 49	require.Nil(t, err)
 50	err = sdb.MakeCheckpoint() // Make a checkpoint to increment the batchNum
 51	require.Nil(t, err)
 52
 53	addr := "localhost:12345"
 54	// We won't test the sync/stats endpoint, so we can se the Syncrhonizer to nil
 55	debugAPI := NewDebugAPI(addr, sdb, nil)
 56
 57	ctx, cancel := context.WithCancel(context.Background())
 58	go func() {
 59		err := debugAPI.Run(ctx)
 60		require.Nil(t, err)
 61	}()
 62
 63	var accounts []common.Account
 64	for i := 0; i < 16; i++ {
 65		account := newAccount(t, i)
 66		accounts = append(accounts, *account)
 67		_, err = sdb.CreateAccount(account.Idx, account)
 68		require.Nil(t, err)
 69	}
 70
 71	url := fmt.Sprintf("http://%v/debug/", addr)
 72
 73	var batchNum common.BatchNum
 74	req, err := sling.New().Get(url).Path("sdb/batchnum").ReceiveSuccess(&batchNum)
 75	require.Equal(t, http.StatusOK, req.StatusCode)
 76	require.Nil(t, err)
 77	assert.Equal(t, common.BatchNum(1), batchNum)
 78
 79	var mtroot *big.Int
 80	req, err = sling.New().Get(url).Path("sdb/mtroot").ReceiveSuccess(&mtroot)
 81	require.Equal(t, http.StatusOK, req.StatusCode)
 82	require.Nil(t, err)
 83	// Testing against a hardcoded value obtained by running the test and
 84	// printing the value previously.
 85	assert.Equal(t, "21765339739823365993496282904432398015268846626944509989242908567129545640185",
 86		mtroot.String())
 87
 88	var accountAPI common.Account
 89	req, err = sling.New().Get(url).
 90		Path(fmt.Sprintf("sdb/accounts/%v", accounts[0].Idx)).
 91		ReceiveSuccess(&accountAPI)
 92	require.Equal(t, http.StatusOK, req.StatusCode)
 93	require.Nil(t, err)
 94	assert.Equal(t, accounts[0], accountAPI)
 95
 96	var accountsAPI []common.Account
 97	req, err = sling.New().Get(url).Path("sdb/accounts").ReceiveSuccess(&accountsAPI)
 98	require.Equal(t, http.StatusOK, req.StatusCode)
 99	require.Nil(t, err)
100	assert.Equal(t, accounts, accountsAPI)
101
102	cancel()
103}