From 887c5d83cb98e7bb0fae364a1e902ef86581c98b Mon Sep 17 00:00:00 2001 From: Dusan Brajovic Date: Fri, 25 Aug 2023 16:04:10 +0200 Subject: [PATCH] add TestCheckFeeThreshold --- orchestrator/batch_request_test.go | 36 ++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) diff --git a/orchestrator/batch_request_test.go b/orchestrator/batch_request_test.go index eed250fb..29fb387a 100644 --- a/orchestrator/batch_request_test.go +++ b/orchestrator/batch_request_test.go @@ -119,3 +119,39 @@ func TestRequestBatches(t *testing.T) { }) } + +func TestCheckFeeThreshold(t *testing.T) { + t.Parallel() + + t.Run("fee threshold is met", func(t *testing.T) { + t.Parallel() + + var ( + requester = &batchRequester{minBatchFee: 21} + tokenAddr = eth.HexToAddress("0xe28b3B32B6c345A34Ff64674606124Dd5Aceca30") + totalFees, _ = cosmtypes.NewIntFromString("10000000000000000000") // 10inj + feed = mockPriceFeed{queryFn: func(_ eth.Address) (float64, error) { + return 2.5, nil + }} + ) + + // 2.5 * 10 > 21 + assert.True(t, requester.checkFeeThreshold(feed, tokenAddr, totalFees)) + }) + + t.Run("fee threshold is met", func(t *testing.T) { + t.Parallel() + + var ( + requester = &batchRequester{minBatchFee: 333.333} + tokenAddr = eth.HexToAddress("0xe28b3B32B6c345A34Ff64674606124Dd5Aceca30") + totalFees, _ = cosmtypes.NewIntFromString("100000000000000000000") // 10inj + feed = mockPriceFeed{queryFn: func(_ eth.Address) (float64, error) { + return 2.5, nil + }} + ) + + // 2.5 * 100 < 333.333 + assert.False(t, requester.checkFeeThreshold(feed, tokenAddr, totalFees)) + }) +}