Merge pull request #4 from fluent-ci-templates/feat/run-specific-jobs

feat: allow running specific jobs from a pipeline

example/.fluentci/src/dagger/pipeline.ts

@@ -1,10 +1,28 @@
 import Client, { connect } from "@dagger.io/dagger";
-import { assembleDebug, debugTests, lintDebug } from "./jobs.ts";
+import * as jobs from "./jobs.ts";
 
-export default function pipeline(src = ".") {
+const { assembleDebug, debugTests, lintDebug } = jobs;
+
+export default function pipeline(src = ".", args: string[] = []) {
   connect(async (client: Client) => {
+    if (args.length > 0) {
+      await runSpecificJobs(client, args);
+      return;
+    }
+
     await lintDebug(client, src);
     await debugTests(client, src);
     await assembleDebug(client, src);
   });
 }
+
+async function runSpecificJobs(client: Client, args: string[]) {
+  for (const name of args) {
+    // deno-lint-ignore no-explicit-any
+    const job = (jobs as any)[name];
+    if (!job) {
+      throw new Error(`Job ${name} not found`);
+    }
+    await job(client);
+  }
+}

example/.fluentci/src/dagger/runner.ts

@@ -1,3 +1,3 @@
 import pipeline from "./pipeline.ts";
 
-pipeline();
+pipeline(".", Deno.args);

src/dagger/pipeline.ts

@@ -1,10 +1,28 @@
 import Client, { connect } from "@dagger.io/dagger";
-import { assembleDebug, debugTests, lintDebug } from "./jobs.ts";
+import * as jobs from "./jobs.ts";
 
-export default function pipeline(src = ".") {
+const { assembleDebug, debugTests, lintDebug } = jobs;
+
+export default function pipeline(src = ".", args: string[] = []) {
   connect(async (client: Client) => {
+    if (args.length > 0) {
+      await runSpecificJobs(client, args);
+      return;
+    }
+
     await lintDebug(client, src);
     await debugTests(client, src);
     await assembleDebug(client, src);
   });
 }
+
+async function runSpecificJobs(client: Client, args: string[]) {
+  for (const name of args) {
+    // deno-lint-ignore no-explicit-any
+    const job = (jobs as any)[name];
+    if (!job) {
+      throw new Error(`Job ${name} not found`);
+    }
+    await job(client);
+  }
+}

src/dagger/runner.ts

@@ -1,3 +1,3 @@
 import pipeline from "./pipeline.ts";
 
-pipeline();
+pipeline(".", Deno.args);