summaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
Diffstat (limited to 'server')
-rw-r--r--server/health.ts15
-rw-r--r--server/mod.ts2
2 files changed, 12 insertions, 5 deletions
diff --git a/server/health.ts b/server/health.ts
index 8fbc69d..e69077b 100644
--- a/server/health.ts
+++ b/server/health.ts
@@ -17,9 +17,16 @@ export const healthCheck: HealthChecker = (
.bimap(TraceUtil.withFunctionTrace(healthCheck))
.move(getRequiredEnv("LAMINAR_HOST"))
// ensure LAMINAR_HOST is propagated to getStdout for other procedures
- .map((tEitherEnv) => tEitherEnv.get()
+ .map((tEitherEnv) =>
+ tEitherEnv
+ .get()
.flatMapAsync((_hasEnv) =>
- getStdout(tEitherEnv.move(["laminarc", "show-jobs"]))
- ))
- .map(TraceUtil.promiseify((stdout) => stdout.get().moveRight(HealthCheckOutput.YAASSSLAYQUEEN)))
+ getStdout(tEitherEnv.move(["laminarc", "show-jobs"])),
+ ),
+ )
+ .map(
+ TraceUtil.promiseify((stdout) =>
+ stdout.get().moveRight(HealthCheckOutput.YAASSSLAYQUEEN),
+ ),
+ )
.get();
diff --git a/server/mod.ts b/server/mod.ts
index 1fd4e99..02b307a 100644
--- a/server/mod.ts
+++ b/server/mod.ts
@@ -18,5 +18,5 @@ export const runServer = (
};
return Either.fromFailable<Error, Deno.HttpServer>(() =>
Deno.serve(serverConfig, (req) => server.serve(req)),
- ).flatMapAsync((server) => Either.fromFailableAsync(server.finished));
+ ).flatMapAsync((server) => Either.fromFailableAsync(() => server.finished));
};