machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Empty Bisq blocks was missing. (#541)

Browse Source 
fixes #539
This commit is contained in:
softsimon 2021-06-06 16:07:26 -04:00 committed by GitHub
parent dec8ae2930
commit 8fbd273733
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/api/bisq/bisq.ts
View File

@ -11,6 +11,7 @@ class Bisq {
private static BLOCKS_JSON_FILE_PATH = config.BISQ.DATA_PATH + '/json/all/blocks.json'; private static BLOCKS_JSON_FILE_PATH = config.BISQ.DATA_PATH + '/json/all/blocks.json';
private latestBlockHeight = 0; private latestBlockHeight = 0;
private blocks: BisqBlock[] = []; private blocks: BisqBlock[] = [];
private allBlocks: BisqBlock[] = [];
private transactions: BisqTransaction[] = []; private transactions: BisqTransaction[] = [];
private transactionIndex: { [txId: string]: BisqTransaction } = {}; private transactionIndex: { [txId: string]: BisqTransaction } = {};
private blockIndex: { [hash: string]: BisqBlock } = {}; private blockIndex: { [hash: string]: BisqBlock } = {};
@ -171,7 +172,7 @@ class Bisq {
this.transactionIndex = {}; this.transactionIndex = {};
this.addressIndex = {}; this.addressIndex = {};
this.blocks.forEach((block) => { this.allBlocks.forEach((block) => {
/* Build block index */ /* Build block index */
if (!this.blockIndex[block.hash]) { if (!this.blockIndex[block.hash]) {
this.blockIndex[block.hash] = block; this.blockIndex[block.hash] = block;
@ -245,8 +246,9 @@ class Bisq {
if (cacheData && cacheData.length !== 0) { if (cacheData && cacheData.length !== 0) {
logger.debug('Processing Bisq data dump...'); logger.debug('Processing Bisq data dump...');
const data: BisqBlocks = await this.jsonParsePool.exec(cacheData); const data: BisqBlocks = await this.jsonParsePool.exec(cacheData);
if (data.blocks && data.blocks.length !== this.blocks.length) { if (data.blocks && data.blocks.length !== this.allBlocks.length) {
this.blocks = data.blocks.filter((block) => block.txs.length > 0); this.allBlocks = data.blocks;
this.blocks = this.allBlocks.filter((block) => block.txs.length > 0);
this.blocks.reverse(); this.blocks.reverse();
this.latestBlockHeight = data.chainHeight; this.latestBlockHeight = data.chainHeight;
const time = new Date().getTime() - start; const time = new Date().getTime() - start;