ARCHIVE/Validation-Ledger-Tx-Store-to-xPOP
1
0
Fork 0
mirror of https://github.com/Xahau/Validation-Ledger-Tx-Store-to-xPOP.git synced 2025-11-04 20:35:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Change file path & improve logging info

Browse Source
This commit is contained in:
Wietse Wind
2023-10-01 23:39:15 +02:00
parent b59e396aef
commit 938c61691a
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
lib/onLedger.mjs
View File

@@ -1,6 +1,7 @@
import { writeFile } from 'fs' import { writeFile } from 'fs'
import { stat } from 'fs' import { stat } from 'fs'
import { ledgerIndexToFolders } from './ledgerIndexToFolders.mjs' import { ledgerIndexToFolders } from './ledgerIndexToFolders.mjs'
import { computeBinaryTransactionHash } from './computeBinaryTransactionHash.mjs'
import 'dotenv/config' import 'dotenv/config'
const obtainedHumanReadableLedgers = [] const obtainedHumanReadableLedgers = []
@@ -60,7 +61,15 @@ const onLedger = async ({
obtainedBinaryTxLedgers.unshift(results.ledger_index) obtainedBinaryTxLedgers.unshift(results.ledger_index)
obtainedBinaryTxLedgers.length = 250 obtainedBinaryTxLedgers.length = 250
console.log('Obtained ledger (binary)', results.ledger_index, results.ledger.transactions.length) console.log('Obtained ledger (binary)', relativeStoreDir, results.ledger_index, 'TX#', results.ledger.transactions.length)
/**
* Merge transaction hashes with the raw tx data
*/
results.ledger.transactions.map(t => {
return Object.assign(t, { tx_id: computeBinaryTransactionHash(t.tx_blob), })
})
writeFile(storeDir + '/ledger_binary_transactions.json', Buffer.from(JSON.stringify(results.ledger), 'utf8'), err => { writeFile(storeDir + '/ledger_binary_transactions.json', Buffer.from(JSON.stringify(results.ledger), 'utf8'), err => {
if (err) { if (err) {
console.log('Error writing file @ ' + storeDir) console.log('Error writing file @ ' + storeDir)
@@ -77,8 +86,9 @@ const onLedger = async ({
obtainedHumanReadableLedgers.unshift(results.ledger_index) obtainedHumanReadableLedgers.unshift(results.ledger_index)
obtainedHumanReadableLedgers.length = 250 obtainedHumanReadableLedgers.length = 250
console.log('Obtained ledger (JSON object)', results.ledger_index, results.ledger.ledger_hash) console.log('Obtained ledger (JSON object)', relativeStoreDir, results.ledger_index, 'Hash', results.ledger.ledger_hash)
writeFile(storeDir + '/ledger.json', Buffer.from(JSON.stringify(results.ledger), 'utf8'), err => {
writeFile(storeDir + '/ledger_info.json', Buffer.from(JSON.stringify(results.ledger), 'utf8'), err => {
if (err) { if (err) {
console.log('Error writing file @ ' + storeDir) console.log('Error writing file @ ' + storeDir)
} }