const

x/ccv/consumer/keeper/throttle_retry.go

@@ -34,6 +34,9 @@ import (
 // This design is implemented below, and in relay.go under SendPackets() and OnAcknowledgementPacket().
 //
 
+// Retry delay period could be implemented as a param, but 1 hour is reasonable
+const RETRY_DELAY_PERIOD = time.Hour
+
 // PacketSendingPermitted returns whether the consumer is allowed to send packets
 // from the pending packets queue.
 func (k Keeper) PacketSendingPermitted(ctx sdktypes.Context) bool {
@@ -46,10 +49,8 @@ func (k Keeper) PacketSendingPermitted(ctx sdktypes.Context) bool {
 		// We are waiting on a reply from provider, block sending
 		return false
 	}
-	// Retry delay period could be implemented as a param, but 1 hour is reasonable
-	retryDelayPeriod := time.Hour
 	// If retry delay period has elapsed, we can send again
-	return ctx.BlockTime().After(record.SendTime.Add(retryDelayPeriod))
+	return ctx.BlockTime().After(record.SendTime.Add(RETRY_DELAY_PERIOD))
 }
 
 func (k Keeper) UpdateSlashRecordOnSend(ctx sdktypes.Context) {

x/ccv/consumer/keeper/throttle_retry_test.go

@@ -7,6 +7,7 @@ import (
 	"github.com/stretchr/testify/require"
 
 	testutil "github.com/cosmos/interchain-security/v3/testutil/keeper"
+	consumerkeeper "github.com/cosmos/interchain-security/v3/x/ccv/consumer/keeper"
 	consumertypes "github.com/cosmos/interchain-security/v3/x/ccv/consumer/types"
 )
 
@@ -41,7 +42,7 @@ func TestPacketSendingPermitted(t *testing.T) {
 	require.False(t, consumerKeeper.PacketSendingPermitted(ctx))
 
 	// Elapse retry delay period
-	ctx = ctx.WithBlockTime(ctx.BlockTime().Add(2 * time.Hour))
+	ctx = ctx.WithBlockTime(ctx.BlockTime().Add(2 * consumerkeeper.RETRY_DELAY_PERIOD))
 
 	// Now packet sending is permitted again
 	require.True(t, consumerKeeper.PacketSendingPermitted(ctx))