Merge pull request #1501 from input-output-hk/release/be/0.30.x

LW-11640 Fix queries performances issue

Author: iccicci

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/ChainHistoryBuilder.ts

@@ -310,7 +310,9 @@ export class ChainHistoryBuilder {
       values: [ids]
     });
     const redeemerMap: TransactionDataMap<Cardano.Redeemer[]> = new Map();
-    for (const redeemer of result.rows) {
+    for (const redeemer of result.rows
+      .map(({ id, ...rest }) => ({ id: BigInt(id), ...rest }))
+      .sort((a, b) => Number(a.id - b.id))) {
       const txId = redeemer.tx_id.toString('hex') as unknown as Cardano.TransactionId;
       const currentRedeemers = redeemerMap.get(txId) ?? [];
       redeemerMap.set(txId, [...currentRedeemers, mapRedeemer(redeemer)]);

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/mappers.ts

@@ -161,7 +161,7 @@ const mapRedeemerPurpose = (purpose: RedeemerModel['purpose']): Cardano.Redeemer
     throw new NotImplementedError(`Failed to map redeemer "purpose": ${purpose}`);
   })();
 
-export const mapRedeemer = (redeemerModel: RedeemerModel): Cardano.Redeemer => ({
+export const mapRedeemer = (redeemerModel: Omit<RedeemerModel, 'id'>): Cardano.Redeemer => ({
   data: stubRedeemerData,
   executionUnits: {
     memory: Number(redeemerModel.unit_mem),

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/queries.ts

@@ -41,31 +41,14 @@ export const findTxCollateralsByIds = `
 	WHERE tx.id = ANY($1)
 	ORDER BY tx_in.id ASC`;
 
-export const findTxInputsByAddresses = `
-  ${selectTxInput()}
-	JOIN block ON tx.block_id = block.id
-  WHERE tx_out.address = ANY($1)
-	AND block.block_no >= $2
-	AND block.block_no <= $3
-	ORDER BY tx_in.id ASC`;
-
 export const findTxOutputsByIds = `
   	${selectTxOutput()}
   	WHERE tx.id = ANY($1)
 	ORDER BY tx_out.id ASC`;
 
-export const findTxOutputsByAddresses = `
-  ${selectTxOutput()}
-	JOIN block ON tx.block_id = block.id
-  WHERE tx_out.address = ANY($1)
-	AND block.block_no >= $2
-	AND block.block_no <= $3
-	ORDER BY tx_out.id ASC`;
-
 export const findCollateralOutputsByTxIds = `
 	${selectTxOutput(true)}
-	WHERE tx.id = ANY($1)
-  ORDER BY tx_out.id ASC`;
+	WHERE tx.id = ANY($1)`;
 
 export const findTip = `
 	SELECT 
@@ -181,6 +164,7 @@ export const findWithdrawalsByTxIds = `
 
 export const findRedeemersByTxIds = `
 	SELECT
+		redeemer.id AS id,
 		redeemer."index" AS "index",
 		redeemer.purpose AS purpose,
 		redeemer.script_hash AS script_hash,
@@ -189,8 +173,7 @@ export const findRedeemersByTxIds = `
 		tx.hash AS tx_id
 	FROM redeemer
 	JOIN tx ON tx.id = redeemer.tx_id
-	WHERE tx.id = ANY($1)
-	ORDER BY redeemer.id ASC`;
+	WHERE tx.id = ANY($1)`;
 
 export const findVotingProceduresByTxIds = `
 	SELECT

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/types.ts

@@ -109,6 +109,7 @@ export interface WithdrawalModel {
 }
 
 export interface RedeemerModel {
+  id: string;
   index: number;
   purpose: 'cert' | 'mint' | 'spend' | 'reward' | 'vote' | 'propose';
   script_hash: Buffer;

packages/cardano-services/test/ChainHistory/DbSyncChainHistoryProvider/mappers.test.ts

@@ -456,7 +456,7 @@ describe('chain history mappers', () => {
     );
   });
   describe('mapRedeemer', () => {
-    const redeemerModel: Omit<RedeemerModel, 'purpose'> = {
+    const redeemerModel: Omit<RedeemerModel, 'id' | 'purpose'> = {
       index: 1,
       script_hash: Buffer.from(hash28ByteBase16, 'hex'),
       tx_id: Buffer.from(transactionHash, 'hex'),