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

Wrap lightning stats importer into try/catch

Browse Source
This commit is contained in:
nymkappa 2023-04-01 14:56:18 +09:00
parent 46fbd6aa49
commit a512884b65
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/src/tasks/lightning/sync-tasks/stats-importer.ts
View File

@ -15,6 +15,7 @@ class LightningStatsImporter {
topologiesFolder = config.LIGHTNING.TOPOLOGY_FOLDER; topologiesFolder = config.LIGHTNING.TOPOLOGY_FOLDER;
async $run(): Promise<void> { async $run(): Promise<void> {
try {
const [channels]: any[] = await DB.query('SELECT short_id from channels;'); const [channels]: any[] = await DB.query('SELECT short_id from channels;');
logger.info(`Caching funding txs for currently existing channels`, logger.tags.ln); logger.info(`Caching funding txs for currently existing channels`, logger.tags.ln);
await fundingTxFetcher.$fetchChannelsFundingTxs(channels.map(channel => channel.short_id)); await fundingTxFetcher.$fetchChannelsFundingTxs(channels.map(channel => channel.short_id));
@ -25,6 +26,9 @@ class LightningStatsImporter {
await this.$importHistoricalLightningStats(); await this.$importHistoricalLightningStats();
await this.$cleanupIncorrectSnapshot(); await this.$cleanupIncorrectSnapshot();
} catch (e) {
logger.err(`Exception in LightningStatsImporter::$run(). ${e}`);
}
} }
/** /**