triggerdotdev · nicktrn · Sep 30, 2024 · Sep 26, 2024 · Sep 26, 2024 · Sep 26, 2024
diff --git a/apps/coordinator/package.json b/apps/coordinator/package.json
@@ -17,10 +17,10 @@
  "license": "MIT",
  "dependencies": {
    "@trigger.dev/core": "workspace:*",
-    "execa": "^8.0.1",
    "nanoid": "^5.0.6",
    "prom-client": "^15.1.0",
-    "socket.io": "4.7.4"
+    "socket.io": "4.7.4",
+    "tinyexec": "^0.3.0"
  },
  "devDependencies": {
    "@types/node": "^18",

diff --git a/apps/coordinator/src/chaosMonkey.ts b/apps/coordinator/src/chaosMonkey.ts
@@ -1,4 +1,3 @@
-import type { Execa$ } from "execa";
 import { setTimeout as timeout } from "node:timers/promises";

 class ChaosMonkeyError extends Error {
@@ -35,11 +34,9 @@ export class ChaosMonkey {
  }

  async call({
-    $,
    throwErrors = !this.disableErrors,
    addDelays = !this.disableDelays,
  }: {
-    $?: Execa$<string>;
    throwErrors?: boolean;
    addDelays?: boolean;
  } = {}) {
@@ -60,23 +57,15 @@ export class ChaosMonkey {
      chaosEvents.push(async () => {
        console.log("🍌 Chaos monkey: Add delay");

-        if ($) {
-          await $`sleep ${this.delayInSeconds}`;
-        } else {
-          await timeout(this.delayInSeconds * 1000);
-        }
+        await timeout(this.delayInSeconds * 1000);
      });
    }

    if (throwErrors) {
      chaosEvents.push(async () => {
        console.log("🍌 Chaos monkey: Throw error");

-        if ($) {
-          await $`false`;
-        } else {
-          throw new ChaosMonkey.Error("🍌 Chaos monkey: Throw error");
-        }
+        throw new ChaosMonkey.Error("🍌 Chaos monkey: Throw error");
      });
    }