From 1b4a1b54019f99fc36dd5861b6a1e4eb2db84df1 Mon Sep 17 00:00:00 2001
From: Darren Kelly <107671032+darrenvechain@users.noreply.github.com>
Date: Thu, 30 Jan 2025 13:31:42 +0000
Subject: [PATCH] fix: using from instead of to (#968)

* fix: using from instead of to

---------

Co-authored-by: otherview <otherview@gmail.com>
---
 api/events/types.go      |  2 +-
 api/events/types_test.go | 71 +++++++++++++++++++++++++++++++++++-----
 2 files changed, 64 insertions(+), 9 deletions(-)

diff --git a/api/events/types.go b/api/events/types.go
index 78d0cf712..432099085 100644
--- a/api/events/types.go
+++ b/api/events/types.go
@@ -167,7 +167,7 @@ func ConvertRange(chain *chain.Chain, r *Range) (*logdb.Range, error) {
 
 		toHeader := head
 		if r.To != nil {
-			toHeader, err = chain.FindBlockHeaderByTimestamp(*r.From, -1)
+			toHeader, err = chain.FindBlockHeaderByTimestamp(*r.To, -1)
 			if err != nil {
 				return nil, err
 			}
diff --git a/api/events/types_test.go b/api/events/types_test.go
index 6d16ca4d8..78b1bfe5e 100644
--- a/api/events/types_test.go
+++ b/api/events/types_test.go
@@ -15,7 +15,6 @@ import (
 	"github.com/vechain/thor/v2/logdb"
 	"github.com/vechain/thor/v2/test/testchain"
 	"github.com/vechain/thor/v2/thor"
-	"github.com/vechain/thor/v2/tx"
 )
 
 func newRange(unit RangeType, from uint64, to uint64) *Range {
@@ -29,10 +28,14 @@ func newRange(unit RangeType, from uint64, to uint64) *Range {
 func TestEventsTypes(t *testing.T) {
 	c := initChain(t)
 	for name, tt := range map[string]func(*testing.T, *testchain.Chain){
-		"testConvertRangeWithBlockRangeType":               testConvertRangeWithBlockRangeType,
-		"testConvertRangeWithTimeRangeTypeLessThenGenesis": testConvertRangeWithTimeRangeTypeLessThenGenesis,
-		"testConvertRangeWithTimeRangeType":                testConvertRangeWithTimeRangeType,
-		"testConvertRangeWithFromGreaterThanGenesis":       testConvertRangeWithFromGreaterThanGenesis,
+		"testConvertRangeWithBlockRangeType":                          testConvertRangeWithBlockRangeType,
+		"testConvertRangeWithBlockRangeTypeMoreThanMaxBlockNumber":    testConvertRangeWithBlockRangeTypeMoreThanMaxBlockNumber,
+		"testConvertRangeWithBlockRangeTypeWithSwitchedFromAndTo":     testConvertRangeWithBlockRangeTypeWithSwitchedFromAndTo,
+		"testConvertRangeWithTimeRangeTypeLessThenGenesis":            testConvertRangeWithTimeRangeTypeLessThenGenesis,
+		"testConvertRangeWithTimeRangeType":                           testConvertRangeWithTimeRangeType,
+		"testConvertRangeWithFromGreaterThanGenesis":                  testConvertRangeWithFromGreaterThanGenesis,
+		"testConvertRangeWithTimeRangeLessThanGenesisGreaterThanBest": testConvertRangeWithTimeRangeLessThanGenesisGreaterThanBest,
+		"testConvertRangeWithTimeRangeTypeWithSwitchedFromAndTo":      testConvertRangeWithTimeRangeTypeWithSwitchedFromAndTo,
 	} {
 		t.Run(name, func(t *testing.T) {
 			tt(t, c)
@@ -40,6 +43,38 @@ func TestEventsTypes(t *testing.T) {
 	}
 }
 
+func testConvertRangeWithTimeRangeLessThanGenesisGreaterThanBest(t *testing.T, chain *testchain.Chain) {
+	genesis := chain.GenesisBlock().Header()
+	bestBlock := chain.Repo().BestBlockSummary()
+
+	rng := newRange(TimeRangeType, genesis.Timestamp()-1_000, bestBlock.Header.Timestamp()+1_000)
+	expectedRange := &logdb.Range{
+		From: genesis.Number(),
+		To:   bestBlock.Header.Number(),
+	}
+
+	convRng, err := ConvertRange(chain.Repo().NewBestChain(), rng)
+
+	assert.NoError(t, err)
+	assert.Equal(t, expectedRange, convRng)
+}
+
+func testConvertRangeWithTimeRangeTypeWithSwitchedFromAndTo(t *testing.T, chain *testchain.Chain) {
+	genesis := chain.GenesisBlock().Header()
+	bestBlock := chain.Repo().BestBlockSummary()
+
+	rng := newRange(TimeRangeType, bestBlock.Header.Timestamp(), genesis.Timestamp())
+	expectedRange := &logdb.Range{
+		From: bestBlock.Header.Number(),
+		To:   genesis.Number(),
+	}
+
+	convRng, err := ConvertRange(chain.Repo().NewBestChain(), rng)
+
+	assert.NoError(t, err)
+	assert.Equal(t, expectedRange, convRng)
+}
+
 func testConvertRangeWithBlockRangeType(t *testing.T, chain *testchain.Chain) {
 	rng := newRange(BlockRangeType, 1, 2)
 
@@ -50,8 +85,27 @@ func testConvertRangeWithBlockRangeType(t *testing.T, chain *testchain.Chain) {
 	assert.Equal(t, uint32(*rng.To), convertedRng.To)
 }
 
+func testConvertRangeWithBlockRangeTypeMoreThanMaxBlockNumber(t *testing.T, chain *testchain.Chain) {
+	rng := newRange(BlockRangeType, logdb.MaxBlockNumber+1, logdb.MaxBlockNumber+2)
+
+	convertedRng, err := ConvertRange(chain.Repo().NewBestChain(), rng)
+
+	assert.NoError(t, err)
+	assert.Equal(t, &emptyRange, convertedRng)
+}
+
+func testConvertRangeWithBlockRangeTypeWithSwitchedFromAndTo(t *testing.T, chain *testchain.Chain) {
+	rng := newRange(BlockRangeType, logdb.MaxBlockNumber, 0)
+
+	convertedRng, err := ConvertRange(chain.Repo().NewBestChain(), rng)
+
+	assert.NoError(t, err)
+	assert.Equal(t, emptyRange.From, convertedRng.From)
+	assert.Equal(t, uint32(*rng.To), convertedRng.To)
+}
+
 func testConvertRangeWithTimeRangeTypeLessThenGenesis(t *testing.T, chain *testchain.Chain) {
-	rng := newRange(TimeRangeType, 100, 2200)
+	rng := newRange(TimeRangeType, chain.GenesisBlock().Header().Timestamp()-1000, chain.GenesisBlock().Header().Timestamp()-100)
 	expectedEmptyRange := &logdb.Range{
 		From: logdb.MaxBlockNumber,
 		To:   logdb.MaxBlockNumber,
@@ -98,8 +152,9 @@ func initChain(t *testing.T) *testchain.Chain {
 	thorChain, err := testchain.NewIntegrationTestChain()
 	require.NoError(t, err)
 
-	require.NoError(t, thorChain.MintBlock(genesis.DevAccounts()[0], []*tx.Transaction{}...))
-	require.NoError(t, thorChain.MintBlock(genesis.DevAccounts()[0], []*tx.Transaction{}...))
+	for i := 0; i < 10; i++ {
+		require.NoError(t, thorChain.MintBlock(genesis.DevAccounts()[0]))
+	}
 
 	return thorChain
 }