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.ts16
1 files changed, 9 insertions, 7 deletions
diff --git a/hooks/server/health.ts b/hooks/server/health.ts
index 41dfcb4..2f67aa4 100644
--- a/hooks/server/health.ts
+++ b/hooks/server/health.ts
@@ -1,23 +1,25 @@
import {
getRequiredEnv,
getStdout,
+ type HealthChecker,
type HealthCheckInput,
HealthCheckOutput,
type IEither,
type ITraceable,
+ type ServerTrace,
TraceUtil,
} from "@emprespresso/pengueno";
-export const healthCheck = <Trace>(
- input: ITraceable<HealthCheckInput, Trace>,
+export const healthCheck: HealthChecker = (
+ input: ITraceable<HealthCheckInput, ServerTrace>,
): Promise<IEither<Error, HealthCheckOutput>> =>
input.bimap(TraceUtil.withFunctionTrace(healthCheck))
.move(getRequiredEnv("LAMINAR_HOST"))
- // we need to test LAMINAR_HOST is propagated to getStdout for other procedures
- .map(({ item }) => item.moveRight(["laminarc", "show-jobs"]))
+ // ensure LAMINAR_HOST is propagated to getStdout for other procedures
+ .map((e) => e.get().moveRight(["laminarc", "show-jobs"]))
.map((i) =>
- i.item.mapRight(i.move.apply)
+ i.get().mapRight(i.move.apply)
.flatMapAsync(getStdout.apply)
- .then((gotJobs) => gotJobs.moveRight(HealthCheckOutput.YAASQUEEN))
+ .then((gotJobs) => gotJobs.moveRight(HealthCheckOutput.YAASSSLAYQUEEN))
)
- .item;
+ .get();