Index asciiScriptSig and display it in /mining/blocks

backend/src/api/blocks.ts

@@ -108,9 +108,7 @@ class Blocks {
     const blockExtended: BlockExtended = Object.assign({ extras: {} }, block);
     blockExtended.extras.reward = transactions[0].vout.reduce((acc, curr) => acc + curr.value, 0);
     blockExtended.extras.coinbaseTx = transactionUtils.stripCoinbaseTransaction(transactions[0]);
-
-    const coinbaseRaw: IEsploraApi.Transaction = await bitcoinApi.$getRawTransaction(transactions[0].txid, true, false, block.id);
-    blockExtended.extras.coinbaseRaw = coinbaseRaw.hex;
+    blockExtended.extras.coinbaseRaw = transactionUtils.hex2ascii(blockExtended.extras.coinbaseTx.vin[0].scriptsig);
 
     if (block.height === 0) {
       blockExtended.extras.medianFee = 0; // 50th percentiles
@@ -410,6 +408,7 @@ class Blocks {
       weight: block.weight,
       previousblockhash: block.previousblockhash,
       extras: {
+        coinbaseRaw: block.coinbase_raw ?? block.extras.coinbaseRaw,
         medianFee: block.medianFee ?? block.median_fee ?? block.extras?.medianFee,
         feeRange: block.feeRange ?? block.fee_range ?? block?.extras?.feeSpan,
         reward: block.reward ?? block?.extras?.reward,

backend/src/api/database-migration.ts

@@ -6,7 +6,7 @@ import logger from '../logger';
 const sleep = (ms: number) => new Promise(res => setTimeout(res, ms));
 
 class DatabaseMigration {
-  private static currentVersion = 14;
+  private static currentVersion = 15;
   private queryTimeout = 120000;
   private statisticsAddedIndexed = false;
 
@@ -175,6 +175,12 @@ class DatabaseMigration {
         await this.$executeQuery(connection, 'ALTER TABLE `hashrates` MODIFY `pool_id` SMALLINT UNSIGNED NOT NULL DEFAULT "0"');
       }
 
+      if (databaseSchemaVersion < 15 && isBitcoin === true) {
+        logger.warn(`'blocks' table has been truncated. Re-indexing from scratch.`);
+        await this.$executeQuery(connection, 'TRUNCATE blocks;'); // Need to re-index
+        await this.$executeQuery(connection, 'ALTER TABLE `blocks` MODIFY `coinbase_raw` TEXT COLLATE "utf8mb4_general_ci" NULL ');
+      }
+
       connection.release();
     } catch (e) {
       connection.release();

backend/src/api/transaction-utils.ts

@@ -45,12 +45,21 @@ class TransactionUtils {
     return transactionExtended;
   }
 
-  public hex2ascii(hex: string) {
-    let str = '';
-    for (let i = 0; i < hex.length; i += 2) {
-      str += String.fromCharCode(parseInt(hex.substr(i, 2), 16));
+  public hex2ascii(hex: string): string {
+    const opPush = hex.split(' ').filter((_, i, a) => i > 0 && /^OP_PUSH/.test(a[i - 1]));
+
+    if (opPush[0]) {
+      hex = opPush[0];
     }
-    return str;
+
+    if (!hex) {
+      return '';
+    }
+    const bytes: number[] = [];
+    for (let i = 0; i < hex.length; i += 2) {
+      bytes.push(parseInt(hex.substr(i, 2), 16));
+    }
+    return new TextDecoder('utf8').decode(Uint8Array.from(bytes));
   }
 }
 

backend/src/repositories/BlocksRepository.ts

@@ -32,7 +32,7 @@ class BlocksRepository {
         block.size,
         block.weight,
         block.tx_count,
-        block.extras.coinbaseRaw,
+        connection.escape(block.extras.coinbaseRaw),
         block.difficulty,
         block.extras.pool?.id, // Should always be set to something
         block.extras.totalFees,
@@ -56,7 +56,7 @@ class BlocksRepository {
         logger.debug(`$saveBlockInDatabase() - Block ${block.height} has already been indexed, ignoring`);
       } else {
         connection.release();
-        logger.err('$saveBlockInDatabase() error' + (e instanceof Error ? e.message : e));
+        logger.err('$saveBlockInDatabase() error: ' + (e instanceof Error ? e.message : e));
         throw e;
       }
     }