Merge pull request #32 from fluentci-io/fix/wasm-pipeline-args

fix bug on passing args to the wasm pipeline
fluentci-io · Apr 9, 2024 · 599e3d7 · 599e3d7
2 parents 22eebf2 + 182c01c
commit 599e3d7
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -80,7 +80,7 @@ fluentci # Run the pipeline
 fluentci --help
 
 Usage:   fluentci [pipeline] [jobs...]
-Version: 0.12.2  
+Version: 0.12.3  
 
 Description:
 

diff --git a/flake.nix b/flake.nix
@@ -25,7 +25,7 @@
 
         packages.default = pkgs.deno2nix.mkExecutable {
           pname = "fluentci";
-          version = "0.12.2";
+          version = "0.12.3";
 
           src = ./.;
           lockfile = "./deno.lock";

diff --git a/main.ts b/main.ts
@@ -40,16 +40,32 @@ export async function main() {
     .arguments("[pipeline:string] [jobs...:string]")
     .option("-r, --reload", "Reload pipeline source cache")
     .option("-w, --wasm", "Run pipeline as WebAssembly Module")
-    .option("-*, --* <args:string>", "Pass arguments to pipeline")
+    .option("-*, --* [args:string]", "Pass arguments to pipeline")
     .action(function (options, pipeline, ...jobs: [string, ...Array<string>]) {
+      if (options.wasm) {
+        Deno.args.findIndex((arg) => arg === pipeline);
+        const args = Deno.args.slice(
+          Deno.args.findIndex((arg) => arg === pipeline) + 1
+        );
+        run(pipeline || ".", args, options);
+        return;
+      }
       run(pipeline || ".", jobs, options);
     })
     .command("run", "Run a pipeline")
     .arguments("<pipeline:string> [jobs...:string]")
     .option("-r, --reload", "Reload pipeline source cache")
     .option("-w, --wasm", "Run pipeline as WebAssembly Module")
-    .option("-*, --* <args:string>", "Pass arguments to pipeline")
+    .option("-*, --* [args:string]", "Pass arguments to pipeline")
     .action(function (options, pipeline, ...jobs: [string, ...Array<string>]) {
+      if (options.wasm) {
+        Deno.args.findIndex((arg) => arg === pipeline);
+        const args = Deno.args.slice(
+          Deno.args.findIndex((arg) => arg === pipeline) + 1
+        );
+        run(pipeline, args, options);
+        return;
+      }
       run(pipeline, jobs, options);
     })
     .command("init", "Initialize a new pipeline")

diff --git a/src/consts.ts b/src/consts.ts
@@ -1,6 +1,6 @@
 import { dir } from "../deps.ts";
 
-export const VERSION = "0.12.2";
+export const VERSION = "0.12.3";
 
 export const BASE_URL = "https://api.fluentci.io/v1";