|
|
@@ -5,13 +5,13 @@
|
|
|
var pagesCollection = db.getCollection('pages');
|
|
|
var revisionsCollection = db.getCollection('revisions');
|
|
|
|
|
|
-var processorName = process.env.PROCESSOR_NAME;
|
|
|
+var migrationFileName = process.env.MIGRATION_FILE_NAME;
|
|
|
var migrationType = process.env.MIGRATION_TYPE;
|
|
|
|
|
|
var batchSize = process.env.BATCH_SIZE ?? 100; // default 100 revisions in 1 bulkwrite
|
|
|
var batchSizeInterval = process.env.BATCH_INTERVAL ?? 3000; // default 3 sec
|
|
|
|
|
|
-var getProcessorArray = require(`./processors/${processorName}`);
|
|
|
+var getProcessorArray = require(`./migrations/${migrationFileName}`);
|
|
|
var processors = getProcessorArray(migrationType);
|
|
|
|
|
|
if (processors.length === 0) {
|