diff --git a/lib/providers/circuit-breaker/dynamo.ts b/lib/providers/circuit-breaker/dynamo.ts index 3ba8c48..d512591 100644 --- a/lib/providers/circuit-breaker/dynamo.ts +++ b/lib/providers/circuit-breaker/dynamo.ts @@ -47,8 +47,8 @@ export class DynamoCircuitBreakerConfigurationProvider implements CircuitBreaker this.timestamps = await this.timestampDB.getFillerTimestampsMap(this.fillerEndpoints); } - /* add filler to `enabled` array if it's not blocked until a future timestamp - add disabled fillers and the `blockUntilTimestamp`s to disabled array */ + /* add filler to `enabled` array if it's not blocked until a future timestamp; + add disabled fillers and the `blockUntilTimestamp`s to disabled array */ async getEndpointStatuses(endpoints: WebhookConfiguration[]): Promise { try { const now = Math.floor(Date.now() / 1000); diff --git a/lib/repositories/fades-repository.ts b/lib/repositories/fades-repository.ts index 040bfcf..ce0e050 100644 --- a/lib/repositories/fades-repository.ts +++ b/lib/repositories/fades-repository.ts @@ -181,7 +181,7 @@ AND latestOrdersV2.quoteId IS NOT NULL AND rfqFiller != '0x0000000000000000000000000000000000000000' AND chainId NOT IN (5,8001,420,421613) -- exclude mainnet goerli, polygon goerli, optimism goerli and arbitrum goerli testnets AND - postTimestamp >= extract(epoch from (GETDATE() - INTERVAL '48 HOURS')) -- 2 days rolling window + postTimestamp >= extract(epoch from (GETDATE() - INTERVAL '20 MINUTE')) -- 20-minute rolling window ) ORDER BY rfqFiller, postTimestamp DESC LIMIT 1000