diff options
author | Elizabeth <lizhunt@amazon.com> | 2025-05-28 15:05:38 -0700 |
---|---|---|
committer | Elizabeth <lizhunt@amazon.com> | 2025-05-28 15:05:38 -0700 |
commit | 3005cc83e605fb89b079cf0e6fd0ec95cd27b30e (patch) | |
tree | 992c5933f2ec4a75e32469ddd772c61dbcb2e2fd /u/server/activity/health.ts | |
parent | e3cf820b07e282221502cf2f116c9780b7375e0e (diff) | |
download | ci-3005cc83e605fb89b079cf0e6fd0ec95cd27b30e.tar.gz ci-3005cc83e605fb89b079cf0e6fd0ec95cd27b30e.zip |
Run prettier, add zed settings
Diffstat (limited to 'u/server/activity/health.ts')
-rw-r--r-- | u/server/activity/health.ts | 58 |
1 files changed, 30 insertions, 28 deletions
diff --git a/u/server/activity/health.ts b/u/server/activity/health.ts index 0f54a99..83be399 100644 --- a/u/server/activity/health.ts +++ b/u/server/activity/health.ts @@ -23,45 +23,47 @@ export interface IHealthCheckActivity { } const healthCheckMetric = Metric.fromName("Health"); -export interface HealthChecker extends - Mapper< +export interface HealthChecker + extends Mapper< ITraceable<HealthCheckInput, ServerTrace>, Promise<IEither<Error, HealthCheckOutput>> > {} export class HealthCheckActivityImpl implements IHealthCheckActivity { - constructor( - private readonly check: HealthChecker, - ) {} + constructor(private readonly check: HealthChecker) {} public checkHealth(req: ITraceable<PenguenoRequest, ServerTrace>) { return req .bimap(TraceUtil.withFunctionTrace(this.checkHealth)) .bimap(TraceUtil.withMetricTrace(healthCheckMetric)) .flatMap((r) => r.move(HealthCheckInput.CHECK).map(this.check)) - .peek(TraceUtil.promiseify((h) => - h.get().fold((err) => { - if (err) { - h.trace.trace(healthCheckMetric.failure); - h.trace.addTrace(LogLevel.ERROR).trace(`${err}`); - return; - } - h.trace.trace(healthCheckMetric.success); - }) - )) - .map(TraceUtil.promiseify((h) => - h.get() - .mapBoth( - () => "oh no, i need to eat more vegetables (。•́︿•̀。)...", - () => "think im healthy!! (✿˘◡˘) ready to do work~", - ) - .fold((errMsg, okMsg) => - new JsonResponse( - req, - errMsg ?? okMsg, - { status: errMsg ? 500 : 200 }, + .peek( + TraceUtil.promiseify((h) => + h.get().fold((err) => { + if (err) { + h.trace.trace(healthCheckMetric.failure); + h.trace.addTrace(LogLevel.ERROR).trace(`${err}`); + return; + } + h.trace.trace(healthCheckMetric.success); + }), + ), + ) + .map( + TraceUtil.promiseify((h) => + h + .get() + .mapBoth( + () => "oh no, i need to eat more vegetables (。•́︿•̀。)...", + () => "think im healthy!! (✿˘◡˘) ready to do work~", ) - ) - )) + .fold( + (errMsg, okMsg) => + new JsonResponse(req, errMsg ?? okMsg, { + status: errMsg ? 500 : 200, + }), + ), + ), + ) .get(); } } |