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

Merge pull request #2518 from mempool/nymkappa/feature/only-scan-closed-chan-new-block

Browse Source 
Only scan for closed channels when there is a new block
This commit is contained in:
softsimon 2022-09-08 17:44:10 +02:00 committed by GitHub
commit 249a65bb57
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
backend/src/tasks/lightning/network-sync.service.ts
View File

@ -12,9 +12,11 @@ import { ResultSetHeader } from 'mysql2';
import fundingTxFetcher from './sync-tasks/funding-tx-fetcher'; import fundingTxFetcher from './sync-tasks/funding-tx-fetcher';
import NodesSocketsRepository from '../../repositories/NodesSocketsRepository'; import NodesSocketsRepository from '../../repositories/NodesSocketsRepository';
import { Common } from '../../api/common'; import { Common } from '../../api/common';
import blocks from '../../api/blocks';
class NetworkSyncService { class NetworkSyncService {
loggerTimer = 0; loggerTimer = 0;
closedChannelsScanBlock = 0;
constructor() {} constructor() {}
@ -240,10 +242,22 @@ class NetworkSyncService {
} }
private async $scanForClosedChannels(): Promise<void> { private async $scanForClosedChannels(): Promise<void> {
if (this.closedChannelsScanBlock === blocks.getCurrentBlockHeight()) {
logger.debug(`We've already scan closed channels for this block, skipping.`);
return;
}
let progress = 0; let progress = 0;
try { try {
logger.info(`Starting closed channels scan`); let log = `Starting closed channels scan`;
if (this.closedChannelsScanBlock > 0) {
log += `. Last scan was at block ${this.closedChannelsScanBlock}`;
} else {
log += ` for the first time`;
}
logger.info(log);
const channels = await channelsApi.$getChannelsByStatus([0, 1]); const channels = await channelsApi.$getChannelsByStatus([0, 1]);
for (const channel of channels) { for (const channel of channels) {
const spendingTx = await bitcoinApi.$getOutspend(channel.transaction_id, channel.transaction_vout); const spendingTx = await bitcoinApi.$getOutspend(channel.transaction_id, channel.transaction_vout);
@ -263,7 +277,9 @@ class NetworkSyncService {
this.loggerTimer = new Date().getTime() / 1000; this.loggerTimer = new Date().getTime() / 1000;
} }
} }
logger.info(`Closed channels scan complete.`);
this.closedChannelsScanBlock = blocks.getCurrentBlockHeight();
logger.info(`Closed channels scan completed at block ${this.closedChannelsScanBlock}`);
} catch (e) { } catch (e) {
logger.err('$scanForClosedChannels() error: ' + (e instanceof Error ? e.message : e)); logger.err('$scanForClosedChannels() error: ' + (e instanceof Error ? e.message : e));
} }