Merge pull request #31 from likecoin/fix_import_typo

fix block importer fail insert due to typo
ArweaveTeam · Feb 19, 2022 · e86fb5a · e86fb5a
2 parents fdd6f77 + a6ab720
commit e86fb5a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/database/doctor.ts b/src/database/doctor.ts
@@ -47,12 +47,11 @@ export const findBlockGaps = async (
   );
 
   const missingHeights: number[] = [];
-
-  for (const heightGroup of queryHeightGroups) {
+  for (const [index, heightGroup] of queryHeightGroups.entries()) {
     const blockQ: { rows: unknown[] } = await cassandraClient.execute(
-      `SELECT block_height FROM ${KEYSPACE}.block_height_sorted_asc  WHERE height >= ${R.head(
+      `SELECT block_height FROM ${KEYSPACE}.block_height_sorted_asc  WHERE nth_million = ${index} AND block_height >= ${R.head(
         heightGroup
-      )} AND height <= ${R.last(heightGroup)}`
+      )} AND block_height <= ${R.last(heightGroup)}`
     );
     for (const height of R.range(
       R.head(heightGroup),

diff --git a/src/workers/import-block.ts b/src/workers/import-block.ts
@@ -56,7 +56,7 @@ export async function importBlock(
 
   try {
     await blockHeightToHashMapper.insert({
-      block_heigh: height,
+      block_height: height,
       block_hash: newBlock.indep_hash,
     });
   } catch (error) {
@@ -94,6 +94,7 @@ export async function importBlock(
 
   try {
     await blockSortedAscMapper.insert({
+      block_height: height,
       block_hash: newBlock.indep_hash,
       nth_million: nthMillBlock,
     });
@@ -103,6 +104,7 @@ export async function importBlock(
 
   try {
     await blockSortedDescMapper.insert({
+      block_height: height,
       block_hash: newBlock.indep_hash,
       nth_million: nthMillBlock,
     });