Fixes 07 2024 (#485)

* update

Author: PiotrRumblefish

packages/analyzer/src/utils/fragmentReader.ts

@@ -48,13 +48,30 @@ export class FragmentReader {
     const abiInterface = new Interface(abiDefinition)
 
     abiInterface.forEachFunction((fragment) => {
-      const functionFragment = abiInterface.getFunction(fragment.selector, [...fragment.inputs])
-      this.storeFragment(functionFragment.selector, functionFragment, 'function')
+      try {
+        const functionFragment = abiInterface.getFunction(fragment.selector, [...fragment.inputs])
+        this.storeFragment(functionFragment.selector, functionFragment, 'function')
+      } catch (error) {
+        console.log('getFunction', {
+          fragment,
+          error,
+          abiDefinition,
+        })
+      }
     })
 
     abiInterface.forEachEvent((fragment) => {
-      const eventFragment = abiInterface.getEvent(fragment.name, [...fragment.inputs])
-      this.storeFragment(eventFragment.topicHash.slice(0, 10), eventFragment, 'event')
+      try {
+        const eventFragment = abiInterface.getEvent(fragment.topicHash, [...fragment.inputs])
+        this.storeFragment(eventFragment.topicHash.slice(0, 10), eventFragment, 'event')
+      } catch (error) {
+        console.log('getEvent', {
+          fragment,
+          format: fragment.format('minimal'),
+          error,
+          abiDefinition,
+        })
+      }
     })
 
     abiInterface.forEachError((fragment) => {

packages/transaction-trace-provider/hardhat.config.ts

@@ -29,6 +29,11 @@ export const config: HardhatUserConfig = {
             cancun: 3_100_000,
           },
         },
+        [ChainId.amoy]: {
+          hardforkHistory: {
+            cancun: 0,
+          },
+        },
         [ChainId.arbitrum]: {
           hardforkHistory: {
             cancun: 70_000_000,

packages/transaction-trace-provider/src/sqsConsumer.ts

@@ -38,9 +38,6 @@ export const localDebugTransaction = async ({ txHash, chainId, hardhatForkingUrl
         },
       }
     })
-
-    console.log('Hardhat config extended', JSON.stringify(hardhat.config.networks.hardhat.forking, null, 2))
-
     const hardhatProvider = await hardhat.run(TASK_NODE_GET_PROVIDER, {
       chainId,
     })

packages/transaction-trace-provider/tests/unit/sqsConsumer.test.ts

@@ -22,7 +22,6 @@ jest.mock('../../src/s3', () => ({
   createMultiPartUpload: jest.fn().mockResolvedValue(uploadIdMock),
 }))
 
-jest.mock('hardhat')
 jest.mock('../../hardhat.config.ts', () => ({
   config: {
     solidity: '0.8.9',
@@ -66,7 +65,23 @@ jest.mock('../../hardhat.config.ts', () => ({
     },
   },
 }))
-// jest.mock('@nomicfoundation/hardhat-network-helpers')
+jest.mock('hardhat', () => ({
+  run: jest.fn(),
+  ethers: {
+    provider: {
+      request: jest.fn(),
+    },
+  },
+  config: {
+    networks: {
+      hardhat: {
+        forking: {
+          url: 'https://eth-mainnet.alchemyapi.io/v2/abcd',
+        },
+      },
+    },
+  },
+}))
 
 describe('Unit test for sqs consumer', function () {
   beforeEach(() => {
@@ -75,15 +90,23 @@ describe('Unit test for sqs consumer', function () {
   })
 
   it('Analyze, upload and create ddb events', async () => {
+    global.fetch = jest.fn().mockResolvedValue({
+      json: jest.fn().mockResolvedValue({
+        result: {
+          number: '0x10',
+        },
+      }),
+    })
     // eslint-disable-next-line @typescript-eslint/ban-ts-comment
     // @ts-ignore
     hardhat.run = () => ({
       send: () => sampleTraceResult,
+      request: jest.fn().mockResolvedValue({}),
     })
 
     const TX_HASH = '0xf2a56c4a9edc31fd3a8ed3c3e256d500f548035e84e55df6e1c6b631d91c04f9'
     const CHAIN_ID = '1'
-    const HARDHAT_FORKING_URL = ' https://eth-mainnet.alchemyapi.io/v2/abcd'
+    const HARDHAT_FORKING_URL = 'https://eth-mainnet.alchemyapi.io/v2/abcd'
     const testEvent = createSQSRecordEvent(TX_HASH, CHAIN_ID, HARDHAT_FORKING_URL, '4444')
     const bucketName = 'www.bucket.com'
     process.env.ANALYZER_DATA_BUCKET_NAME = bucketName
@@ -109,15 +132,28 @@ describe('Unit test for sqs consumer', function () {
     expect(getMockCalledInputItem(ddbMock, 0).status).toEqual(TransactionTraceResponseStatus.RUNNING)
     expect(getMockCalledInputItem(ddbMock, 1).status).toEqual(TransactionTraceResponseStatus.SUCCESS)
     expect(getMockCalledInputItem(ddbMock, 1).s3Location).toEqual(`${bucketName}/trace/${CHAIN_ID}/${TX_HASH}.json`)
+    expect(fetch).toHaveBeenCalledWith(HARDHAT_FORKING_URL, {
+      method: 'POST',
+      body: JSON.stringify({ params: ['latest', false], method: 'eth_getBlockByNumber', jsonrpc: '2.0', id: 1 }),
+    })
   })
 
   it('Add fail event in case of the error', async () => {
     const ERROR_MSG = 'Sample error during hardhat run'
+    global.fetch = jest.fn().mockResolvedValue({
+      json: jest.fn().mockResolvedValue({
+        result: {
+          number: '0x10',
+        },
+      }),
+    })
     // eslint-disable-next-line @typescript-eslint/ban-ts-comment
     // @ts-ignore
     hardhat.run = () => ({
       send: jest.fn().mockRejectedValue(new Error(ERROR_MSG)),
+      request: jest.fn().mockResolvedValue({}),
     })
+
     const TX_HASH = '0xf2a56c4a9edc31fd3a8ed3c3e256d500f548035e84e55df6e1c6b631d91c04f9'
     const CHAIN_ID = '1'
     const HARDHAT_FORKING_URL = ' https://eth-mainnet.alchemyapi.io/v2/abcd'