feat(@angular-devkit/architect): add generic architect builders

Four builders were added;
- true, always succeed
- false, always fails
- concat, runs all targets or builders in succession
- allOf, runs all targets or builders in parallel

Author: hansl

packages/angular_devkit/architect/builders/all-of.ts

@@ -0,0 +1,59 @@
+/**
+ * @license
+ * Copyright Google Inc. All Rights Reserved.
+ *
+ * Use of this source code is governed by an MIT-style license that can be
+ * found in the LICENSE file at https://angular.io/license
+ */
+import { json } from '@angular-devkit/core';
+import { EMPTY, from, of } from 'rxjs';
+import { map, mergeMap } from 'rxjs/operators';
+import { BuilderOutput, BuilderRun, createBuilder } from '../src/index2';
+import { Schema as OperatorSchema } from './operator-schema';
+
+export default createBuilder<json.JsonObject & OperatorSchema>((options, context) => {
+  const allRuns: Promise<[number, BuilderRun]>[] = [];
+
+  context.reportProgress(0,
+    (options.targets ? options.targets.length : 0)
+    + (options.builders ? options.builders.length : 0),
+  );
+
+  if (options.targets) {
+    allRuns.push(...options.targets.map(({ target: targetStr, overrides }, i) => {
+      const [project, target, configuration] = targetStr.split(/:/g, 3);
+
+      return context.scheduleTarget({ project, target, configuration }, overrides || {})
+        .then(run => [i, run] as [number, BuilderRun]);
+    }));
+  }
+
+  if (options.builders) {
+    allRuns.push(...options.builders.map(({ builder, options }, i) => {
+      return context.scheduleBuilder(builder, options || {})
+        .then(run => [i, run] as [number, BuilderRun]);
+    }));
+  }
+
+  const allResults: (BuilderOutput | null)[] = allRuns.map(() => null);
+  let n = 0;
+  context.reportProgress(n++, allRuns.length);
+
+  return from(allRuns).pipe(
+    mergeMap(runPromise => from(runPromise)),
+    mergeMap(([i, run]: [number, BuilderRun]) => run.output.pipe(map(output => [i, output]))),
+    mergeMap<[number, BuilderOutput], BuilderOutput>(([i, output]) => {
+      allResults[i] = output;
+      context.reportProgress(n++, allRuns.length);
+
+      if (allResults.some(x => x === null)) {
+        // Some builders aren't done running yet.
+        return EMPTY;
+      } else {
+        return of({
+          success: allResults.every(x => x ? x.success : false),
+        });
+      }
+    }),
+  );
+});

packages/angular_devkit/architect/builders/builders.json

@@ -0,0 +1,25 @@
+{
+  "$schema": "../src/builders-schema.json",
+  "builders": {
+    "true": {
+      "implementation": "./true",
+      "schema": "./noop-schema.json",
+      "description": "Always succeed."
+    },
+    "false": {
+      "implementation": "./false",
+      "schema": "./noop-schema.json",
+      "description": "Always fails."
+    },
+    "allOf": {
+      "implementation": "./all-of",
+      "schema": "./operator-schema.json",
+      "description": "A builder that executes many builders in parallel, and succeed if both succeeds."
+    },
+    "concat": {
+      "implementation": "./concat",
+      "schema": "./operator-schema.json",
+      "description": "A builder that executes many builders one after the other, and stops when one fail. It will succeed if all builders succeeds (and return the last output)"
+    }
+  }
+}

packages/angular_devkit/architect/builders/concat.ts

@@ -0,0 +1,56 @@
+/**
+ * @license
+ * Copyright Google Inc. All Rights Reserved.
+ *
+ * Use of this source code is governed by an MIT-style license that can be
+ * found in the LICENSE file at https://angular.io/license
+ */
+import { json } from '@angular-devkit/core';
+import { from, of } from 'rxjs';
+import { concatMap, first, last, map, switchMap } from 'rxjs/operators';
+import { BuilderOutput, BuilderRun, createBuilder } from '../src/index2';
+import { Schema as OperatorSchema } from './operator-schema';
+
+export default createBuilder<json.JsonObject & OperatorSchema>((options, context) => {
+  const allRuns: (() => Promise<BuilderRun>)[] = [];
+
+  context.reportProgress(0,
+    (options.targets ? options.targets.length : 0)
+    + (options.builders ? options.builders.length : 0),
+  );
+
+  if (options.targets) {
+    allRuns.push(...options.targets.map(({ target: targetStr, overrides }) => {
+      const [project, target, configuration] = targetStr.split(/:/g, 3);
+
+      return () => context.scheduleTarget({ project, target, configuration }, overrides || {});
+    }));
+  }
+
+  if (options.builders) {
+    allRuns.push(...options.builders.map(({ builder, options }) => {
+      return () => context.scheduleBuilder(builder, options || {});
+    }));
+  }
+
+  let stop: BuilderOutput | null = null;
+  let i = 0;
+  context.reportProgress(i++, allRuns.length);
+
+  return from(allRuns).pipe(
+    concatMap(fn => stop ? of(null) : from(fn()).pipe(
+      switchMap(run => run === null ? of(null) : run.output.pipe(first())),
+    )),
+    map(output => {
+      context.reportProgress(i++, allRuns.length);
+      if (output === null || stop !== null) {
+        return stop || { success: false };
+      } else if (output.success === false) {
+        return stop = output;
+      } else {
+        return output;
+      }
+    }),
+    last(),
+  );
+});

packages/angular_devkit/architect/builders/false.ts

@@ -0,0 +1,14 @@
+/**
+ * @license
+ * Copyright Google Inc. All Rights Reserved.
+ *
+ * Use of this source code is governed by an MIT-style license that can be
+ * found in the LICENSE file at https://angular.io/license
+ */
+import { of } from 'rxjs';
+import { createBuilder } from '../src/index2';
+
+export default createBuilder(() => of({
+  success: false,
+  error: 'False builder always errors.',
+}));

packages/angular_devkit/architect/builders/noop-schema.json

@@ -0,0 +1,4 @@
+{
+  "$schema": "http://json-schema.org/schema",
+  "type": "object"
+}

packages/angular_devkit/architect/builders/operator-schema.json

@@ -0,0 +1,45 @@
+{
+  "$schema": "http://json-schema.org/schema",
+  "description": "All input types of builders that perform operations on one or multiple sub-builders.",
+  "type": "object",
+  "properties": {
+    "builders": {
+      "type": "array",
+      "items": {
+        "type": "object",
+        "properties": {
+          "builder": {
+            "type": "string",
+            "pattern": ".*:.*"
+          },
+          "options": {
+            "type": "object"
+          }
+        },
+        "required": [
+          "builder"
+        ]
+      },
+      "minItems": 1
+    },
+    "targets": {
+      "type": "array",
+      "items": {
+        "type": "object",
+        "properties": {
+          "target": {
+            "type": "string",
+            "pattern": ".*:.*"
+          },
+          "overrides": {
+            "type": "object"
+          }
+        },
+        "required": [
+          "target"
+        ]
+      },
+      "minItems": 1
+    }
+  }
+}

packages/angular_devkit/architect/builders/true.ts

@@ -0,0 +1,11 @@
+/**
+ * @license
+ * Copyright Google Inc. All Rights Reserved.
+ *
+ * Use of this source code is governed by an MIT-style license that can be
+ * found in the LICENSE file at https://angular.io/license
+ */
+import { of } from 'rxjs';
+import { createBuilder } from '../src/index2';
+
+export default createBuilder(() => of({ success: true }));

packages/angular_devkit/architect/package.json

@@ -7,5 +7,6 @@
   "dependencies": {
     "@angular-devkit/core": "0.0.0",
     "rxjs": "6.3.3"
-  }
-}
+  },
+  "builders": "./builders/builders.json"
+}