Musare/backend/logic/migration/migrations/migration9.js

import async from "async";

/**
 * Migration 9
 *
 * Migration for news
 *
 * @param {object} MigrationModule - the MigrationModule
 * @returns {Promise} - returns promise
 */
export default async function migrate(MigrationModule) {
	const newsModel = await MigrationModule.runJob("GET_MODEL", { modelName: "news" }, this);

	return new Promise((resolve, reject) => {
		async.waterfall(
			[
				next => {
					// return next("BLOCKED");
					this.log("INFO", `Migration 9. Finding news with document version 1.`);
					newsModel.find({ documentVersion: 1 }, (err, news) => {
						if (err) next(err);
						else {
							async.eachLimit(
								news.map(newi => newi._doc),
								1,
								(newi, next) => {
									newi.markdown = `# ${newi.title}\n\n`;
									newi.markdown += `## ${newi.description}\n\n`;

									if (newi.bugs) {
										newi.markdown += `**Bugs:**\n\n${newi.bugs.join(", ")}\n\n`;
									}

									if (newi.features) {
										newi.markdown += `**Features:**\n\n${newi.features.join(", ")}\n\n`;
									}

									if (newi.improvements) {
										newi.markdown += `**Improvements:**\n\n${newi.improvements.join(", ")}\n\n`;
									}

									if (newi.upcoming) {
										newi.markdown += `**Upcoming:**\n\n${newi.upcoming.join(", ")}\n`;
									}

									newsModel.updateOne(
										{ _id: newi._id },
										{
											$set: {
												markdown: newi.markdown,
												status: "published",
												documentVersion: 2
											},
											$unset: {
												description: "",
												bugs: "",
												features: "",
												improvements: "",
												upcoming: ""
											}
										},
										next
									);
								},
								err => {
									if (err) next(err);
									else {
										this.log("INFO", `Migration 9. News found: ${news.length}.`);
										next();
									}
								}
							);
						}
					});
				}
			],
			err => {
				if (err) {
					reject(new Error(err));
				} else {
					resolve();
				}
			}
		);
	});
}