feat(repair): add lerna repair command

.eslintrc.json

@@ -1,5 +1,8 @@
 {
   "root": true,
+  "parserOptions": {
+    "ecmaVersion": 2020
+  },
   "extends": ["airbnb-base", "plugin:jest/recommended", "plugin:node/recommended", "prettier"],
   "plugins": ["jest", "node"],
   "ignorePatterns": ["website/**/*"],

commands/info/README.md

@@ -6,7 +6,7 @@ Install [lerna](https://www.npmjs.com/package/lerna) for access to the `lerna` C
 
 ## Usage
 
-The `info` prints local environment information that proves to be useful especially while submitting bug reports.
+The `info` command prints local environment information that proves to be useful especially while submitting bug reports.
 
 `lerna info`
 

core/command/index.js

@@ -19,7 +19,7 @@ const { warnIfHanging } = require("./lib/warn-if-hanging");
 const DEFAULT_CONCURRENCY = os.cpus().length;
 
 class Command {
-  constructor(_argv) {
+  constructor(_argv, { skipValidations } = { skipValidations: false }) {
     log.pause();
     log.heading = "lerna";
 
@@ -49,7 +49,10 @@ class Command {
       chain = chain.then(() => this.configureOptions());
       chain = chain.then(() => this.configureProperties());
       chain = chain.then(() => this.configureLogging());
-      chain = chain.then(() => this.runValidations());
+      // For the special "repair" command we want to intitialize everything but don't want to run validations as that will end up becoming cyclical
+      if (!skipValidations) {
+        chain = chain.then(() => this.runValidations());
+      }
       chain = chain.then(() => this.runPreparations());
       chain = chain.then(() => this.runCommand());
 

core/lerna/commands/repair/command.js

@@ -0,0 +1,29 @@
+// @ts-check
+
+"use strict";
+
+/**
+ * @see https://github.com/yargs/yargs/blob/master/docs/advanced.md#providing-a-command-module
+ */
+exports.command = "repair";
+
+exports.describe = "Runs automated migrations to repair the state of a lerna repo";
+
+exports.builder = (yargs) => {
+  yargs.options({
+    /**
+     * equivalent to --loglevel=verbose, but added explicitly here because the repair()
+     * output will potentially contain instructions to run with --verbose
+     */
+    verbose: {
+      hidden: true,
+      type: "boolean",
+    },
+  });
+  return yargs;
+};
+
+exports.handler = function handler(argv) {
+  // eslint-disable-next-line global-require
+  return require(".")(argv);
+};

core/lerna/commands/repair/index.js

@@ -0,0 +1,56 @@
+// @ts-check
+
+"use strict";
+
+const { Command } = require("@lerna/command");
+const log = require("npmlog");
+const { repair } = require("nx/src/command-line/repair");
+const migrationsJson = require("../../migrations.json");
+
+module.exports = factory;
+
+function factory(argv) {
+  return new RepairCommand(argv);
+}
+
+class RepairCommand extends Command {
+  constructor(argv) {
+    super(argv, { skipValidations: true });
+  }
+
+  // eslint-disable-next-line class-methods-use-this
+  initialize() {}
+
+  async execute() {
+    this.configureNxOutput();
+    const verbose = this.options?.verbose ? true : log.level === "verbose";
+
+    const lernaMigrations = Object.entries(migrationsJson.generators).map(([name, migration]) => {
+      return /** @type {const} */ ({
+        package: "lerna",
+        cli: "nx",
+        name,
+        description: migration.description,
+        version: migration.version,
+      });
+    });
+
+    await repair({ verbose }, lernaMigrations);
+  }
+
+  configureNxOutput() {
+    try {
+      // eslint-disable-next-line global-require
+      const nxOutput = require("nx/src/utils/output");
+      nxOutput.output.cliName = "Lerna";
+      nxOutput.output.formatCommand = (taskId) => taskId;
+      return nxOutput;
+    } catch (err) {
+      this.logger.error("There was a critical issue when trying to execute the repair command.");
+      // Rethrow so that the lerna logger can automatically handle the unexpected error
+      throw err;
+    }
+  }
+}
+
+module.exports.RepairCommand = RepairCommand;

core/lerna/index.js

@@ -1,3 +1,5 @@
+// @ts-check
+
 "use strict";
 
 const cli = require("@lerna/cli");
@@ -18,6 +20,8 @@ const publishCmd = require("@lerna/publish/command");
 const runCmd = require("@lerna/run/command");
 const versionCmd = require("@lerna/version/command");
 
+const repairCmd = require("./commands/repair/command");
+
 const pkg = require("./package.json");
 
 module.exports = main;
@@ -27,6 +31,7 @@ function main(argv) {
     lernaVersion: pkg.version,
   };
 
+  // @ts-ignore
   return cli()
     .command(addCmd)
     .command(bootstrapCmd)
@@ -41,6 +46,7 @@ function main(argv) {
     .command(linkCmd)
     .command(listCmd)
     .command(publishCmd)
+    .command(repairCmd)
     .command(runCmd)
     .command(versionCmd)
     .parse(argv, context);

core/lerna/migrations.json

@@ -0,0 +1,10 @@
+{
+  "generators": {
+    "noop": {
+      "cli": "nx",
+      "version": "5.3.0",
+      "description": "Noop example migration, can be removed once a real migration is created",
+      "implementation": "./migrations/noop/noop"
+    }
+  }
+}

core/lerna/migrations/noop/noop.js

@@ -0,0 +1,6 @@
+// @ts-check
+
+// eslint-disable-next-line no-unused-vars
+exports.default = async function generator(tree) {
+  // This is a noop migration just to show how one would be written until the first real implementation is in place.
+};

core/lerna/migrations/noop/noop.test.js

@@ -0,0 +1,16 @@
+// @ts-check
+
+const { createTreeWithEmptyWorkspace } = require("@nrwl/devkit/testing");
+const { default: noopMigration } = require("./noop");
+
+describe("noop migration", () => {
+  let tree;
+
+  beforeEach(() => {
+    tree = createTreeWithEmptyWorkspace();
+  });
+
+  it("should be runnable and not throw", async () => {
+    await expect(noopMigration(tree)).resolves.toBeUndefined();
+  });
+});

core/lerna/package.json

@@ -19,7 +19,10 @@
   "files": [
     "index.js",
     "cli.js",
-    "schemas/lerna-schema.json"
+    "schemas/lerna-schema.json",
+    "migrations",
+    "commands",
+    "migrations.json"
   ],
   "engines": {
     "node": "^14.15.0 || >=16.0.0"
@@ -32,12 +35,16 @@
     "url": "git+https://github.com/lerna/lerna.git",
     "directory": "core/lerna"
   },
+  "nx-migrations": {
+    "migrations": "./migrations.json"
+  },
   "scripts": {
     "test": "echo \"Run tests from root\" && exit 1"
   },
   "dependencies": {
     "@lerna/add": "file:../../commands/add",
     "@lerna/bootstrap": "file:../../commands/bootstrap",
+    "@lerna/command": "file:../command",
     "@lerna/changed": "file:../../commands/changed",
     "@lerna/clean": "file:../../commands/clean",
     "@lerna/cli": "file:../cli",
@@ -52,6 +59,7 @@
     "@lerna/publish": "file:../../commands/publish",
     "@lerna/run": "file:../../commands/run",
     "@lerna/version": "file:../../commands/version",
+    "@nrwl/devkit": ">=14.8.1 < 16",
     "import-local": "^3.0.2",
     "npmlog": "^6.0.2",
     "nx": ">=14.8.1 < 16",

e2e/tests/lerna-repair/lerna-repair.spec.ts

@@ -0,0 +1,38 @@
+import { Fixture } from "../../utils/fixture";
+import { normalizeEnvironment } from "../../utils/snapshot-serializer-utils";
+
+expect.addSnapshotSerializer({
+  serialize(str) {
+    return normalizeEnvironment(str);
+  },
+  test(val) {
+    return val != null && typeof val === "string";
+  },
+});
+
+describe("lerna-repair", () => {
+  let fixture: Fixture;
+
+  beforeAll(async () => {
+    fixture = await Fixture.create({
+      name: "lerna-repair",
+      packageManager: "npm",
+      initializeGit: true,
+      runLernaInit: true,
+      installDependencies: true,
+    });
+  });
+  afterAll(() => fixture.destroy());
+
+  it("should run any existing migrations", async () => {
+    const output = await fixture.lerna("repair");
+
+    expect(output.combinedOutput).toMatchInlineSnapshot(`
+      lerna notice cli v999.9.9-e2e.0
+
+       >  Lerna   No changes were necessary. This workspace is up to date!
+
+
+    `);
+  });
+});

nx.json

@@ -1,4 +1,5 @@
 {
+  "$schema": "./node_modules/nx/schemas/nx-schema.json",
   "tasksRunnerOptions": {
     "default": {
       "runner": "@nrwl/nx-cloud",