mirrors/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2025-02-23 06:35:15 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #2241 from mempool/nymkappa/bugfix/top-nodes-queries

Browse source 
Rewrite queries to get top nodes by channels and capacity
This commit is contained in:
wiz 2022-08-03 00:23:50 +00:00 • committed by GitHub
commit db779578d2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
backend/src/api/explorer/nodes.api.ts
View file

@ -66,16 +66,19 @@ class NodesApi {
public async $getTopCapacityNodes(): Promise<any> {
try {
let [rows]: any[] = await DB.query('SELECT UNIX_TIMESTAMP(MAX(added)) as maxAdded FROM node_stats');
const latestDate = rows[0].maxAdded;
const query = `
SELECT IF(nodes.alias = '', SUBSTRING(nodes.public_key, 1, 20), alias) as alias, nodes.public_key,
CAST(COALESCE(node_stats.capacity, 0) as INT) as capacity,
CAST(COALESCE(node_stats.channels, 0) as INT) as channels
FROM nodes
LEFT JOIN node_stats ON node_stats.public_key = nodes.public_key
ORDER BY node_stats.added DESC, node_stats.capacity DESC
LIMIT 10
SELECT nodes.public_key, nodes.alias, node_stats.capacity, node_stats.channels
FROM node_stats
JOIN nodes ON nodes.public_key = node_stats.public_key
WHERE added = FROM_UNIXTIME(${latestDate})
ORDER BY capacity DESC
LIMIT 10;
`;
const [rows]: any = await DB.query(query);
[rows] = await DB.query(query);
return rows;
} catch (e) {
logger.err('$getTopCapacityNodes error: ' + (e instanceof Error ? e.message : e));
@ -85,16 +88,19 @@ class NodesApi {
public async $getTopChannelsNodes(): Promise<any> {
try {
let [rows]: any[] = await DB.query('SELECT UNIX_TIMESTAMP(MAX(added)) as maxAdded FROM node_stats');
const latestDate = rows[0].maxAdded;
const query = `
SELECT IF(nodes.alias = '', SUBSTRING(nodes.public_key, 1, 20), alias) as alias, nodes.public_key,
CAST(COALESCE(node_stats.capacity, 0) as INT) as capacity,
CAST(COALESCE(node_stats.channels, 0) as INT) as channels
FROM nodes
LEFT JOIN node_stats
ON node_stats.public_key = nodes.public_key
ORDER BY node_stats.added DESC, node_stats.channels DESC
LIMIT 10`;
const [rows]: any = await DB.query(query);
SELECT nodes.public_key, nodes.alias, node_stats.capacity, node_stats.channels
FROM node_stats
JOIN nodes ON nodes.public_key = node_stats.public_key
WHERE added = FROM_UNIXTIME(${latestDate})
ORDER BY channels DESC
LIMIT 10;
`;
[rows] = await DB.query(query);
return rows;
} catch (e) {
logger.err('$getTopChannelsNodes error: ' + (e instanceof Error ? e.message : e));