Gulpfile.js

'use strict';

const gulp      = require('gulp');
const glob      = require('glob');
const gutil     = require('gulp-util');
const merge     = require('merge2');
const {argv}    = require('yargs');
const {spawn}   = require('child_process');
const gsequence = require('gulp-sequence');
const mkdirp    = require("mkdirp");
const {join, dirname}    = require('path');
const {writeFileSync} = require('fs');
const {keys, intersection} = require('lodash');

gulp.task('default', ['build']);

const PACKAGE_DIRS         = [
  ...glob.sync('./packages/*')
];

const PACKAGE_NAMES = PACKAGE_DIRS.map(dir => dir.split('/').pop());

const NODE_MODULES_DIR     = join(__dirname, 'node_modules');
const NODE_MODULES_BIN_DIR = join(NODE_MODULES_DIR, '.bin');
const WATCH                = argv.watch != null;
const GREP                 = argv.grep;

const gulpSpawn = (command, args, options) => {
  gutil.log([command, ...args, options.cwd].join(' '));
  const proc = spawn(command, args, options);

  proc.stdout.setEncoding('utf8');
  proc.stderr.setEncoding('utf8');

  proc.stdout.on('data', data => {
    gutil.log(data.trim());
  });

  proc.stderr.on('data', data => {
    gutil.log(gutil.colors.red(data.trim()));
    gutil.beep();
  });

  return proc.stdout;
};

// extraArgs(WATCH, watchArgs, GREP, grepArgs)
const extraArgs = function() {
  let extra = [];
  for (let i = 0; i < arguments.length; i += 2) {
    const flag  = arguments[i];
    const arg   = arguments[i + 1];
    if (flag) extra.push(...[].concat((typeof arg === 'function' ? arg() : arg)));
  }

  return extra.length ? ['--', ...extra] : [];
};

gulp.task('build', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('npm', ['run', 'build', ...(WATCH ? ['--', '--watch'] : [])], { cwd: dir })
  )));
});

gulp.task('build:docs', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('npm', ['run', 'build:docs', ...(WATCH ? ['--', '--watch'] : [])], { cwd: dir })
  )));
});

gulp.task('clean', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('npm', ['run', 'clean'], { cwd: dir })
  )));
});

gulp.task('test', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('npm', ['test', ...extraArgs(WATCH, '--watch', GREP, ['--grep', GREP])], { cwd: dir })
  )));
});

gulp.task('yarn:link', gsequence('yarn:link:criss', 'yarn:link:cross'));

/**
 * Link packages globally
 */

gulp.task('yarn:link:criss', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('yarn', ['link'], { cwd: dir })
  )));
});

/**
 * Link package dependencies
 */

gulp.task('yarn:link:cross', () => {
  return merge(
    PACKAGE_DIRS.map(dir => {
      const pkg = require(join(__dirname, dir, 'package.json'));
      return merge(intersection(keys(Object.assign({}, pkg.dependencies || {}, pkg.devDependencies || {})), PACKAGE_NAMES).map((dep) => {
        return gulpSpawn('yarn', ['link', dep], { cwd: dir });
      }));
    })
  );
});

gulp.task('npm:patch', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('npm', ['version', 'patch'], { cwd: dir })
  )));
});

gulp.task('npm:publish', () => {
  return merge(PACKAGE_DIRS.map((dir) => (
    gulpSpawn('npm', ['publish'], { cwd: dir })
  )));
});