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

Merge pull request #1470 from mempool/nymkappa/bugfix/insert-unknown-pool

Browse Source 
Fix query to insert unknown mining pool
This commit is contained in:
softsimon 2022-03-29 11:45:28 +04:00 committed by GitHub
commit cbb157a94c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -108,7 +108,7 @@ class PoolsParser {
if (slug === undefined) { if (slug === undefined) {
// Only keep alphanumerical // Only keep alphanumerical
slug = poolNames[i].replace(/[^a-z0-9]/gi,'').toLowerCase(); slug = poolNames[i].replace(/[^a-z0-9]/gi, '').toLowerCase();
logger.debug(`No slug found for '${poolNames[i]}', generating it => '${slug}'`); logger.debug(`No slug found for '${poolNames[i]}', generating it => '${slug}'`);
} }
@ -135,10 +135,11 @@ class PoolsParser {
logger.debug(`Update pools table now`); logger.debug(`Update pools table now`);
// Add new mining pools into the database // Add new mining pools into the database
let queryAdd: string = 'INSERT INTO pools(name, link, regexes, addresses) VALUES '; let queryAdd: string = 'INSERT INTO pools(name, link, regexes, addresses, slug) VALUES ';
for (let i = 0; i < finalPoolDataAdd.length; ++i) { for (let i = 0; i < finalPoolDataAdd.length; ++i) {
queryAdd += `('${finalPoolDataAdd[i].name}', '${finalPoolDataAdd[i].link}', queryAdd += `('${finalPoolDataAdd[i].name}', '${finalPoolDataAdd[i].link}',
'${JSON.stringify(finalPoolDataAdd[i].regexes)}', '${JSON.stringify(finalPoolDataAdd[i].addresses)}'),`; '${JSON.stringify(finalPoolDataAdd[i].regexes)}', '${JSON.stringify(finalPoolDataAdd[i].addresses)}',
${JSON.stringify(finalPoolDataAdd[i].slug)}),`;
} }
queryAdd = queryAdd.slice(0, -1) + ';'; queryAdd = queryAdd.slice(0, -1) + ';';
@ -180,7 +181,7 @@ class PoolsParser {
const [rows]: any[] = await connection.query({ sql: 'SELECT name from pools where name="Unknown"', timeout: 120000 }); const [rows]: any[] = await connection.query({ sql: 'SELECT name from pools where name="Unknown"', timeout: 120000 });
if (rows.length === 0) { if (rows.length === 0) {
await connection.query({ await connection.query({
sql: `INSERT INTO pools(name, link, regexes, addresses) sql: `INSERT INTO pools(name, link, regexes, addresses, slug)
VALUES("Unknown", "https://learnmeabitcoin.com/technical/coinbase-transaction", "[]", "[]", "unknown"); VALUES("Unknown", "https://learnmeabitcoin.com/technical/coinbase-transaction", "[]", "[]", "unknown");
`}); `});
} else { } else {
@ -189,7 +190,7 @@ class PoolsParser {
regexes='[]', addresses='[]', regexes='[]', addresses='[]',
slug='unknown' slug='unknown'
WHERE name='Unknown' WHERE name='Unknown'
`) `);
} }
} catch (e) { } catch (e) {
logger.err('Unable to insert "Unknown" mining pool'); logger.err('Unable to insert "Unknown" mining pool');