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

feat: allow running specific jobs from a pipeline

main.ts

@@ -7,7 +7,7 @@ import upgrade from "./upgrade.ts";
 export async function main() {
   await new Command()
     .name("fluentci")
-    .version("0.3.1")
+    .version("0.3.2")
     .description(
       `
       .
@@ -20,10 +20,10 @@ export async function main() {
              
       `
     )
-    .arguments("<pipeline:string>")
+    .arguments("<pipeline:string> [jobs...:string]")
     .option("-r, --reload", "Reload pipeline source cache")
-    .action(function (options, pipeline) {
-      run(pipeline, options.reload);
+    .action(function (options, pipeline, ...jobs: [string, ...Array<string>]) {
+      run(pipeline, jobs, options.reload);
     })
     .command("init", "Initialize a new pipeline")
     .arguments("[pipeline-name:string]")

run.ts

@@ -2,7 +2,11 @@ import { green } from "https://deno.land/[email protected]/fmt/colors.ts";
 
 const BASE_URL = "https://api.fluentci.io/v1";
 
-async function run(pipeline: string, reload = false) {
+async function run(
+  pipeline: string,
+  jobs: [string, ...Array<string>],
+  reload = false
+) {
   if (pipeline === ".") {
     try {
       // verify if .fluentci directory exists
@@ -18,12 +22,16 @@ async function run(pipeline: string, reload = false) {
       args: [
         "run",
         "-A",
-        `--import-map=.fluentci/import_map.json`,
-        `.fluentci/src/dagger/runner.ts`,
+        "--import-map=.fluentci/import_map.json",
+        ".fluentci/src/dagger/runner.ts",
+        ...jobs,
       ],
     });
 
-    await command.output();
+    const { stderr, success } = await command.output();
+    if (!success) {
+      console.log(new TextDecoder().decode(stderr));
+    }
     return;
   }
 
@@ -41,6 +49,7 @@ async function run(pipeline: string, reload = false) {
   let denoModule = [
     `--import-map=https://deno.land/x/${pipeline}/import_map.json`,
     `https://deno.land/x/${pipeline}/src/dagger/runner.ts`,
+    ...jobs,
   ];
 
   if (reload) {