53 lines
1.6 KiB
JavaScript
53 lines
1.6 KiB
JavaScript
const {join, relative} = require('path');
|
|
const {PassThrough} = require('stream');
|
|
|
|
const {pipesink, processCode, spawnWith} = require('@flecks/core/src/server');
|
|
const chalk = require('chalk');
|
|
const {glob} = require('glob');
|
|
|
|
const concurrent = require('./concurrent');
|
|
|
|
const {
|
|
FLECKS_CORE_ROOT = process.cwd(),
|
|
FLECKS_CI_SHOW_SUCCESS,
|
|
} = process.env;
|
|
|
|
const args = process.argv.slice(2);
|
|
const {workspaces} = require(join(FLECKS_CORE_ROOT, 'package.json'));
|
|
|
|
const showSuccess = !!FLECKS_CI_SHOW_SUCCESS;
|
|
|
|
(async () => {
|
|
process.exitCode = await concurrent(
|
|
(await Promise.all(workspaces.map((path) => glob(join(FLECKS_CORE_ROOT, path))))).flat(),
|
|
async (cwd) => {
|
|
const child = spawnWith(
|
|
args,
|
|
{
|
|
cwd,
|
|
stdio: 'pipe',
|
|
},
|
|
);
|
|
const stdio = new PassThrough();
|
|
const buffer = pipesink(child.stderr.pipe(child.stdout.pipe(stdio)));
|
|
const code = await processCode(child);
|
|
if (!showSuccess && 0 === code) {
|
|
console.log(`@flecks/${
|
|
chalk.blue(relative(join(FLECKS_CORE_ROOT, 'packages'), cwd))
|
|
} ${chalk.green('passed')}\n`);
|
|
}
|
|
else {
|
|
console.log(
|
|
`::group::@flecks/${
|
|
chalk.blue(relative(join(FLECKS_CORE_ROOT, 'packages'), cwd))
|
|
} ${0 === code ? chalk.green('passed') : chalk.red('failed')}`,
|
|
);
|
|
process.stdout.write(await buffer);
|
|
console.log('::endgroup::\n');
|
|
}
|
|
return code;
|
|
},
|
|
);
|
|
console.log(0 === process.exitCode ? chalk.green('success') : chalk.red('failure'), '\n');
|
|
})();
|