From d51c9d74857aca3c2f172609297266968bc7f809 Mon Sep 17 00:00:00 2001
From: Elizabeth Alexander Hunt <me@liz.coffee>
Date: Mon, 12 May 2025 09:40:12 -0700
Subject: The big refactor TM

---
 worker/executor/job.ts | 42 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 worker/executor/job.ts

(limited to 'worker/executor/job.ts')

diff --git a/worker/executor/job.ts b/worker/executor/job.ts
new file mode 100644
index 0000000..76f0e0c
--- /dev/null
+++ b/worker/executor/job.ts
@@ -0,0 +1,42 @@
+import {
+  getStdout,
+  type ITraceable,
+  LogLevel,
+  type LogMetricTraceSupplier,
+  memoize,
+  Metric,
+  TraceUtil,
+  validateExecutionEntries,
+} from "@emprespresso/pengueno";
+import type { Job } from "@emprespresso/ci-model";
+
+const jobTypeMetric = memoize((type: string) => Metric.fromName(`run.${type}`));
+export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) =>
+  tJob.bimap(TraceUtil.withMetricTrace(jobTypeMetric(tJob.get().type)))
+    .peek((tJob) =>
+      tJob.trace.trace(
+        `let's do this little job ok!! ${tJob.get()}`,
+      )
+    )
+    .map((tJob) =>
+      validateExecutionEntries(tJob.get().arguments)
+        .mapLeft((badEntries) => {
+          tJob.trace.addTrace(LogLevel.ERROR).trace(
+            badEntries.toString(),
+          );
+          return new Error("invalid job arguments");
+        })
+        .flatMapAsync((args) =>
+          getStdout(tJob.move(tJob.get().type), { env: args })
+        )
+    )
+    .peek(
+      TraceUtil.promiseify((q) =>
+        q.trace.trace(
+          q.get().fold((err, _val) =>
+            jobTypeMetric(tJob.get().type)[err ? "failure" : "success"]
+          ),
+        )
+      ),
+    )
+    .get();
-- 
cgit v1.2.3-70-g09d2