feat(tasks): adds task runner function run

src/helpers/create-context.ts

@@ -0,0 +1,23 @@
+import { Context } from '../definitions';
+import { into } from 'pipettes';
+
+const cancellation = new Promise<void>(() => undefined);
+
+export function createContext(context?: Partial<Context>): Context {
+  return into(
+    context || {},
+    (context: Partial<Context>): Context => ({
+      cwd: context.cwd || process.cwd(),
+      env: context.env || { ...process.env },
+      args: context.args || [],
+      stdio: context.stdio || [process.stdin, process.stdout, process.stderr],
+      level: context.level || 'info',
+      route: context.route || [],
+      prefix: context.prefix || 'none',
+      cancellation: context.cancellation
+        ? context.cancellation.then(() => undefined)
+        : cancellation
+    }),
+    (context) => Object.freeze(context)
+  );
+}

src/tasks/consume/index.ts

@@ -0,0 +1 @@
+export * from './run';

src/tasks/consume/run.ts

@@ -0,0 +1,24 @@
+import { Task, Context } from '../../definitions';
+import { createContext } from '../../helpers/create-context';
+import { isCancelled } from '../../utils';
+import { log } from '../create/log';
+import { into } from 'pipettes';
+
+const noop = (): void => undefined;
+
+export async function run(
+  task: Task,
+  context?: Partial<Context>
+): Promise<void> {
+  const ctx = createContext(context);
+  const safe = { ...ctx, cancellation: ctx.cancellation.catch(noop) };
+
+  try {
+    if (await isCancelled(safe)) return await ctx.cancellation;
+    await task(safe);
+    if (await isCancelled(safe)) return await ctx.cancellation;
+  } catch (err) {
+    into(safe, log('error', err));
+    throw err;
+  }
+}

src/tasks/index.ts

@@ -1 +1,2 @@
+export * from './consume';
 export * from './create';