import {
  getRequiredEnv,
  getStdout,
  type HealthChecker,
  type HealthCheckInput,
  HealthCheckOutput,
  type IEither,
  type ITraceable,
  type ServerTrace,
  TraceUtil,
} from "@emprespresso/pengueno";

export const healthCheck: HealthChecker = (
  input: ITraceable<HealthCheckInput, ServerTrace>,
): Promise<IEither<Error, HealthCheckOutput>> =>
  input
    .bimap(TraceUtil.withFunctionTrace(healthCheck))
    .move(getRequiredEnv("LAMINAR_HOST"))
    // ensure LAMINAR_HOST is propagated to getStdout for other procedures
    .map((tEitherEnv) =>
      tEitherEnv
        .get()
        .flatMapAsync((_hasEnv) =>
          getStdout(tEitherEnv.move(["laminarc", "show-jobs"])),
        ),
    )
    .map(
      TraceUtil.promiseify((stdout) =>
        stdout.get().moveRight(HealthCheckOutput.YAASSSLAYQUEEN),
      ),
    )
    .get();