RanchiMall/fcoin
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

migrate: chaindb2to3 fixes.

Browse Source
This commit is contained in:
Christopher Jeffrey 2017-07-03 04:59:07 -07:00
parent b6e6442026
commit 517a66309c
No known key found for this signature in database
GPG Key ID: 8962AB9DE6666BBD
4 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
migrate/chaindb2to3.js
View File

@ -70,7 +70,7 @@ async function readJournal() {
state = data.readUInt8(1, true);
hash = data.toString('hex', 2, 34);
console.log('Read journal.');
console.log('Reading journal.');
console.log('Recovering from state %d.', state);
return [state, hash];
@ -117,14 +117,17 @@ async function reserializeUndo(hash) {
if (hash !== encoding.NULL_HASH)
tip = await getEntry(hash);
console.log('Reserializing undo coins from tip %s.', tip.rhash());
console.log('Reserializing undo coins from tip %s.', util.revHex(tip.hash));
while (tip.height !== 0) {
let undoData = await db.get(pair('u', tip.hash));
let blockData = await db.get(pair('b', tip.hash));
let block, old, undo;
assert(undoData);
if (!undoData) {
tip = await getEntry(tip.prevBlock);
continue;
}
if (!blockData) {
if (!(await isPruned()))
@ -154,7 +157,7 @@ async function reserializeUndo(hash) {
item.coinbase = coin.coinbase;
item.output.script = output.script;
item.output.value = output.value;
item.spent = false;
item.spent = true;
item.raw = null;
// Store an index of heights and versions for later.
@ -231,7 +234,7 @@ async function cleanupIndex() {
async function reserializeCoins(hash) {
let batch = db.batch();
let start = false;
let start = true;
let total = 0;
let iter = db.iterator({
@ -539,6 +542,6 @@ function bpair(prefix, hash, index) {
console.log('Migration complete.');
process.exit(0);
}).catch((err) => {
})().catch((err) => {
throw err;
});

2
migrate/coins/coins.js
View File

@ -13,7 +13,7 @@ const Output = require('../../lib/primitives/output');
const BufferReader = require('../../lib/utils/reader');
const StaticWriter = require('../../lib/utils/staticwriter');
const encoding = require('../../lib/utils/encoding');
const compressor = require('../../lib/coins/compress');
const compressor = require('./compress');
const compress = compressor.compress;
const decompress = compressor.decompress;

4
migrate/coins/coinview.js
View File

@ -7,8 +7,8 @@
'use strict';
const assert = require('assert');
const Coins = require('../../lib/coins/coins');
const UndoCoins = require('../../lib/coins/undocoins');
const Coins = require('./coins');
const UndoCoins = require('./undocoins');
const BufferReader = require('../../lib/utils/reader');
const BufferWriter = require('../../lib/utils/writer');
const CoinEntry = Coins.CoinEntry;

4
migrate/coins/undocoins.js
View File

@ -11,8 +11,8 @@ const BufferReader = require('../../lib/utils/reader');
const StaticWriter = require('../../lib/utils/staticwriter');
const encoding = require('../../lib/utils/encoding');
const Output = require('../../lib/primitives/output');
const Coins = require('../../lib/coins');
const compressor = require('../../lib/compress');
const Coins = require('./coins');
const compressor = require('./compress');
const compress = compressor.compress;
const decompress = compressor.decompress;