diff options
Diffstat (limited to 'server')
-rw-r--r-- | server/health.ts | 15 | ||||
-rw-r--r-- | server/mod.ts | 2 |
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)); }; |