|
7 | 7 | */ |
8 | 8 | // tslint:disable:no-implicit-dependencies |
9 | 9 | import { logging } from '@angular-devkit/core'; |
10 | | -import { resolve } from '@angular-devkit/core/node'; |
11 | | -import * as stream from 'stream'; |
| 10 | +import { spawnSync } from 'child_process'; |
12 | 11 | import { packages } from '../lib/packages'; |
13 | 12 | import build from './build'; |
14 | 13 |
|
15 | | -const npm = require(resolve('npm', { basedir: '/', checkGlobal: true })); |
16 | 14 |
|
17 | | -class NullStream extends stream.Writable { |
18 | | - _write() {} |
| 15 | +function _exec(command: string, args: string[], opts: { cwd?: string }, logger: logging.Logger) { |
| 16 | + const { status, error, stderr, stdout } = spawnSync(command, args, { ...opts }); |
| 17 | + |
| 18 | + if (status != 0) { |
| 19 | + logger.error(`Command failed: ${command} ${args.map(x => JSON.stringify(x)).join(', ')}`); |
| 20 | + if (error) { |
| 21 | + logger.error('Error: ' + (error ? error.message : 'undefined')); |
| 22 | + } else { |
| 23 | + logger.error(`STDERR:\n${stderr}`); |
| 24 | + } |
| 25 | + throw error; |
| 26 | + } else { |
| 27 | + return stdout.toString(); |
| 28 | + } |
19 | 29 | } |
20 | 30 |
|
21 | 31 |
|
22 | | -export default function (_: {}, logger: logging.Logger) { |
| 32 | +export default function (args: { tag?: string }, logger: logging.Logger) { |
23 | 33 | logger.info('Building...'); |
24 | 34 | build({}, logger.createChild('build')); |
25 | 35 |
|
26 | | - return new Promise<void>((resolve, reject) => { |
27 | | - const loadOptions = { progress: false, logstream: new NullStream() }; |
28 | | - npm.load(loadOptions, (err: Error | string) => err ? reject(err) : resolve()); |
29 | | - }) |
30 | | - .then(() => { |
31 | | - return Object.keys(packages).reduce((acc: Promise<void>, name: string) => { |
32 | | - const pkg = packages[name]; |
33 | | - if (pkg.packageJson['private']) { |
34 | | - logger.debug(`${name} (private)`); |
35 | | - |
36 | | - return acc; |
37 | | - } |
38 | | - |
39 | | - return acc |
40 | | - .then(() => new Promise<void>((resolve, reject) => { |
41 | | - logger.info(name); |
42 | | - process.chdir(pkg.dist); |
43 | | - npm.commands['publish']([], (err: Error) => { |
44 | | - if (err) { |
45 | | - reject(err); |
46 | | - } else { |
47 | | - resolve(); |
48 | | - } |
49 | | - }); |
50 | | - })) |
51 | | - .catch((err: Error) => { |
52 | | - logger.error(err.message); |
53 | | - }); |
54 | | - }, Promise.resolve()); |
55 | | - }) |
56 | | - .then(() => logger.info('done'), (err: Error) => logger.fatal(err.message)); |
| 36 | + return Object.keys(packages).reduce((acc: Promise<void>, name: string) => { |
| 37 | + const pkg = packages[name]; |
| 38 | + if (pkg.packageJson['private']) { |
| 39 | + logger.debug(`${name} (private)`); |
| 40 | + |
| 41 | + return acc; |
| 42 | + } |
| 43 | + |
| 44 | + return acc |
| 45 | + .then(() => { |
| 46 | + logger.info(name); |
| 47 | + |
| 48 | + return _exec('npm', ['publish'].concat(args.tag ? ['--tag', args.tag] : []), { |
| 49 | + cwd: pkg.dist, |
| 50 | + }, logger); |
| 51 | + }) |
| 52 | + .then((stdout: string) => { |
| 53 | + logger.info(stdout); |
| 54 | + }); |
| 55 | + }, Promise.resolve()) |
| 56 | + .then(() => logger.info('done'), (err: Error) => logger.fatal(err.message)); |
57 | 57 | } |
0 commit comments