API add get state

api/state_test.go

@@ -0,0 +1,79 @@
+package api
+
+import (
+	"testing"
+	"time"
+
+	"github.com/hermeznetwork/hermez-node/common"
+	"github.com/stretchr/testify/assert"
+)
+
+const secondsPerBlock = 15
+
+func TestSetRollupVariables(t *testing.T) {
+	rollupVars := &common.RollupVariables{}
+	assert.Equal(t, *rollupVars, api.status.Rollup)
+	api.SetRollupVariables(tc.rollupVars)
+	assert.Equal(t, tc.rollupVars, api.status.Rollup)
+}
+
+func TestSetWDelayerVariables(t *testing.T) {
+	wdelayerVars := &common.WDelayerVariables{}
+	assert.Equal(t, *wdelayerVars, api.status.WithdrawalDelayer)
+	api.SetWDelayerVariables(tc.wdelayerVars)
+	assert.Equal(t, tc.wdelayerVars, api.status.WithdrawalDelayer)
+}
+
+func TestSetAuctionVariables(t *testing.T) {
+	auctionVars := &common.AuctionVariables{}
+	assert.Equal(t, *auctionVars, api.status.Auction)
+	api.SetAuctionVariables(tc.auctionVars)
+	assert.Equal(t, tc.auctionVars, api.status.Auction)
+}
+
+func TestNextForgers(t *testing.T) {
+	// It's assumed that bids for each slot will be received in increasing order
+	bestBids := make(map[int64]testBid)
+	for j := range tc.bids {
+		bestBids[tc.bids[j].SlotNum] = tc.bids[j]
+	}
+	lastBlock := tc.blocks[len(tc.blocks)-1]
+	for i := int64(0); i < tc.slots[len(tc.slots)-1].SlotNum; i++ {
+		lastClosedSlot := i + int64(api.status.Auction.ClosedAuctionSlots)
+		nextForgers, err := api.GetNextForgers(tc.blocks[len(tc.blocks)-1], i, lastClosedSlot)
+		assert.NoError(t, err)
+		for j := i; j <= lastClosedSlot; j++ {
+			for q := range nextForgers {
+				if nextForgers[q].Period.SlotNum == j {
+					if nextForgers[q].Coordinator.ItemID != 0 {
+						assert.Equal(t, bestBids[j].Bidder, nextForgers[q].Coordinator.Bidder)
+					} else {
+						assert.Equal(t, bootCoordinator.Bidder, nextForgers[q].Coordinator.Bidder)
+					}
+					firstBlockSlot, lastBlockSlot := api.getFirstLastBlock(j)
+					fromTimestamp := lastBlock.Timestamp.Add(time.Second * time.Duration(secondsPerBlock*(firstBlockSlot-lastBlock.EthBlockNum)))
+					toTimestamp := lastBlock.Timestamp.Add(time.Second * time.Duration(secondsPerBlock*(lastBlockSlot-lastBlock.EthBlockNum)))
+					assert.Equal(t, fromTimestamp.Unix(), nextForgers[q].Period.FromTimestamp.Unix())
+					assert.Equal(t, toTimestamp.Unix(), nextForgers[q].Period.ToTimestamp.Unix())
+				}
+			}
+		}
+	}
+}
+
+func TestUpdateNetworkInfo(t *testing.T) {
+	status := &Network{}
+	assert.Equal(t, status.LastBlock, api.status.Network.LastBlock)
+	assert.Equal(t, status.LastBatch.BatchNum, api.status.Network.LastBatch.BatchNum)
+	assert.Equal(t, status.CurrentSlot, api.status.Network.CurrentSlot)
+	assert.Equal(t, status.NextForgers, api.status.Network.NextForgers)
+	lastBlock := tc.blocks[3]
+	lastBatchNum := common.BatchNum(3)
+	currentSlotNum := int64(1)
+	err := api.UpdateNetworkInfo(lastBlock, lastBatchNum, currentSlotNum)
+	assert.NoError(t, err)
+	assert.Equal(t, lastBlock.EthBlockNum, api.status.Network.LastBlock)
+	assert.Equal(t, lastBatchNum, api.status.Network.LastBatch.BatchNum)
+	assert.Equal(t, currentSlotNum, api.status.Network.CurrentSlot)
+	assert.Equal(t, int(api.status.Auction.ClosedAuctionSlots)+1, len(api.status.Network.NextForgers))
+}