refactor: detect proxy api then handle erc721/20 types

src/services/evm/constant.ts

@@ -149,6 +149,10 @@ export const SERVICE = {
     CrawlEvmProxyHistory: {
       key: 'CrawlEvmProxyHistory',
       path: 'v1.CrawlEvmProxyHistory',
+      handleTypeProxyContracts: {
+        key: 'handleTypeProxyContracts',
+        path: 'v1.CrawlEvmProxyHistory.handleTypeProxyContracts',
+      },
     },
     JobService: {
       CrawlEvmEvent: {

src/services/evm/crawl_evm_proxy_history.service.ts

@@ -1,9 +1,12 @@
 /* eslint-disable @typescript-eslint/return-await */
 /* eslint-disable no-await-in-loop */
 /* eslint-disable no-restricted-syntax */
-import { Service } from '@ourparentcenter/moleculer-decorators-extended';
+import {
+  Action,
+  Service,
+} from '@ourparentcenter/moleculer-decorators-extended';
 import _, { Dictionary } from 'lodash';
-import { ServiceBroker } from 'moleculer';
+import { Context, ServiceBroker } from 'moleculer';
 import {
   PublicClient,
   decodeAbiParameters,
@@ -235,6 +238,38 @@ export default class CrawlProxyContractEVMService extends BullableService {
     await this.handleTypeProxyContracts(newProxyContracts);
   }
 
+  @Action({
+    name: SERVICE.V1.CrawlEvmProxyHistory.handleTypeProxyContracts.key,
+    params: {
+      proxyHistoryIds: {
+        type: 'array',
+        items: 'number',
+        required: true,
+      },
+    },
+  })
+  public async actionHandleTypeProxyContracts(
+    ctx: Context<{ proxyHistoryIds: number[] }>
+  ) {
+    const ids = ctx.params.proxyHistoryIds;
+    // handle erc20 proxies
+    await this.handleErc20ProxyContracts(
+      ids.map((id) =>
+        EvmProxyHistory.fromJson({
+          id,
+        })
+      )
+    );
+    // handle erc721 proxies
+    await this.handleErc721ProxyContracts(
+      ids.map((id) =>
+        EvmProxyHistory.fromJson({
+          id,
+        })
+      )
+    );
+  }
+
   async handleTypeProxyContracts(proxyContracts: EvmProxyHistory[]) {
     // handle erc20 proxies
     await this.handleErc20ProxyContracts(proxyContracts);

src/services/evm/evm_proxy.service.ts

@@ -78,6 +78,12 @@ export default class EVMProxy extends BaseService {
           })
           .returning('*');
       }
+      await this.broker.call(
+        SERVICE.V1.CrawlEvmProxyHistory.handleTypeProxyContracts.path,
+        {
+          proxyHistoryIds: [evmProxyHistory.id],
+        }
+      );
     }
 
     return evmProxyHistory;

test/unit/services/evm/evm_proxy.spec.ts

@@ -51,7 +51,7 @@ export default class EvmProxyServiceTest {
     jest
       .spyOn(ContractHelper.prototype, 'isContractProxy')
       .mockResolvedValueOnce(proxyContractRPC);
-
+    jest.spyOn(this.evmProxyService.broker, 'call').mockImplementation();
     const insertedSmartContract = await EVMSmartContract.query()
       .insert({ address: ctx.params.contractAddress })
       .returning('*');
@@ -82,7 +82,7 @@ export default class EvmProxyServiceTest {
     jest
       .spyOn(this.evmProxyService.viemClient, 'getBlockNumber')
       .mockResolvedValueOnce(Promise.resolve(BigInt(lastBlockHeight)));
-
+    jest.spyOn(this.evmProxyService.broker, 'call').mockImplementation();
     await EVMSmartContract.query()
       .insert({
         address: ctx.params.contractAddress,