feat: update-all command

bin/dev-package.js

@@ -44,6 +44,22 @@ When <package-name> is not provided then all dependencies of a project at
 current working directory are ensured to be linked or installed
 up to dev-package installation rules
 
+Options:
+
+    --disable-git-pull     Do not pull changes from remote
+    --enable-git-push      Push committed changes to remote
+    --help,            -h  Show this message
+
+`
+	],
+	[
+		"update-all",
+		`dev-package v${ meta.version }
+
+Usage: dev-package update-all [-h | --help] [--disable-git-pull] [--enable-git-push]
+
+Ensures all packages in npm packages folder are properly installed and up to date
+
 Options:
 
     --disable-git-pull     Do not pull changes from remote
@@ -71,14 +87,14 @@ if (!command) {
 	process.exit(1);
 }
 
-const supportedCommands = new Set(["install"]);
+const supportedCommands = new Set(["install", "update-all"]);
 
 if (!supportedCommands.has(command)) {
 	process.stderr.write(`${ command } is not a suppported command\n\n${ usage }`);
 	process.exit(1);
 }
 
-require("../lib/private/cli")(packageName, {
+require("../lib/private/cli")(command, packageName, {
 	gitPull: !argv["disable-git-pull"],
 	gitPush: argv["enable-git-push"]
 });

lib/private/cli/index.js

@@ -7,16 +7,22 @@ const log                      = require("log4").get("dev-package")
     , DevPackageError          = require("../../dev-package-error")
     , resolveUserConfiguration = require("../resolve-user-configuration")
     , install                  = require("../../../install")
-    , installPackage           = require("../../../install-package");
+    , installPackage           = require("../../../install-package")
+    , updateAll                = require("../../../update-all");
 
-module.exports = async (packageName, inputOptions) => {
+module.exports = async (command, packageName, inputOptions) => {
 	cliFooter.shouldAddProgressAnimationPrefix = true;
 	cliFooter.updateProgress(["resolving user configuration"]);
 
 	const userConfiguration = await resolveUserConfiguration();
-	const installPromise = packageName
-		? installPackage(packageName, userConfiguration, inputOptions)
-		: install(process.cwd(), userConfiguration, inputOptions);
+	const installPromise = (() => {
+		if (command === "install") {
+			return packageName
+				? installPackage(packageName, userConfiguration, inputOptions)
+				: install(process.cwd(), userConfiguration, inputOptions);
+		}
+		if (command === "update-all") return updateAll(userConfiguration, inputOptions);
+	})();
 	const installsInProgress = new Map();
 
 	const logWordForms = {

lib/private/update-all.js

@@ -0,0 +1,28 @@
+"use strict";
+
+const { resolve }    = require("path")
+    , readdir        = require("fs2/readdir")
+    , installPackage = require("./install-package");
+
+module.exports = async (userConfiguration, inputOptions, progressData) => {
+	const { packagesPath, packagesMeta } = userConfiguration;
+	const { done } = progressData;
+
+	const conditionallyUpdatePackage = name => {
+		if (!packagesMeta[name]) return null; // Not recognized as dev package folder
+		if (done.has(name)) return null; // Already processed
+		return installPackage({ name }, userConfiguration, inputOptions, progressData);
+	};
+	for (const directoryName of await readdir(packagesPath, { type: { directory: true } })) {
+		// Intentionally (to avoid npm race conditions) process packages one by one
+		if (directoryName.startsWith("@")) {
+			for (const subDirectoryName of await readdir(resolve(packagesPath, directoryName), {
+				type: { directory: true }
+			})) {
+				await conditionallyUpdatePackage(`${ directoryName }/${ subDirectoryName }`);
+			}
+			continue;
+		}
+		await conditionallyUpdatePackage(directoryName);
+	}
+};

package.json

@@ -51,7 +51,8 @@
       {
         "files": [
           "lib/private/install-package/index.js",
-          "lib/private/setup-dependencies/index.js"
+          "lib/private/setup-dependencies/index.js",
+          "lib/private/update-all.js"
         ],
         "rules": {
           "no-await-in-loop": "off"

update-all.js

@@ -0,0 +1,16 @@
+"use strict";
+
+const toPlainObject       = require("es5-ext/object/normalize-options")
+    , ee                  = require("event-emitter")
+    , unifyEmitters       = require("event-emitter/unify")
+    , ensureConfiguration = require("./lib/private/ensure-user-configuration")
+    , updateAll           = require("./lib/private/update-all");
+
+module.exports = (configuration, options = {}) => {
+	const progressData = ee({ done: new Set(), ongoingMap: new Map(), externalsMap: new Map() });
+	const promise = ee(
+		updateAll(ensureConfiguration(configuration), toPlainObject(options), progressData)
+	);
+	unifyEmitters(progressData, promise);
+	return promise;
+};