fix: remove POOL_CACHE_BUCKET_2 from env var (Uniswap#749)

* fix: remove POOL_CACHE_BUCKET_2 from env var

* fix prettier

Author: jsy1218

bin/stacks/routing-caching-stack.ts

@@ -130,9 +130,7 @@ export class RoutingCachingStack extends cdk.NestedStack {
           tracing: aws_lambda.Tracing.ACTIVE,
           environment: {
             POOL_CACHE_BUCKET: this.poolCacheBucket.bucketName,
-            POOL_CACHE_BUCKET_2: this.poolCacheBucket2.bucketName,
             POOL_CACHE_BUCKET_3: this.poolCacheBucket3.bucketName,
-            POOL_CACHE_KEY: this.poolCacheKey,
             POOL_CACHE_GZIP_KEY: this.poolCacheGzipKey,
             ALCHEMY_QUERY_KEY: this.alchemyQueryKey ?? '',
             DCN_API_KEY: this.decentralizedNetworkApiKey ?? '',

bin/stacks/routing-lambda-stack.ts

@@ -49,7 +49,6 @@ export class RoutingLambdaStack extends cdk.NestedStack {
       poolCacheBucket,
       poolCacheBucket2,
       poolCacheBucket3,
-      poolCacheKey,
       poolCacheGzipKey,
       jsonRpcProviders,
       tokenListCacheBucket,
@@ -122,9 +121,7 @@ export class RoutingLambdaStack extends cdk.NestedStack {
         VERSION: '26',
         NODE_OPTIONS: '--enable-source-maps',
         POOL_CACHE_BUCKET: poolCacheBucket.bucketName,
-        POOL_CACHE_BUCKET_2: poolCacheBucket2.bucketName,
         POOL_CACHE_BUCKET_3: poolCacheBucket3.bucketName,
-        POOL_CACHE_KEY: poolCacheKey,
         POOL_CACHE_GZIP_KEY: poolCacheGzipKey,
         TOKEN_LIST_CACHE_BUCKET: tokenListCacheBucket.bucketName,
         ETH_GAS_STATION_INFO_URL: ethGasStationInfoUrl,

lib/cron/cache-pools.ts

@@ -129,9 +129,7 @@ const handler: ScheduledHandler = metricScope((metrics) => async (event: EventBr
 
   log.info({ result }, `Done ${protocol} for ${chainId.toString()}`)
 
-  log.info(
-    `Successfully cached ${chainId} ${protocol} pools to S3 bucket ${process.env.POOL_CACHE_BUCKET_2} ${process.env.POOL_CACHE_BUCKET_3}`
-  )
+  log.info(`Successfully cached ${chainId} ${protocol} pools to S3 bucket ${process.env.POOL_CACHE_BUCKET_3}`)
   metric.putMetric(`${metricPrefix}.latency`, Date.now() - beforeAll)
 
   log.info(

lib/handlers/injector-sor.ts

@@ -147,9 +147,7 @@ export abstract class InjectorSOR<Router, QueryParams> extends Injector<
 
     try {
       const {
-        POOL_CACHE_BUCKET_2,
         POOL_CACHE_BUCKET_3,
-        POOL_CACHE_KEY,
         POOL_CACHE_GZIP_KEY,
         TOKEN_LIST_CACHE_BUCKET,
         ROUTES_TABLE_NAME,
@@ -265,19 +263,7 @@ export abstract class InjectorSOR<Router, QueryParams> extends Injector<
                     throw new Error(`Chain protocol not found for chain ${chainId} and protocol ${Protocol.V3}`)
                   }
 
-                  const subgraphProvider = await V3AWSSubgraphProvider.EagerBuild(
-                    POOL_CACHE_BUCKET_3!,
-                    POOL_CACHE_GZIP_KEY!,
-                    chainId
-                  ).catch(async (err) => {
-                    log.error(
-                      { err },
-                      'compressed s3 subgraph pool caching unavailable, fall back to the existing s3 subgraph pool caching'
-                    )
-
-                    return await V3AWSSubgraphProvider.EagerBuild(POOL_CACHE_BUCKET_2!, POOL_CACHE_KEY!, chainId)
-                  })
-                  return subgraphProvider
+                  return await V3AWSSubgraphProvider.EagerBuild(POOL_CACHE_BUCKET_3!, POOL_CACHE_GZIP_KEY!, chainId)
                 } catch (err) {
                   log.error({ err }, 'AWS Subgraph Provider unavailable, defaulting to Static Subgraph Provider')
                   return new StaticV3SubgraphProvider(chainId, v3PoolProvider)
@@ -293,19 +279,7 @@ export abstract class InjectorSOR<Router, QueryParams> extends Injector<
                     throw new Error(`Chain protocol not found for chain ${chainId} and protocol ${Protocol.V2}`)
                   }
 
-                  const subgraphProvider = await V2AWSSubgraphProvider.EagerBuild(
-                    POOL_CACHE_BUCKET_3!,
-                    POOL_CACHE_GZIP_KEY!,
-                    chainId
-                  ).catch(async (err) => {
-                    log.error(
-                      { err },
-                      'compressed s3 subgraph pool caching unavailable, fall back to the existing s3 subgraph pool caching'
-                    )
-
-                    return await V2AWSSubgraphProvider.EagerBuild(POOL_CACHE_BUCKET_2!, POOL_CACHE_KEY!, chainId)
-                  })
-                  return subgraphProvider
+                  return await V2AWSSubgraphProvider.EagerBuild(POOL_CACHE_BUCKET_3!, POOL_CACHE_GZIP_KEY!, chainId)
                 } catch (err) {
                   return new StaticV2SubgraphProvider(chainId)
                 }