feat: add kube diff and kube dryrun

anduintransaction · Nov 23, 2023 · a27b241 · a27b241
1 parent e3e7d8f
commit a27b241
Show file tree

Hide file tree

Showing 2 changed files with 41 additions and 8 deletions.
diff --git a/js/package.json b/js/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@anduintransaction/rivendell",
-  "version": "0.4.2",
+  "version": "0.4.3",
   "repository": {
     "type": "git",
     "url": "git+https://github.com/anduintransaction/rivendell.git"

diff --git a/js/src/runner.ts b/js/src/runner.ts
@@ -52,20 +52,17 @@ export class NoopRunner extends Runner {
 
 export class KubeRunner extends Runner {
   kubeCtx: string;
-  dryRun: boolean;
   namespace: string;
 
   static KUBECTL_BIN = "kubectl";
 
   constructor(
     kubeCtx: string = "",
     namespace: string = "default",
-    dryRun: boolean = false,
   ) {
     super();
     this.kubeCtx = kubeCtx;
     this.namespace = namespace;
-    this.dryRun = dryRun;
   }
 
   commonArgs() {
@@ -124,8 +121,6 @@ export class KubeRunner extends Runner {
   }
 
   async wait(w: WaitStep) {
-    if (this.dryRun) return;
-
     switch (w.wait.kind.toLowerCase()) {
       case "job": {
         await this.waitForJob(w.wait.name, w.wait.timeout);
@@ -162,10 +157,48 @@ export class KubeRunner extends Runner {
 
     const args = this.commonArgs();
     args.push("apply", "-f", "-");
-    if (this.dryRun) {
-      args.push("--dry-run=server");
+    const manifest = yaml.stringify(step.object);
+    execFileSync(KubeRunner.KUBECTL_BIN, args, {
+      input: manifest,
+      stdio: ["pipe", "inherit", "inherit"],
+    });
+  }
+}
+
+export class KubeDryrunRunner extends KubeRunner {
+  override async wait(_: WaitStep): Promise<void> {
+    return Promise.resolve();
+  }
+
+  override async deploy(step: DeployStep) {
+    if (step.object.kind.toLowerCase() === "job") {
+      // skip
+      return;
     }
 
+    const args = this.commonArgs();
+    args.push("apply", "--dry-run=server", "-f", "-");
+    const manifest = yaml.stringify(step.object);
+    execFileSync(KubeRunner.KUBECTL_BIN, args, {
+      input: manifest,
+      stdio: ["pipe", "inherit", "inherit"],
+    });
+  }
+}
+
+export class KubeDiffRunner extends KubeRunner {
+  override async wait(_: WaitStep): Promise<void> {
+    return Promise.resolve();
+  }
+
+  override async deploy(step: DeployStep) {
+    if (step.object.kind.toLowerCase() === "job") {
+      // skip
+      return;
+    }
+
+    const args = this.commonArgs();
+    args.push("diff", "-f", "-");
     const manifest = yaml.stringify(step.object);
     execFileSync(KubeRunner.KUBECTL_BIN, args, {
       input: manifest,