summaryrefslogtreecommitdiff
path: root/u/server/activity/health.ts
diff options
context:
space:
mode:
authorElizabeth <lizhunt@amazon.com>2025-05-28 15:05:38 -0700
committerElizabeth <lizhunt@amazon.com>2025-05-28 15:05:38 -0700
commit3005cc83e605fb89b079cf0e6fd0ec95cd27b30e (patch)
tree992c5933f2ec4a75e32469ddd772c61dbcb2e2fd /u/server/activity/health.ts
parente3cf820b07e282221502cf2f116c9780b7375e0e (diff)
downloadci-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.ts58
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();
}
}