summaryrefslogtreecommitdiff
path: root/hooks/server/health.ts
diff options
context:
space:
mode:
Diffstat (limited to 'hooks/server/health.ts')
-rw-r--r--hooks/server/health.ts25
1 files changed, 25 insertions, 0 deletions
diff --git a/hooks/server/health.ts b/hooks/server/health.ts
new file mode 100644
index 0000000..2f67aa4
--- /dev/null
+++ b/hooks/server/health.ts
@@ -0,0 +1,25 @@
+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((e) => e.get().moveRight(["laminarc", "show-jobs"]))
+ .map((i) =>
+ i.get().mapRight(i.move.apply)
+ .flatMapAsync(getStdout.apply)
+ .then((gotJobs) => gotJobs.moveRight(HealthCheckOutput.YAASSSLAYQUEEN))
+ )
+ .get();