2fdc737355
* bugfix, lint and refactor all bin scripts * for squash: throw Error(message) rather than log(message); throw Error() * for squash: Exit non-0 on unhandled Promise rejection Many of the recent lint changes have converted normal functions to async functions, and an error thrown in an async function does not cause Node.js to exit by default. * for squash: fix `require()` paths * for squash: remove erroneous `Object.keys()` call * for squash: fix missing `continue` statements * for squash: Fix HTTP method for deleteSession * for squash: delete erroneous throw Throw is only for errors, not successful completion. * for squash: redo migrateDirtyDBtoRealDB.js to fix async bugs * for squash: fix erroneous use of `for..of` * for squash: Add line break between statements * for squash: put closing paren on same line as last arg * for squash: Move `log()` back up where it was to minimize the diff to develop * for squash: indentation fixes * for squash: typo fix * for squash: wrap long lines * for squash: use `util.callbackify` to silence promise/no-callback-in-promise warning * for squash: use double quotes to improve readability Co-authored-by: Richard Hansen <rhansen@rhansen.org>
95 lines
3.2 KiB
JavaScript
95 lines
3.2 KiB
JavaScript
'use strict';
|
|
/*
|
|
* This is a debug tool. It checks all revisions for data corruption
|
|
*/
|
|
|
|
// As of v14, Node.js does not exit when there is an unhandled Promise rejection. Convert an
|
|
// unhandled rejection into an uncaught exception, which does cause Node.js to exit.
|
|
process.on('unhandledRejection', (err) => { throw err; });
|
|
|
|
if (process.argv.length !== 2) throw new Error('Use: node bin/checkAllPads.js');
|
|
|
|
// load and initialize NPM
|
|
const npm = require('ep_etherpad-lite/node_modules/npm');
|
|
npm.load({}, async () => {
|
|
try {
|
|
// initialize the database
|
|
require('ep_etherpad-lite/node/utils/Settings');
|
|
const db = require('ep_etherpad-lite/node/db/DB');
|
|
await db.init();
|
|
|
|
// load modules
|
|
const Changeset = require('ep_etherpad-lite/static/js/Changeset');
|
|
const padManager = require('ep_etherpad-lite/node/db/PadManager');
|
|
|
|
let revTestedCount = 0;
|
|
|
|
// get all pads
|
|
const res = await padManager.listAllPads();
|
|
for (const padId of res.padIDs) {
|
|
const pad = await padManager.getPad(padId);
|
|
|
|
// check if the pad has a pool
|
|
if (pad.pool === undefined) {
|
|
console.error(`[${pad.id}] Missing attribute pool`);
|
|
continue;
|
|
}
|
|
// create an array with key kevisions
|
|
// key revisions always save the full pad atext
|
|
const head = pad.getHeadRevisionNumber();
|
|
const keyRevisions = [];
|
|
for (let rev = 0; rev < head; rev += 100) {
|
|
keyRevisions.push(rev);
|
|
}
|
|
|
|
// run through all key revisions
|
|
for (const keyRev of keyRevisions) {
|
|
// create an array of revisions we need till the next keyRevision or the End
|
|
const revisionsNeeded = [];
|
|
for (let rev = keyRev; rev <= keyRev + 100 && rev <= head; rev++) {
|
|
revisionsNeeded.push(rev);
|
|
}
|
|
|
|
// this array will hold all revision changesets
|
|
const revisions = [];
|
|
|
|
// run through all needed revisions and get them from the database
|
|
for (const revNum of revisionsNeeded) {
|
|
const revision = await db.get(`pad:${pad.id}:revs:${revNum}`);
|
|
revisions[revNum] = revision;
|
|
}
|
|
|
|
// check if the revision exists
|
|
if (revisions[keyRev] == null) {
|
|
console.error(`[${pad.id}] Missing revision ${keyRev}`);
|
|
continue;
|
|
}
|
|
|
|
// check if there is a atext in the keyRevisions
|
|
if (revisions[keyRev].meta === undefined || revisions[keyRev].meta.atext === undefined) {
|
|
console.error(`[${pad.id}] Missing atext in revision ${keyRev}`);
|
|
continue;
|
|
}
|
|
|
|
const apool = pad.pool;
|
|
let atext = revisions[keyRev].meta.atext;
|
|
for (let rev = keyRev + 1; rev <= keyRev + 100 && rev <= head; rev++) {
|
|
try {
|
|
const cs = revisions[rev].changeset;
|
|
atext = Changeset.applyToAText(cs, atext, apool);
|
|
revTestedCount++;
|
|
} catch (e) {
|
|
console.error(`[${pad.id}] Bad changeset at revision ${rev} - ${e.message}`);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (revTestedCount === 0) {
|
|
throw new Error('No revisions tested');
|
|
}
|
|
console.log(`Finished: Tested ${revTestedCount} revisions`);
|
|
} catch (err) {
|
|
console.trace(err);
|
|
throw err;
|
|
}
|
|
});
|