in middleware/cron/syncTransactionHistory.js [155:188]
function storeTransactions(blocks) {
return new Promise((resolve, reject) => {
const timestamp = Math.floor(Date.now() / 1000);
db.serialize(() => {
const stmt = db.prepare(`
INSERT INTO transactions
(block_id,volume,created_at)
VALUES (?, ?, ?)
`);
let transactionCount = 0;
blocks.forEach(block => {
const { id,createdAt,transactions } = block;
stmt.run(
id,
Array.isArray(transactions) ? transactions?.length : 0,
createdAt,
);
});
stmt.finalize(err => {
if (err) {
logger.error('Error storing transactions:', err);
reject(err);
} else {
logger.info(`Successfully stored ${transactionCount} transactions from ${blocks.length} blocks`);
resolve(transactionCount);
}
});
});
});
}