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();