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

Fix linter issues and typo

Browse Source
This commit is contained in:
nymkappa 2022-01-20 16:34:14 +09:00
parent 979c52d3c4
commit 1210643e8e
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
backend/src/api/pools-parser.ts
View File

@ -3,10 +3,10 @@ import { DB } from '../database';
import logger from '../logger'; import logger from '../logger';
interface Pool { interface Pool {
name: string, name: string;
link: string, link: string;
regexes: string[], regexes: string[];
addresses: string[], addresses: string[];
} }
class PoolsParser { class PoolsParser {
@ -18,14 +18,14 @@ class PoolsParser {
logger.info('Importing pools.json to the database'); logger.info('Importing pools.json to the database');
// Get existing pools from the db // Get existing pools from the db
const [existingPools] = await connection.query<any>({ sql: 'SELECT * FROM pools;', timeout: 120000 }); // We clear the table before insertion const [existingPools] = await connection.query<any>({ sql: 'SELECT * FROM pools;', timeout: 120000 });
logger.info('Open ./pools.json'); logger.info('Open ./pools.json');
const fileContent: string = readFileSync('./pools.json','utf8'); const fileContent: string = readFileSync('./pools.json', 'utf8');
const poolsJson: object = JSON.parse(fileContent); const poolsJson: object = JSON.parse(fileContent);
// First we save every entries without paying attention to pool duplication // First we save every entries without paying attention to pool duplication
let poolsDuplicated: Pool[] = []; const poolsDuplicated: Pool[] = [];
logger.info('Parse coinbase_tags'); logger.info('Parse coinbase_tags');
const coinbaseTags = Object.entries(poolsJson['coinbase_tags']); const coinbaseTags = Object.entries(poolsJson['coinbase_tags']);
@ -50,7 +50,7 @@ class PoolsParser {
// Then, we find unique mining pool names // Then, we find unique mining pool names
logger.info('Identify unique mining pools'); logger.info('Identify unique mining pools');
let poolNames : string[] = []; const poolNames: string[] = [];
for (let i = 0; i < poolsDuplicated.length; ++i) { for (let i = 0; i < poolsDuplicated.length; ++i) {
if (poolNames.indexOf(poolsDuplicated[i].name) === -1) { if (poolNames.indexOf(poolsDuplicated[i].name) === -1) {
poolNames.push(poolsDuplicated[i].name); poolNames.push(poolsDuplicated[i].name);
@ -59,47 +59,47 @@ class PoolsParser {
logger.info(`Found ${poolNames.length} unique mining pools`); logger.info(`Found ${poolNames.length} unique mining pools`);
// Finally, we generate the final consolidated pools data // Finally, we generate the final consolidated pools data
let finalPoolDataAdd: Pool[] = []; const finalPoolDataAdd: Pool[] = [];
let finalPoolDataUpdate: Pool[] = []; const finalPoolDataUpdate: Pool[] = [];
for (let i = 0; i < poolNames.length; ++i) { for (let i = 0; i < poolNames.length; ++i) {
let allAddresses: string[] = []; let allAddresses: string[] = [];
let allRegexes: string[] = []; let allRegexes: string[] = [];
let match = poolsDuplicated.filter((pool: Pool) => pool.name === poolNames[i]); const match = poolsDuplicated.filter((pool: Pool) => pool.name === poolNames[i]);
for (let y = 0; y < match.length; ++y) { for (let y = 0; y < match.length; ++y) {
allAddresses = allAddresses.concat(match[y].addresses); allAddresses = allAddresses.concat(match[y].addresses);
allRegexes = allRegexes.concat(match[y].regexes); allRegexes = allRegexes.concat(match[y].regexes);
} }
const finalPoolName = poolNames[i].replace("'", "''"); // To support single quote in names when doing db queries const finalPoolName = poolNames[i].replace(`'`, `''`); // To support single quote in names when doing db queries
if (existingPools.find((pool) => { return pool.name === poolNames[i]}) !== undefined) { if (existingPools.find((pool) => pool.name === poolNames[i]) !== undefined) {
logger.debug(`Update '${finalPoolName} mining pool`); logger.debug(`Update '${finalPoolName}' mining pool`);
finalPoolDataUpdate.push({ finalPoolDataUpdate.push({
'name': finalPoolName, 'name': finalPoolName,
'link': match[0].link, 'link': match[0].link,
'regexes': allRegexes, 'regexes': allRegexes,
'addresses': allAddresses, 'addresses': allAddresses,
}) });
} else { } else {
logger.debug(`Add '${finalPoolName} mining pool`); logger.debug(`Add '${finalPoolName}' mining pool`);
finalPoolDataAdd.push({ finalPoolDataAdd.push({
'name': finalPoolName, 'name': finalPoolName,
'link': match[0].link, 'link': match[0].link,
'regexes': allRegexes, 'regexes': allRegexes,
'addresses': allAddresses, 'addresses': allAddresses,
}) });
} }
} }
// Manually add the 'unknown pool' // Manually add the 'unknown pool'
if (existingPools.find((pool) => { return pool.name === "Uknown"}) !== undefined) { if (existingPools.find((pool) => pool.name === 'Unknown') !== undefined) {
finalPoolDataAdd.push({ finalPoolDataAdd.push({
'name': 'Unknown', 'name': 'Unknown',
'link': 'https://learnmeabitcoin.com/technical/coinbase-transaction', 'link': 'https://learnmeabitcoin.com/technical/coinbase-transaction',
regexes: [], regexes: [],
addresses: [], addresses: [],
}) });
} }
logger.info(`Update pools table now`); logger.info(`Update pools table now`);
@ -113,7 +113,7 @@ class PoolsParser {
queryAdd = queryAdd.slice(0, -1) + ';'; queryAdd = queryAdd.slice(0, -1) + ';';
// Add new mining pools into the database // Add new mining pools into the database
let updateQueries: string[] = []; const updateQueries: string[] = [];
for (let i = 0; i < finalPoolDataUpdate.length; ++i) { for (let i = 0; i < finalPoolDataUpdate.length; ++i) {
updateQueries.push(` updateQueries.push(`
UPDATE pools UPDATE pools
@ -141,4 +141,4 @@ class PoolsParser {
} }
export default new PoolsParser(); export default new PoolsParser();