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

Make sure we work with integer in the stats importer

Browse Source
This commit is contained in:
nymkappa 2022-08-09 10:28:40 +02:00
parent abb078f7ee
commit 6a52725b63
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
2 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
backend/src/tasks/lightning/stats-updater.service.ts
View File

@ -25,9 +25,10 @@ class LightningStatsUpdater {
const date = new Date(); const date = new Date();
Common.setDateMidnight(date); Common.setDateMidnight(date);
logger.info(`Updating latest network stats`);
const networkGraph = await lightningApi.$getNetworkGraph(); const networkGraph = await lightningApi.$getNetworkGraph();
LightningStatsImporter.computeNetworkStats(date.getTime() / 1000, networkGraph); LightningStatsImporter.computeNetworkStats(date.getTime() / 1000, networkGraph);
logger.info(`Updated latest network stats`);
} }
} }

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

@ -128,32 +128,32 @@ class LightningStatsImporter {
if (channel.node1_policy !== undefined) { // Coming from the node if (channel.node1_policy !== undefined) { // Coming from the node
for (const policy of [channel.node1_policy, channel.node2_policy]) { for (const policy of [channel.node1_policy, channel.node2_policy]) {
if (policy && policy.fee_rate_milli_msat < 5000) { if (policy && policy.fee_rate_milli_msat < 5000) {
avgFeeRate += policy.fee_rate_milli_msat; avgFeeRate += parseInt(policy.fee_rate_milli_msat, 10);
feeRates.push(policy.fee_rate_milli_msat); feeRates.push(parseInt(policy.fee_rate_milli_msat, 10));
} }
if (policy && policy.fee_base_msat < 5000) { if (policy && policy.fee_base_msat < 5000) {
avgBaseFee += policy.fee_base_msat; avgBaseFee += parseInt(policy.fee_base_msat, 10);
baseFees.push(policy.fee_base_msat); baseFees.push(parseInt(policy.fee_base_msat, 10));
} }
} }
} else { // Coming from the historical import } else { // Coming from the historical import
if (channel.fee_rate_milli_msat < 5000) { if (channel.fee_rate_milli_msat < 5000) {
avgFeeRate += channel.fee_rate_milli_msat; avgFeeRate += parseInt(channel.fee_rate_milli_msat, 10);
feeRates.push(channel.fee_rate_milli_msat); feeRates.push(parseInt(channel.fee_rate_milli_msat), 10);
} }
if (channel.fee_base_msat < 5000) { if (channel.fee_base_msat < 5000) {
avgBaseFee += channel.fee_base_msat; avgBaseFee += parseInt(channel.fee_base_msat, 10);
baseFees.push(channel.fee_base_msat); baseFees.push(parseInt(channel.fee_base_msat), 10);
} }
} }
} }
avgFeeRate /= networkGraph.edges.length; avgFeeRate /= Math.max(networkGraph.edges.length, 1);
avgBaseFee /= networkGraph.edges.length; avgBaseFee /= Math.max(networkGraph.edges.length, 1);
const medCapacity = capacities.sort((a, b) => b - a)[Math.round(capacities.length / 2 - 1)]; const medCapacity = capacities.sort((a, b) => b - a)[Math.round(capacities.length / 2 - 1)];
const medFeeRate = feeRates.sort((a, b) => b - a)[Math.round(feeRates.length / 2 - 1)]; const medFeeRate = feeRates.sort((a, b) => b - a)[Math.round(feeRates.length / 2 - 1)];
const medBaseFee = baseFees.sort((a, b) => b - a)[Math.round(baseFees.length / 2 - 1)]; const medBaseFee = baseFees.sort((a, b) => b - a)[Math.round(baseFees.length / 2 - 1)];
const avgCapacity = Math.round(capacity / capacities.length); const avgCapacity = Math.round(capacity / Math.max(capacities.length, 1));
let query = `INSERT INTO lightning_stats( let query = `INSERT INTO lightning_stats(
added, added,
@ -251,6 +251,9 @@ class LightningStatsImporter {
}; };
} }
/**
* Import topology files LN historical data into the database
*/
async $importHistoricalLightningStats(): Promise<void> { async $importHistoricalLightningStats(): Promise<void> {
let latestNodeCount = 1; let latestNodeCount = 1;