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

Refactor BlocksSummariesRepository::$saveSummary

Browse Source
This commit is contained in:
nymkappa 2022-07-15 11:03:59 +02:00
parent d8a1c0ac1b
commit 2872d2e299
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
4 changed files with 15 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/src/api/blocks.ts
View File

@ -578,7 +578,7 @@ class Blocks {
// Index the response if needed // Index the response if needed
if (Common.blocksSummariesIndexingEnabled() === true) { if (Common.blocksSummariesIndexingEnabled() === true) {
await BlocksSummariesRepository.$saveSummary(block.height, summary, null); await BlocksSummariesRepository.$saveSummary({height: block.height, mined: summary});
} }
return summary.transactions; return summary.transactions;

9
backend/src/api/websocket-handler.ts
View File

@ -451,9 +451,12 @@ class WebsocketHandler {
value: tx.value, value: tx.value,
}; };
}); });
BlocksSummariesRepository.$saveSummary(block.height, null, { BlocksSummariesRepository.$saveSummary({
id: block.id, height: block.height,
transactions: stripped template: {
id: block.id,
transactions: stripped
}
}); });
BlocksAuditsRepository.$saveAudit({ BlocksAuditsRepository.$saveAudit({

14
backend/src/repositories/BlocksSummariesRepository.ts
View File

@ -17,18 +17,18 @@ class BlocksSummariesRepository {
return undefined; return undefined;
} }
public async $saveSummary(height: number, mined: BlockSummary | null = null, template: BlockSummary | null = null) { public async $saveSummary(params: { height: number, mined?: BlockSummary, template?: BlockSummary}) {
const blockId = mined?.id ?? template?.id; const blockId = params.mined?.id ?? params.template?.id;
try { try {
const [dbSummary]: any[] = await DB.query(`SELECT * FROM blocks_summaries WHERE id = "${blockId}"`); const [dbSummary]: any[] = await DB.query(`SELECT * FROM blocks_summaries WHERE id = "${blockId}"`);
if (dbSummary.length === 0) { // First insertion if (dbSummary.length === 0) { // First insertion
await DB.query(`INSERT INTO blocks_summaries VALUE (?, ?, ?, ?)`, [ await DB.query(`INSERT INTO blocks_summaries VALUE (?, ?, ?, ?)`, [
height, blockId, JSON.stringify(mined?.transactions ?? []), JSON.stringify(template?.transactions ?? []) params.height, blockId, JSON.stringify(params.mined?.transactions ?? []), JSON.stringify(params.template?.transactions ?? [])
]); ]);
} else if (mined !== null) { // Update mined block summary } else if (params.mined !== undefined) { // Update mined block summary
await DB.query(`UPDATE blocks_summaries SET transactions = ? WHERE id = "${mined.id}"`, [JSON.stringify(mined?.transactions)]); await DB.query(`UPDATE blocks_summaries SET transactions = ? WHERE id = "${params.mined.id}"`, [JSON.stringify(params.mined.transactions)]);
} else if (template !== null) { // Update template block summary } else if (params.template !== undefined) { // Update template block summary
await DB.query(`UPDATE blocks_summaries SET template = ? WHERE id = "${template.id}"`, [JSON.stringify(template?.transactions)]); await DB.query(`UPDATE blocks_summaries SET template = ? WHERE id = "${params.template.id}"`, [JSON.stringify(params.template?.transactions)]);
} }
} catch (e: any) { } catch (e: any) {
if (e.errno === 1062) { // ER_DUP_ENTRY - This scenario is possible upon node backend restart if (e.errno === 1062) { // ER_DUP_ENTRY - This scenario is possible upon node backend restart

4
frontend/src/app/components/block-overview-graph/tx-view.ts
View File

@ -143,9 +143,7 @@ export default class TxView implements TransactionStripped {
getColor(): Color { getColor(): Color {
// Block audit // Block audit
if (this.status === 'found') { if (this.status === 'missing') {
// return hexToColor('1a4987');
} else if (this.status === 'missing') {
return hexToColor('039BE5'); return hexToColor('039BE5');
} else if (this.status === 'added') { } else if (this.status === 'added') {
return hexToColor('D81B60'); return hexToColor('D81B60');