65 lines
1.4 KiB
JavaScript
Executable File
65 lines
1.4 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
|
|
'use strict';
|
|
|
|
var HistoricSync = require('../lib/HistoricSync');
|
|
var async = require('async');
|
|
|
|
|
|
var historicSync = new HistoricSync({ shouldBroadcastSync: false });
|
|
var txDb=historicSync.sync.txDb;
|
|
var bDb=historicSync.sync.bDb;
|
|
|
|
var height = 0;
|
|
var hash = historicSync.genesis;
|
|
var tipHash;
|
|
|
|
async.series([
|
|
function(c){
|
|
txDb.checkVersion02(function(isV2){
|
|
var err;
|
|
if(isV2) err='Already in v0.2!';
|
|
return c(err);
|
|
});
|
|
},
|
|
function(c){
|
|
var script=[];
|
|
async.whilst(
|
|
function() {
|
|
return hash;
|
|
},
|
|
function (w_cb) {
|
|
script=script.concat(bDb._setHeightScript(hash,height));
|
|
bDb.getNext(hash,function(err,val){
|
|
if (err) return w_cb(err);
|
|
tipHash = hash;
|
|
hash = val;
|
|
if (hash) height++;
|
|
if (!(height%1000) || !hash) {
|
|
console.log('*update 1/2\t%d blocks processed', height);
|
|
bDb._runScript(script, function(err) {
|
|
script=[];
|
|
return w_cb(err);
|
|
});
|
|
}
|
|
else return w_cb();
|
|
});
|
|
}, c);
|
|
},
|
|
function(c){
|
|
console.log('Migrating txs... (this will take some minutes...)'); //TODO
|
|
bDb.migrateV02(c);
|
|
},
|
|
function(c){
|
|
bDb.setTip(tipHash, height, c);
|
|
},
|
|
function(c){
|
|
bDb.migrateV02cleanup(c);
|
|
},
|
|
],function(err){
|
|
if (err)
|
|
console.log('## '+err);
|
|
else
|
|
console.log('Finished OK.');
|
|
});
|