Tests/gossip

gossip/emitter/emitter_test.go

@@ -89,10 +89,6 @@ func TestEmitter(t *testing.T) {
 		tx1 := types.NewTransaction(1, common.Address{}, big.NewInt(1), 1, big.NewInt(1), nil)
 		tx2 := types.NewTransaction(2, common.Address{}, big.NewInt(2), 2, big.NewInt(2), nil)
 
-		external.EXPECT().IsBusy().
-			Return(true).
-			AnyTimes()
-
 		txtime.Saw(tx1.Hash(), time.Unix(1, 0))
 
 		require.Equal(time.Unix(1, 0), txtime.Of(tx1.Hash()))
@@ -112,7 +108,37 @@ func TestEmitter(t *testing.T) {
 		require.Equal(time.Unix(3, 0), txtime.Of(tx2.Hash()))
 	})
 
+	external.EXPECT().IsBusy().Return(true).Times(1)
 	t.Run("tick", func(t *testing.T) {
 		em.tick()
 	})
+
+	t.Run("tick", func(t *testing.T) {
+		tx1 := types.NewTransaction(1, common.Address{}, big.NewInt(1), 1, big.NewInt(1), nil)
+		tx2 := types.NewTransaction(2, common.Address{}, big.NewInt(2), 2, big.NewInt(2), nil)
+
+		txPool.EXPECT().Count().
+			Return(1).
+			AnyTimes()
+		txPool.EXPECT().Pending(true).
+			Return(map[common.Address]types.Transactions{
+				common.Address{}: {tx1, tx2},
+			}, nil).AnyTimes()
+
+		external.EXPECT().IsBusy().
+			Return(false).
+			AnyTimes()
+		external.EXPECT().GetLatestBlockIndex().
+			Return(idx.Block(0)).
+			AnyTimes()
+
+		txSigner.EXPECT().Sender(tx1).
+			Return(common.Address{}, nil).
+			AnyTimes()
+		txSigner.EXPECT().Sender(tx2).
+			Return(common.Address{}, nil).
+			AnyTimes()
+		em.tick()
+	})
+
 }

gossip/emitter/parents_test.go

@@ -0,0 +1,145 @@
+package emitter
+
+import (
+	"testing"
+	"time"
+
+	"github.com/Fantom-foundation/lachesis-base/emitter/ancestor"
+	"github.com/Fantom-foundation/lachesis-base/hash"
+	"github.com/Fantom-foundation/lachesis-base/inter/idx"
+	"github.com/Fantom-foundation/lachesis-base/inter/pos"
+	"github.com/Fantom-foundation/lachesis-base/kvdb/memorydb"
+	"github.com/golang/mock/gomock"
+	"github.com/stretchr/testify/require"
+
+	"github.com/Fantom-foundation/go-opera/gossip/emitter/mock"
+	"github.com/Fantom-foundation/go-opera/integration/makefakegenesis"
+	"github.com/Fantom-foundation/go-opera/inter"
+	"github.com/Fantom-foundation/go-opera/opera"
+	"github.com/Fantom-foundation/go-opera/vecmt"
+)
+
+func TestParents(t *testing.T) {
+	cfg := DefaultConfig()
+	gValidators := makefakegenesis.GetFakeValidators(3)
+	vv := pos.NewBuilder()
+	for _, v := range gValidators {
+		vv.Set(v.ID, pos.Weight(1))
+	}
+	validators := vv.Build()
+	cfg.Validator.ID = gValidators[0].ID
+
+	ctrl := gomock.NewController(t)
+	external := mock.NewMockExternal(ctrl)
+	txPool := mock.NewMockTxPool(ctrl)
+	signer := mock.NewMockSigner(ctrl)
+	txSigner := mock.NewMockTxSigner(ctrl)
+
+	external.EXPECT().Lock().
+		AnyTimes()
+	external.EXPECT().Unlock().
+		AnyTimes()
+	external.EXPECT().DagIndex().
+		Return(func() *vecmt.Index {
+			vi := vecmt.NewIndex(func(err error) { panic(err) }, vecmt.LiteConfig())
+			vi.Reset(validators, memorydb.New(), nil)
+			return vi
+		}()).
+		AnyTimes()
+	external.EXPECT().IsSynced().
+		Return(true).
+		AnyTimes()
+	external.EXPECT().PeersNum().
+		Return(int(3)).
+		AnyTimes()
+	external.EXPECT().StateDB().
+		Return(nil).
+		AnyTimes()
+
+	em := NewEmitter(cfg, World{
+		External: external,
+		TxPool:   txPool,
+		Signer:   signer,
+		TxSigner: txSigner,
+	})
+
+	t.Run("init", func(t *testing.T) {
+		external.EXPECT().GetRules().
+			Return(opera.FakeNetRules()).
+			AnyTimes()
+
+		external.EXPECT().GetEpochValidators().
+			Return(validators, idx.Epoch(1)).
+			AnyTimes()
+
+		external.EXPECT().GetLastEvent(idx.Epoch(1), cfg.Validator.ID).
+			Return((*hash.Event)(nil)).
+			AnyTimes()
+
+		external.EXPECT().GetLastEvent(idx.Epoch(2), cfg.Validator.ID).
+			Return(new(hash.Event)).
+			AnyTimes()
+
+		external.EXPECT().GetLastEvent(idx.Epoch(2), gValidators[1].ID).
+			Return((*hash.Event)(nil)).
+			AnyTimes()
+
+		external.EXPECT().GetHeads(idx.Epoch(1)).
+			Return(hash.Events{}).
+			AnyTimes()
+
+		external.EXPECT().GetHeads(idx.Epoch(2)).
+			Return(hash.Events{}).
+			AnyTimes()
+
+		external.EXPECT().GetGenesisTime().
+			Return(inter.Timestamp(uint64(time.Now().UnixNano()))).
+			AnyTimes()
+
+		em.init()
+	})
+
+	t.Run("build strategies 0 events", func(t *testing.T) {
+		strategies := em.buildSearchStrategies(idx.Event(0))
+		require.Equal(t, 0, len(strategies))
+	})
+
+	t.Run("build strategies 1 event", func(t *testing.T) {
+		strategies := em.buildSearchStrategies(idx.Event(1))
+		require.Equal(t, 1, len(strategies))
+	})
+
+	t.Run("build strategies 4 event", func(t *testing.T) {
+		strategies := em.buildSearchStrategies(idx.Event(4))
+		require.Equal(t, 4, len(strategies))
+	})
+
+	t.Run("build strategies with fcIndexer", func(t *testing.T) {
+		gValidator := makefakegenesis.GetFakeValidators(1)
+		vvNew := pos.NewBuilder()
+		vvNew.Set(gValidator[0].ID, pos.Weight(1))
+		newValidators := vvNew.Build()
+
+		em.quorumIndexer = nil
+		em.fcIndexer = ancestor.NewFCIndexer(newValidators, em.world.DagIndex(), em.config.Validator.ID)
+
+		strategies := em.buildSearchStrategies(idx.Event(4))
+		require.Equal(t, 4, len(strategies))
+	})
+
+	t.Run("choose parent not selfParent", func(t *testing.T) {
+		event, events, ok := em.chooseParents(idx.Epoch(1), em.config.Validator.ID)
+		require.Equal(t, true, ok)
+		var eventExp *hash.Event
+		require.Equal(t, eventExp, event)
+		require.Equal(t, hash.Events{}, events)
+	})
+
+	t.Run("choose parent selfParent", func(t *testing.T) {
+		event, events, ok := em.chooseParents(idx.Epoch(2), em.config.Validator.ID)
+		require.Equal(t, true, ok)
+		eventExp := new(hash.Event)
+		require.Equal(t, eventExp, event)
+		require.Equal(t, hash.Events{hash.Event{}}, events)
+	})
+}

gossip/evmstore/store_test.go

@@ -1,6 +1,11 @@
 package evmstore
 
 import (
+	"testing"
+
+	"github.com/ethereum/go-ethereum/core/types"
+	"github.com/stretchr/testify/require"
+
 	"github.com/Fantom-foundation/lachesis-base/kvdb/memorydb"
 )
 
@@ -15,3 +20,21 @@ func nonCachedStore() *Store {
 
 	return NewStore(memorydb.NewProducer(""), cfg)
 }
+
+func TestStoreSetTx(t *testing.T) {
+	store := cachedStore()
+
+	tx := types.NewTx(&types.LegacyTx{Data: []byte("test")})
+
+	store.SetTx(tx.Hash(), tx)
+
+	txFromStore := store.GetTx(tx.Hash())
+	require.Equal(t, tx.Hash(), txFromStore.Hash())
+	require.Equal(t, tx.Data(), txFromStore.Data())
+	require.Equal(t, tx.Nonce(), txFromStore.Nonce())
+	require.Equal(t, tx.Size(), txFromStore.Size())
+	require.Equal(t, tx.Value(), txFromStore.Value())
+	require.Equal(t, tx.To(), txFromStore.To())
+	require.Equal(t, tx.Gas(), txFromStore.Gas())
+	require.Equal(t, tx.GasPrice(), txFromStore.GasPrice())
+}