|
|
@@ -4,7 +4,6 @@ import mongoose from 'mongoose';
|
|
|
import streamToPromise from 'stream-to-promise';
|
|
|
|
|
|
import getPageModel from '~/server/models/page';
|
|
|
-import { Revision } from '~/server/models/revision';
|
|
|
import { createBatchStream } from '~/server/util/batch-stream';
|
|
|
import { getModelSafely, getMongoUri, mongoOptions } from '~/server/util/mongoose-utils';
|
|
|
import loggerFactory from '~/utils/logger';
|
|
|
@@ -19,6 +18,7 @@ module.exports = {
|
|
|
async up(db, client) {
|
|
|
mongoose.connect(getMongoUri(), mongoOptions);
|
|
|
const Page = getModelSafely('Page') || getPageModel();
|
|
|
+ const Revision = await db.collection('revisions');
|
|
|
|
|
|
const pagesStream = await Page.find({ revision: { $ne: null } }, { _id: 1, path: 1 }).cursor({ batch_size: LIMIT });
|
|
|
const batchStrem = createBatchStream(LIMIT);
|
|
|
@@ -69,6 +69,7 @@ module.exports = {
|
|
|
async down(db, client) {
|
|
|
mongoose.connect(getMongoUri(), mongoOptions);
|
|
|
const Page = getModelSafely('Page') || getPageModel();
|
|
|
+ const Revision = await db.collection('revisions');
|
|
|
|
|
|
const pagesStream = await Page.find({ revision: { $ne: null } }, { _id: 1, path: 1 }).cursor({ batch_size: LIMIT });
|
|
|
const batchStrem = createBatchStream(LIMIT);
|