optimize subql handler with bulk creation

bodhi/.eslintrc.js

@@ -8,6 +8,7 @@ module.exports = {
     indent: [2, 2, { SwitchCase: 1 }],
     quotes: [2, 'single'],
     semi: [2, 'always'],
+    'no-trailing-spaces': [2],
     'quote-props': [2, 'as-needed'],
     'eol-last': [2, 'always'],
     'object-curly-spacing': [2, 'always'],

eth-providers/.eslintrc.js

@@ -8,6 +8,7 @@ module.exports = {
     indent: [2, 2, { SwitchCase: 1 }],
     quotes: [2, 'single'],
     semi: [2, 'always'],
+    'no-trailing-spaces': [2],
     'quote-props': [2, 'as-needed'],
     'eol-last': [2, 'always'],
     'object-curly-spacing': [2, 'always'],

eth-rpc-adapter/.eslintrc.js

@@ -8,6 +8,7 @@ module.exports = {
     indent: [2, 2, { SwitchCase: 1 }],
     quotes: [2, 'single'],
     semi: [2, 'always'],
+    'no-trailing-spaces': [2],
     'quote-props': [2, 'as-needed'],
     'eol-last': [2, 'always'],
     'object-curly-spacing': [2, 'always'],

eth-transactions/.eslintrc.js

@@ -7,8 +7,9 @@ module.exports = {
   rules: {
     indent: [2, 2, { SwitchCase: 1 }],
     quotes: [2, 'single'],
-    'quote-props': [2, 'as-needed'],
     semi: [2, 'always'],
+    'no-trailing-spaces': [2],
+    'quote-props': [2, 'as-needed'],
     'eol-last': [2, 'always'],
     'object-curly-spacing': [2, 'always'],
     'comma-dangle': [2, {

evm-subql/.eslintignore

@@ -0,0 +1,2 @@
+src/types/
+dist/

evm-subql/.eslintrc.js

@@ -18,6 +18,7 @@ module.exports = {
     indent: [2, 2, { SwitchCase: 1 }],
     quotes: [2, 'single'],
     semi: [2, 'always'],
+    'no-trailing-spaces': [2],
     'quote-props': [2, 'as-needed'],
     'eol-last': [2, 'always'],
     'object-curly-spacing': [2, 'always'],

evm-subql/src/mappings/mappingHandlers.ts

@@ -1,7 +1,6 @@
 import '@polkadot/api-augment';
 import { parseReceiptsFromBlockData } from '@acala-network/eth-providers/lib/utils';
 import { SubstrateBlock } from '@subql/types';
-import { Log, TransactionReceipt } from '../types';
 
 export const handleBlock = async (substrateBlock: SubstrateBlock): Promise<void> => {
   const receipts = await parseReceiptsFromBlockData(
@@ -10,12 +9,15 @@ export const handleBlock = async (substrateBlock: SubstrateBlock): Promise<void>
     substrateBlock.events,
   );
 
-  for (const [idx, receipt] of receipts.entries()) {
+  const blockNumber = substrateBlock.block.header.number.toBigInt();
+  const receiptEntities = [];
+  const logEntities = [];
+
+  receipts.forEach((receipt, idx) => {
     const receiptId = `${receipt.blockNumber.toString()}-${idx}`;
     const transactionIndex = BigInt(receipt.transactionIndex);
-    const blockNumber = BigInt(receipt.blockNumber);
-
-    await TransactionReceipt.create({
+
+    receiptEntities.push({
       ...receipt,
       id: receiptId,
       gasUsed: receipt.gasUsed.toBigInt(),
@@ -25,16 +27,21 @@ export const handleBlock = async (substrateBlock: SubstrateBlock): Promise<void>
       status: BigInt(receipt.status),
       transactionIndex,
       blockNumber,
-    }).save();
+    });
 
-    await store.bulkCreate('Log', receipt.logs.map(log => ({
+    receipt.logs.forEach(log => logEntities.push({
       ...log,
       id: `${receiptId}-${log.logIndex}`,
       receiptId,
       transactionIndex,
       blockNumber,
       logIndex: BigInt(log.logIndex),
       removed: false,   // this field was removed by formatter.receipt...
-    })));
-  }
+    }));
+  });
+
+  await Promise.all([
+    store.bulkCreate('TransactionReceipt', receiptEntities),
+    store.bulkCreate('Log', logEntities),
+  ]);
 };