Skip to content

Commit 8b95857

Browse files
committed
limit query range
1 parent bf552cb commit 8b95857

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

api/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ var DefaultConfig = Config{
4141
WebSocketPort: 16014,
4242
TpsWindow: 10,
4343
GasStation: gasstation.DefaultConfig,
44-
RangeQueryLimit: 1000,
44+
RangeQueryLimit: 2000,
4545
BatchRequestLimit: _defaultBatchRequestLimit,
4646
WebsocketRateLimit: 5,
4747
ListenerLimit: 5000,

api/coreservice.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1618,6 +1618,9 @@ func (core *coreService) LogsInRange(filter *logfilter.LogFilter, start, end, pa
16181618
if err != nil {
16191619
return nil, nil, err
16201620
}
1621+
if end > start+core.cfg.RangeQueryLimit {
1622+
return nil, nil, status.Error(codes.InvalidArgument, "range exceeds the limit")
1623+
}
16211624
// getLogs via range Blooom filter [start, end]
16221625
blockNumbers, err := core.bfIndexer.FilterBlocksInRange(filter, start, end, paginationSize)
16231626
if err != nil {

api/coreservice_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -880,7 +880,7 @@ func TestActions(t *testing.T) {
880880
},
881881
)
882882
_, err := cs.Actions(0, 0)
883-
require.EqualError(err, t.Name())
883+
require.ErrorContains(err, "count must be greater than zero")
884884
})
885885

886886
t.Run("CountIsZero", func(t *testing.T) {
@@ -911,7 +911,7 @@ func TestActions(t *testing.T) {
911911
},
912912
)
913913

914-
_, err := cs.Actions(0, 1001)
914+
_, err := cs.Actions(0, 2001)
915915
require.ErrorContains(err, "range exceeds the limit")
916916
})
917917

0 commit comments

Comments
 (0)