Merge pull request #2094 from mempool/nymkappa/debug/insert-once-channels-stats-init

Make sure we have initial channel stats to display after fresh run
This commit is contained in:
softsimon 2022-07-14 18:51:26 +02:00 committed by GitHub
commit c6f33310e5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -224,21 +224,38 @@ class LightningStatsUpdater {
total_capacity, total_capacity,
tor_nodes, tor_nodes,
clearnet_nodes, clearnet_nodes,
unannounced_nodes unannounced_nodes,
avg_capacity,
avg_fee_rate,
avg_base_fee_mtokens,
med_capacity,
med_fee_rate,
med_base_fee_mtokens
) )
VALUES (FROM_UNIXTIME(?), ?, ?, ?, ?, ?, ?)`; VALUES (FROM_UNIXTIME(?), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`;
const rowTimestamp = date.getTime() / 1000; // Save timestamp for the row insertion down below
date.setUTCDate(date.getUTCDate() + 1);
// Last iteration, save channels stats
const channelStats = (date >= currentDate ? await channelsApi.$getChannelsStats() : undefined);
await DB.query(query, [ await DB.query(query, [
date.getTime() / 1000, rowTimestamp,
channelsCount, channelsCount,
nodeCount, nodeCount,
totalCapacity, totalCapacity,
torNodes, torNodes,
clearnetNodes, clearnetNodes,
unannouncedNodes, unannouncedNodes,
]); channelStats?.avgCapacity ?? 0,
channelStats?.avgFeeRate ?? 0,
date.setUTCDate(date.getUTCDate() + 1); channelStats?.avgBaseFee ?? 0,
channelStats?.medianCapacity ?? 0,
channelStats?.medianFeeRate ?? 0,
channelStats?.medianBaseFee ?? 0,
]);
} }
logger.info('Historical stats populated.'); logger.info('Historical stats populated.');