fix: bugs found by Rafa

Author: mschead

indexer/src/cache/init.ts

@@ -11,7 +11,7 @@ export const MEMORY_CACHE = new NodeCache({ stdTTL: 0 });
 
 const CACHE_TTL = 1000 * 60 * 5; // 5 minutes
 
-export default function initCache(context: ResolverContext) {
+export default async function initCache(context: ResolverContext) {
   const { blockRepository, networkRepository } = context;
 
   async function getHashRateAndTotalDifficulty() {
@@ -30,7 +30,7 @@ export default function initCache(context: ResolverContext) {
       };
       MEMORY_CACHE.set(HASH_RATE_AND_TOTAL_DIFFICULTY_KEY, newValue);
     } catch (err) {
-      console.log("Error getting hash rate and total difficulty");
+      console.log("Error getting hash rate and total difficulty", err);
     }
   }
 
@@ -39,7 +39,7 @@ export default function initCache(context: ResolverContext) {
       const networkStatistics = await networkRepository.getNetworkStatistics();
       MEMORY_CACHE.set(NETWORK_STATISTICS_KEY, networkStatistics);
     } catch (err) {
-      console.log("Error getting network statistics");
+      console.log("Error getting network statistics", err);
     }
   }
 
@@ -48,18 +48,18 @@ export default function initCache(context: ResolverContext) {
       const nodeInfo = await networkRepository.getNodeInfo();
       MEMORY_CACHE.set(NODE_INFO_KEY, nodeInfo);
     } catch (err) {
-      console.log("Error getting node info");
+      console.log("Error getting node info", err);
     }
   }
 
   MEMORY_CACHE.set(HASH_RATE_AND_TOTAL_DIFFICULTY_KEY, {
     totalDifficulty: -1,
   });
 
-  const getAllInfo = () => {
-    getHashRateAndTotalDifficulty();
-    getNetworkStatistics();
-    getNodeInfo();
+  const getAllInfo = async () => {
+    await getNetworkStatistics();
+    await getNodeInfo();
+    await getHashRateAndTotalDifficulty();
   };
 
   getAllInfo();

indexer/src/kadena-server/repository/infra/repository/block-db-repository.ts

@@ -12,6 +12,9 @@ import { blockValidator } from "../schema-validator/block-schema-validator";
 import Balance from "../../../../models/balance";
 import { handleSingleQuery } from "../../../utils/raw-query";
 import { formatGuard_NODE } from "../../../../utils/chainweb-node";
+import { MEMORY_CACHE } from "../../../../cache/init";
+import { NODE_INFO_KEY } from "../../../../cache/keys";
+import { GetNodeInfo } from "../../application/network-repository";
 
 export default class BlockDbRepository implements BlockRepository {
   async getBlockByHash(hash: string) {
@@ -127,12 +130,8 @@ export default class BlockDbRepository implements BlockRepository {
   }
 
   async getChainIds() {
-    const query = `
-      SELECT DISTINCT b."chainId"
-      FROM "Blocks" b
-    `;
-    const { rows } = await rootPgPool.query(query);
-    return rows.map((r) => Number(r.chainId));
+    const nodeInfo = MEMORY_CACHE.get(NODE_INFO_KEY) as GetNodeInfo;
+    return nodeInfo.nodeChains.map((chainId) => Number(chainId));
   }
 
   async getCompletedBlocks(params: GetCompletedBlocksParams) {

indexer/src/kadena-server/repository/infra/repository/event-db-repository.ts

@@ -159,7 +159,7 @@ export default class EventDbRepository implements EventRepository {
 
     if (requestKey) {
       queryParams.push(requestKey);
-      conditions += `\nAND e."requestkey" = $${queryParams.length}`;
+      conditions += `\nAND t."requestkey" = $${queryParams.length}`;
     }
 
     if (before) {
@@ -174,7 +174,7 @@ export default class EventDbRepository implements EventRepository {
 
     const query = `
       select e.id as id,
-        e.requestkey as "requestKey",
+        t.requestkey as "requestKey",
         b."chainId" as "chainId",
         b.height as height,
         e.module as "moduleName",

indexer/src/kadena-server/repository/infra/repository/transaction-db-repository.ts

@@ -4,7 +4,6 @@ import TransactionRepository, {
   GetTransactionsByRequestKey,
   GetTransactionsCountParams,
   GetTransactionsParams,
-  SignerOutput,
   TransactionOutput,
 } from "../../application/transaction-repository";
 import { getPageInfo } from "../../pagination";
@@ -257,7 +256,7 @@ export default class TransactionDbRepository implements TransactionRepository {
       t.requestkey as "requestKey"
       FROM "Transactions" t
       JOIN "Blocks" b on t."blockId" = b.id 
-      WHERE t.requestkey = $1
+      WHERE t.requestkey::text = $1
       ${conditions}
       `;
 
@@ -290,32 +289,33 @@ export default class TransactionDbRepository implements TransactionRepository {
     }
 
     const query = `
-      SELECT t.id as id,
-      t.hash as "hashTransaction",
-      t.nonce as "nonceTransaction",
-      t.sigs as sigs,
-      t.continuation as continuation,
-      t.num_events as "eventCount",
-      t.pactid as "pactId",
-      t.proof as proof,
-      t.rollback as rollback,
-      b.height as "height",
-      b."hash" as "blockHash",
-      b."chainId" as "chainId",
-      t.gas as "gas",
-      t.step as step,
-      t.data as data,
-      t.code as code,
-      t.logs as "logs",
-      t.result as "result",
-      t.requestkey as "requestKey"
+      SELECT
+        t.id as id,
+        t.hash as "hashTransaction",
+        t.nonce as "nonceTransaction",
+        t.sigs as sigs,
+        t.continuation as continuation,
+        t.num_events as "eventCount",
+        t.pactid as "pactId",
+        t.proof as proof,
+        t.rollback as rollback,
+        b.height as "height",
+        b."hash" as "blockHash",
+        b."chainId" as "chainId",
+        t.gas as "gas",
+        t.step as step,
+        t.data as data,
+        t.code as code,
+        t.logs as "logs",
+        t.result as "result",
+        t.requestkey as "requestKey"
       FROM "Transactions" t
-      JOIN "Blocks" b on t."blockId" = b.id
-      WHERE t.id IN (
+      JOIN "Blocks" b ON t."blockId" = b.id
+      JOIN (
         SELECT DISTINCT s."transactionId"
         FROM "Signers" s
         WHERE s."pubkey" = $2
-      )
+      ) filtered_signers ON t.id = filtered_signers."transactionId"
       ${cursorCondition}
       ORDER BY t.id ${before ? "DESC" : "ASC"}
       LIMIT $1;
@@ -508,7 +508,7 @@ export default class TransactionDbRepository implements TransactionRepository {
         t.requestkey as "requestKey"
       FROM "Signers" s
       JOIN "Transactions" t on s."transactionId" = t.id
-      WHERE s."transactionId" = $1
+      WHERE t.id = $1
     `;
 
     if (orderIndex) {

indexer/src/kadena-server/server.ts

@@ -139,9 +139,9 @@ export async function useKadenaGraphqlServer() {
     });
   });
 
+  await initCache(context);
   await new Promise<void>((resolve) =>
     httpServer.listen({ port: KADENA_GRAPHQL_API_PORT }, resolve),
   );
-  initCache(context);
   console.log(`Server running on port ${KADENA_GRAPHQL_API_PORT}.`);
 }

indexer/src/models/signer.ts

@@ -80,6 +80,10 @@ Signer.init(
         name: "signers_pubkey_transactionid_idx",
         fields: ["pubkey", "transactionId"],
       },
+      {
+        name: "signers_transaction_id_idx",
+        fields: ["transactionId"],
+      },
     ],
   },
 );