function storeTransactions()

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);
                }
            });
        });
    });
}