feat: Support DutchV3 Orders

bin/app.ts

@@ -113,6 +113,11 @@ export class APIPipeline extends Stack {
         'arn:aws:secretsmanager:us-east-2:644039819003:secret:gouda-parameterization-api-internal-api-key-uw4sIa',
     });
 
+    const rpcUrls = sm.Secret.fromSecretAttributes(this, 'rpcUrls', {
+      secretCompleteArn:
+        'arn:aws:secretsmanager:us-east-2:644039819003:secret:prod/param-api/rpc-urls-HJyniu',
+    });
+
     // Beta us-east-2
 
     const betaUsEast2Stage = new APIStage(this, 'beta-us-east-2', {
@@ -123,7 +128,7 @@ export class APIPipeline extends Stack {
       envVars: {
         RFQ_WEBHOOK_CONFIG: rfqWebhookConfig.secretValue.toString(),
         ORDER_SERVICE_URL: urlSecrets.secretValueFromJson('GOUDA_SERVICE_BETA').toString(),
-        ARBITRUM_RPC_URL: urlSecrets.secretValueFromJson('ARBITRUM_RPC_URL').toString(),
+        RPC_42161: rpcUrls.secretValueFromJson('RPC_42161').toString(),
         FILL_LOG_SENDER_ACCOUNT: '321377678687',
         ORDER_LOG_SENDER_ACCOUNT: '321377678687',
         URA_ACCOUNT: '665191769009',
@@ -144,7 +149,7 @@ export class APIPipeline extends Stack {
       envVars: {
         RFQ_WEBHOOK_CONFIG: rfqWebhookConfig.secretValue.toString(),
         ORDER_SERVICE_URL: urlSecrets.secretValueFromJson('GOUDA_SERVICE_PROD').toString(),
-        ARBITRUM_RPC_URL: urlSecrets.secretValueFromJson('ARBITRUM_RPC_URL').toString(),
+        RPC_42161: rpcUrls.secretValueFromJson('RPC_42161').toString(),
         FILL_LOG_SENDER_ACCOUNT: '316116520258',
         ORDER_LOG_SENDER_ACCOUNT: '316116520258',
         URA_ACCOUNT: '652077092967',
@@ -246,7 +251,7 @@ envVars['URA_ACCOUNT'] = process.env['URA_ACCOUNT'] || '';
 envVars['BOT_ACCOUNT'] = process.env['BOT_ACCOUNT'] || '';
 envVars['UNISWAP_API'] = process.env['UNISWAP_API'] || '';
 envVars['ORDER_SERVICE_URL'] = process.env['ORDER_SERVICE_URL'] || '';
-envVars['ARBITRUM_RPC_URL'] = process.env['ARBITRUM_RPC_URL'] || '';
+envVars['RPC_42161'] = process.env['RPC_42161'] || '';
 
 new APIStack(app, `${SERVICE_NAME}Stack`, {
   env: {

lib/handlers/hard-quote/handler.ts

@@ -48,13 +48,19 @@ export class QuoteHandler extends APIGLambdaHandler<
   ): Promise<ErrorResponse | Response<HardQuoteResponseData>> {
     const {
       requestInjected: { log, metric },
-      containerInjected: { quoters, orderServiceProvider, provider },
+      containerInjected: { quoters, orderServiceProvider, chainIdRpcMap },
       requestBody,
     } = params;
     const start = Date.now();
 
     metric.putMetric(Metric.QUOTE_REQUESTED, 1, MetricLoggerUnit.Count);
 
+    const provider = chainIdRpcMap.get(requestBody.tokenInChainId);
+    if (!provider)
+      throw new Error(
+        `No rpc provider found for chain: ${requestBody.tokenInChainId}`
+      );
+
     const orderParser = new UniswapXOrderParser();
     const orderType: OrderType = orderParser.getOrderTypeFromEncoded(
       requestBody.encodedInnerOrder,

lib/handlers/hard-quote/injector.ts

@@ -18,12 +18,13 @@ import { STAGE } from '../../util/stage';
 import { ApiInjector, ApiRInj } from '../base/api-handler';
 import { HardQuoteRequestBody } from './schema';
 import { ethers } from 'ethers';
+import { ChainId, supportedChains } from '../../util/chains';
 
 export interface ContainerInjected {
   quoters: Quoter[];
   firehose: FirehoseLogger;
   orderServiceProvider: OrderServiceProvider;
-  provider: ethers.providers.Provider;
+  chainIdRpcMap: Map<ChainId, ethers.providers.StaticJsonRpcProvider>;
 }
 
 export interface RequestInjected extends ApiRInj {
@@ -42,7 +43,6 @@ export class QuoteInjector extends ApiInjector<ContainerInjected, RequestInjecte
     const s3Key = stage === STAGE.BETA ? BETA_S3_KEY : PRODUCTION_S3_KEY;
 
     const orderServiceUrl = checkDefined(process.env.ORDER_SERVICE_URL, 'ORDER_SERVICE_URL is not defined');
-    const rpcProviderUrl = checkDefined(process.env.ARBITRUM_RPC_URL, 'ARBITRUM_RPC_URL is not defined');
 
     const webhookProvider = new S3WebhookConfigurationProvider(log, `${WEBHOOK_CONFIG_BUCKET}-${stage}-1`, s3Key);
     await webhookProvider.fetchEndpoints();
@@ -78,15 +78,23 @@ export class QuoteInjector extends ApiInjector<ContainerInjected, RequestInjecte
       new WebhookQuoter(log, firehose, webhookProvider, circuitBreakerProvider, fillerComplianceProvider, repository),
     ];
 
-    const provider = new ethers.providers.JsonRpcProvider(
-      rpcProviderUrl,
+    const chainIdRpcMap = new Map<ChainId, ethers.providers.StaticJsonRpcProvider>();
+    supportedChains.forEach(
+      chainId => {
+        const rpcUrl = checkDefined(
+          process.env[`RPC_${chainId}`],
+          `RPC_${chainId} is not defined`
+        );
+        const provider = new ethers.providers.StaticJsonRpcProvider(rpcUrl, chainId); // specify chainId to avoid detecctNetwork() call on initialization
+        chainIdRpcMap.set(chainId, provider);
+      }
     );
 
     return {
       quoters: quoters,
       firehose: firehose,
       orderServiceProvider,
-      provider,
+      chainIdRpcMap,
     };
   }
 

lib/util/chains.ts

@@ -6,6 +6,10 @@ export enum ChainId {
   ARBITRUM_ONE = 42161,
 }
 
+export const supportedChains = [
+  ChainId.ARBITRUM_ONE,
+]
+
 export enum ChainName {
   // ChainNames match infura network strings
   MAINNET = 'mainnet',