feat(tasks,bin): add fail option to watch task and command

rafamel · Apr 7, 2021 · a329ad5 · a329ad5
1 parent 8463a82
commit a329ad5
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/src/cli/commands/watch.ts b/src/cli/commands/watch.ts
@@ -28,6 +28,7 @@ export async function watch(params: CLI.Extension.Params): Promise<Task> {
     Options:
       -g, --glob              Parse globs in paths
       -p, --prime             Runs the task once when ready to wait for changes
+      -f, --fail              Finalizes the watch effort if a given task fails
       -c, --clear             Clear stdout before tasks execution
       -i, --include <value>   Paths to include
       -e, --exclude <value>   Paths to exclude
@@ -47,9 +48,10 @@ export async function watch(params: CLI.Extension.Params): Promise<Task> {
   const types = {
     '--glob': Boolean,
     '--prime': Boolean,
+    '--fail': Boolean,
+    '--clear': Boolean,
     '--include': [String] as [StringConstructor],
     '--exclude': [String] as [StringConstructor],
-    '--clear': Boolean,
     '--parallel': Boolean,
     '--symlinks': Boolean,
     '--debounce': Number,
@@ -90,6 +92,7 @@ export async function watch(params: CLI.Extension.Params): Promise<Task> {
       {
         glob: cmd['--glob'],
         prime: cmd['--prime'],
+        fail: cmd['--fail'],
         clear: cmd['--clear'],
         include: cmd['--include'],
         exclude: cmd['--exclude'],

diff --git a/src/tasks/filesystem/watch.ts b/src/tasks/filesystem/watch.ts
@@ -1,4 +1,5 @@
 import { Task, Context } from '../../definitions';
+import { stringifyError } from '../../helpers/stringify';
 import { run } from '../../utils/run';
 import { log } from '../stdio/log';
 import { clear } from '../stdio/clear';
@@ -14,6 +15,8 @@ export interface WatchOptions {
   glob?: boolean;
   /** Runs the task once when ready to wait for changes */
   prime?: boolean;
+  /** Finalizes the watch effort if a given task fails */
+  fail?: boolean;
   /** Clear stdout before tasks execution */
   clear?: boolean;
   /** Paths to include */
@@ -43,6 +46,7 @@ export function watch(options: WatchOptions | Empty, task: Task): Task.Async {
       {
         glob: false,
         prime: false,
+        fail: false,
         clear: false,
         include: ['./'],
         exclude: ['node_modules'],
@@ -107,7 +111,14 @@ export function watch(options: WatchOptions | Empty, task: Task): Task.Async {
               })
             });
           })
-          .catch(onError);
+          .catch((err) => {
+            return opts.fail
+              ? onError(err)
+              : run(
+                  series(log('trace', err), log('warn', stringifyError(err))),
+                  ctx
+                );
+          });
       },
       opts.debounce >= 0 ? opts.debounce : 0
     );