add option for cache capacity (#1054)

Author: shunjizhan

packages/eth-providers/src/rpc-provider.ts

@@ -1,20 +1,26 @@
 import { ApiPromise, WsProvider } from '@polkadot/api';
-import { withAcalaTypes } from '@acala-network/api';
+import { acalaTypesBundle } from '@acala-network/types';
 
 import { BaseProvider, BaseProviderOptions } from './base-provider';
 
+export type EvmRpcProviderOptions = BaseProviderOptions & {
+  rpcCacheCapacity?: number;
+};
+
 export class EvmRpcProvider extends BaseProvider {
-  constructor(endpoint: string | string[], opts?: BaseProviderOptions) {
+  constructor(endpoint: string | string[], opts?: EvmRpcProviderOptions) {
     super(opts);
 
-    const api = new ApiPromise(withAcalaTypes({
+    const api = new ApiPromise({
       provider: new WsProvider(endpoint),
-    }));
+      typesBundle: acalaTypesBundle,
+      rpcCacheCapacity: opts?.rpcCacheCapacity,
+    });
 
     this.setApi(api);
   }
 
-  static from(endpoint: string | string[], opt?: BaseProviderOptions): EvmRpcProvider {
+  static from(endpoint: string | string[], opt?: EvmRpcProviderOptions): EvmRpcProvider {
     return new EvmRpcProvider(endpoint, opt);
   }
 }

packages/eth-rpc-adapter/src/index.ts

@@ -18,6 +18,7 @@ export async function start(): Promise<void> {
     subqlUrl: opts.subqlUrl,
     maxBlockCacheSize: opts.maxBlockCacheSize,
     storageCacheSize: opts.storageCacheSize,
+    rpcCacheCapacity: opts.rpcCacheCapacity,
   });
 
   const bridge = new Eip1193Bridge(provider);
@@ -58,8 +59,9 @@ export async function start(): Promise<void> {
   server host     : ${opts.host}
   server port     : ${opts.port}
   max blockCache  : ${opts.maxBlockCacheSize}
-  max batchSize   : ${opts.maxBatchSize}  
+  max batchSize   : ${opts.maxBatchSize}
   max storageSize : ${opts.storageCacheSize}
+  cache capacity  : ${opts.rpcCacheCapacity}
   safe mode       : ${opts.safeMode}
   local mode      : ${opts.localMode}
   http only       : ${opts.httpOnly}

packages/eth-rpc-adapter/src/utils/utils.ts

@@ -11,6 +11,7 @@ const {
   MAX_CACHE_SIZE,
   MAX_BATCH_SIZE,
   STORAGE_CACHE_SIZE,
+  RPC_CACHE_CAPACITY,
   SAFE_MODE,
   LOCAL_MODE,
   HTTP_ONLY,
@@ -76,6 +77,12 @@ export const yargsOptions = yargs(hideBin(process.argv))
       describe: 'max storage cache size',
       type: 'number',
     },
+    rpcCacheCapacity: {
+      demandOption: false,
+      default: Number(RPC_CACHE_CAPACITY ?? 1000),
+      describe: 'polkadot api rpc cache capacity',
+      type: 'number',
+    },
     safeMode: {
       alias: 's',
       demandOption: false,

packages/eth-rpc-adapter/src/wrapped-provider.ts

@@ -1,6 +1,7 @@
 import { ApiPromise, WsProvider } from '@polkadot/api';
-import { BaseProvider, BaseProviderOptions } from '@acala-network/eth-providers/base-provider';
-import { withAcalaTypes } from '@acala-network/api';
+import { BaseProvider } from '@acala-network/eth-providers/base-provider';
+import { EvmRpcProviderOptions } from '@acala-network/eth-providers';
+import { acalaTypesBundle } from '@acala-network/types';
 import tracer from 'dd-trace';
 
 const TRACE_METHODS = [
@@ -78,17 +79,19 @@ export class BaseProviderWithTrace extends BaseProvider {
 }
 
 export class EvmRpcProviderWithTrace extends BaseProviderWithTrace {
-  constructor(endpoint: string | string[], opts?: BaseProviderOptions) {
+  constructor(endpoint: string | string[], opts?: EvmRpcProviderOptions) {
     super(opts);
 
-    const api = new ApiPromise(withAcalaTypes({
+    const api = new ApiPromise({
       provider: new WsProvider(endpoint),
-    }));
+      typesBundle: acalaTypesBundle,
+      rpcCacheCapacity: opts?.rpcCacheCapacity,
+    });
 
     this.setApi(api);
   }
 
-  static from(endpoint: string | string[], opt?: BaseProviderOptions): EvmRpcProviderWithTrace {
+  static from(endpoint: string | string[], opt?: EvmRpcProviderOptions): EvmRpcProviderWithTrace {
     return new EvmRpcProviderWithTrace(endpoint, opt);
   }
 }