Merge pull request #196 from codemod-js/abort-semantic-release-monorepo

Abort semantic release monorepo

script/_commands/release.ts

@@ -1,25 +1,10 @@
 import runInPackages from '../_utils/runInPackages';
-import runInDirectory from '../_utils/runInDirectory';
 
 export default async function main(
   args: Array<string>,
   stdin: NodeJS.ReadStream,
   stdout: NodeJS.WriteStream,
   stderr: NodeJS.WriteStream
 ): Promise<void> {
-  await runInDirectory(
-    stdin,
-    stdout,
-    stderr,
-    '.',
-    'npm',
-    ['install', '-g', 'semantic-release', 'semantic-release-monorepo']
-  );
-  await runInPackages(
-    stdin,
-    stdout,
-    stderr,
-    'semantic-release',
-    ['-e', 'semantic-release-monorepo']
-  );
+  await runInPackages(stdin, stdout, stderr, 'npx', ['semantic-release']);
 }

script/_utils/runInPackages.ts

@@ -1,7 +1,7 @@
 import * as globby from 'globby';
+import { spawn } from 'child_process';
 import { readFile } from 'mz/fs';
 import { join } from 'path';
-import runInDirectory from './runInDirectory';
 
 export default async function runInPackages(
   stdin: NodeJS.ReadStream,
@@ -12,10 +12,43 @@ export default async function runInPackages(
   packages?: Array<string>
 ): Promise<void> {
   for (const pkg of await (packages || findPackages())) {
-    await runInDirectory(stdin, stdout, stderr, pkg, command, args);
+    await runForPackage(stdin, stdout, stderr, pkg, command, args);
   }
 }
 
+async function runForPackage(
+  stdin: NodeJS.ReadStream,
+  stdout: NodeJS.WriteStream,
+  stderr: NodeJS.WriteStream,
+  pkg: string,
+  command: string,
+  args: Array<string> = []
+): Promise<void> {
+  return new Promise<void>((resolve, reject) => {
+    stdout.write(`${pkg} ❯ ${command} ${args.join(' ')}\n`);
+
+    const child = spawn(
+      command,
+      args,
+      {
+        cwd: pkg,
+        stdio: [stdin, stdout, stderr]
+      });
+
+    child.on('exit', code => {
+      if (code === 0) {
+        resolve();
+      } else {
+        reject(new Error(`exit status was ${code} for command: ${command} args: [${args.join(' ')}]`));
+      }
+    });
+
+    child.on('error', error => {
+      reject(error);
+    });
+  });
+}
+
 async function findPackages(): Promise<Array<string>> {
   const globs = JSON.parse(await readFile(join(__dirname, '../../package.json'), 'utf8')).workspaces;
   return await globby(globs, { onlyDirectories: true });