3 files changed, 0 insertions, 102 deletions
diff --git a/worker/executor/job.ts b/worker/executor/job.ts
deleted file mode 100644
index ca7feed..0000000
--- a/worker/executor/job.ts
+++ /dev/null
@@ -1,42 +0,0 @@
-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();
diff --git a/worker/executor/mod.ts b/worker/executor/mod.ts
deleted file mode 100644
index 944ab7d..0000000
--- a/worker/executor/mod.ts
+++ /dev/null
@@ -1,2 +0,0 @@
-export * from "./job.ts";
-export * from "./pipeline.ts";
diff --git a/worker/executor/pipeline.ts b/worker/executor/pipeline.ts
deleted file mode 100644
index c8423b1..0000000
--- a/worker/executor/pipeline.ts
+++ /dev/null
@@ -1,58 +0,0 @@
-import {
-  Either,
-  type IEither,
-  type ITraceable,
-  type LogMetricTraceSupplier,
-  Metric,
-  TraceUtil,
-} from "@emprespresso/pengueno";
-import type { Job, JobArgT, Pipeline } from "@emprespresso/ci-model";
-import { executeJob } from "./mod.ts";
-
-const pipelinesMetric = Metric.fromName("pipelines");
-export const executePipeline = (
-  tPipeline: ITraceable<Pipeline, LogMetricTraceSupplier>,
-  baseEnv?: JobArgT,
-): Promise<IEither<Error, void>> =>
-  tPipeline
-    .bimap(TraceUtil.withFunctionTrace(executePipeline))
-    .bimap(TraceUtil.withMetricTrace(pipelinesMetric))
-    .map(async (tJobs): Promise<IEither<Error, void>> => {
-      for (const [i, serialStage] of tJobs.get().serialJobs.entries()) {
-        tJobs.trace.trace(
-          `executing stage ${i}. do your best little stage :>\n${serialStage}`,
-        );
-        const jobResults = await Promise.all(
-          serialStage.parallelJobs.map((job) =>
-            tJobs
-              .bimap((_) => [job, `stage ${i}`])
-              .map(
-                (tJob) =>
-                  <Job>{
-                    ...tJob.get(),
-                    arguments: { ...baseEnv, ...tJob.get().arguments },
-                  },
-              )
-              .map(executeJob)
-              .peek(
-                TraceUtil.promiseify((tEitherJobOutput) =>
-                  tEitherJobOutput
-                    .get()
-                    .mapRight((stdout) =>
-                      tEitherJobOutput.trace.addTrace("STDOUT").trace(stdout),
-                    ),
-                ),
-              )
-              .get(),
-          ),
-        );
-        const failures = jobResults.filter((e) => e.fold((err) => !!err));
-        if (failures.length > 0) {
-          tJobs.trace.trace(pipelinesMetric.failure);
-          return Either.left(new Error(failures.toString()));
-        }
-      }
-      tJobs.trace.trace(pipelinesMetric.success);
-      return Either.right(undefined);
-    })
-    .get();