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

migrate: update chaindb5to6 migration

Browse Source
This commit is contained in:
Javed Khan 2019-03-27 18:58:27 +05:30 committed by Braydon Fuller
parent 32904c7940
commit 7342952ec4
No known key found for this signature in database
GPG Key ID: F24F232D108B3AD4
1 changed files with 41 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
migrate/chaindb5to6.js
View File

@ -17,6 +17,34 @@ const db = bdb.create({
createIfMissing: false
});
async function updateVersion() {
const ver = await checkVersion();
console.log('Updating version to %d.', ver + 1);
const buf = Buffer.allocUnsafe(5 + 4);
buf.write('chain', 0, 'ascii');
buf.writeUInt32LE(6, 5, true);
const parent = db.batch();
parent.put(layout.V.encode(), buf);
await parent.write();
}
async function checkVersion() {
console.log('Checking version.');
const data = await db.get(layout.V.encode());
assert(data, 'No version.');
const ver = data.readUInt32LE(5, true);
if (ver !== 5)
throw Error(`DB is version ${ver}.`);
return ver;
}
async function removeKey(name, key) {
const iter = db.iterator({
gte: key.min(),
@ -43,6 +71,16 @@ async function removeKey(name, key) {
console.log('Cleaned up %d %s index records.', total, name);
}
async function migrateIndexes() {
const t = bdb.key('t', ['hash256']);
const T = bdb.key('T', ['hash', 'hash256']);
const C = bdb.key('C', ['hash', 'hash256', 'uint32']);
await removeKey('hash -> tx', t);
await removeKey('addr -> tx', T);
await removeKey('addr -> coin', C);
}
/*
* Execute
*/
@ -51,24 +89,12 @@ async function removeKey(name, key) {
await db.open();
console.log('Opened %s.', process.argv[2]);
console.log('Checking version.');
await db.verify(layout.V.build(), 'chain', 5);
const t = bdb.key('t', ['hash256']);
const T = bdb.key('T', ['hash', 'hash256']);
const C = bdb.key('C', ['hash', 'hash256', 'uint32']);
await checkVersion();
await migrateIndexes();
await updateVersion();
await removeKey('hash -> tx', t);
await removeKey('addr -> tx', T);
await removeKey('addr -> coin', C);
console.log('Compacting database...');
await db.compactRange();
console.log('Updating version to %d.', 6);
await db.del(layout.V.build());
await db.verify(layout.V.build(), 'chain', 6);
await db.close();
})().then(() => {
console.log('Migration complete.');