summaryrefslogtreecommitdiff
path: root/u/server/activity/health.ts
diff options
context:
space:
mode:
Diffstat (limited to 'u/server/activity/health.ts')
-rw-r--r--u/server/activity/health.ts108
1 files changed, 52 insertions, 56 deletions
diff --git a/u/server/activity/health.ts b/u/server/activity/health.ts
index 95dfa97..b3ae559 100644
--- a/u/server/activity/health.ts
+++ b/u/server/activity/health.ts
@@ -1,71 +1,67 @@
import {
- type IActivity,
- type IEither,
- type ITraceable,
- JsonResponse,
- LogLevel,
- type Mapper,
- Metric,
- type PenguenoRequest,
- type ServerTrace,
- TraceUtil,
-} from "@emprespresso/pengueno";
+ type IActivity,
+ type IEither,
+ IMetric,
+ type ITraceable,
+ JsonResponse,
+ LogLevel,
+ type Mapper,
+ Metric,
+ type PenguenoRequest,
+ type ServerTrace,
+ TraceUtil,
+} from '@emprespresso/pengueno';
export enum HealthCheckInput {
- CHECK,
+ CHECK,
}
export enum HealthCheckOutput {
- YAASSSLAYQUEEN,
+ YAASSSLAYQUEEN,
}
export interface IHealthCheckActivity {
- checkHealth: IActivity;
+ checkHealth: IActivity;
}
-const healthCheckMetric = Metric.fromName("Health");
+const healthCheckMetric: IMetric = Metric.fromName('Health');
export interface HealthChecker
- extends Mapper<
- ITraceable<HealthCheckInput, ServerTrace>,
- Promise<IEither<Error, HealthCheckOutput>>
- > {}
+ 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((input) => this.check(input)),
- )
- .peek(
- TraceUtil.promiseify((h) =>
- h.get().fold(({ isLeft, value }) => {
- if (!isLeft) {
- h.trace.trace(healthCheckMetric.success);
- return;
- }
- h.trace.trace(healthCheckMetric.failure);
- h.trace.addTrace(LogLevel.ERROR).trace(value);
- }),
- ),
- )
- .map(
- TraceUtil.promiseify((h) =>
- h
- .get()
- .mapBoth(
- () => "oh no, i need to eat more vegetables (。•́︿•̀。)...",
- () => "think im healthy!! (✿˘◡˘) ready to do work~",
+ public checkHealth(req: ITraceable<PenguenoRequest, ServerTrace>) {
+ return req
+ .bimap(TraceUtil.withFunctionTrace(this.checkHealth))
+ .bimap(TraceUtil.withMetricTrace(healthCheckMetric))
+ .flatMap((r) => r.move(HealthCheckInput.CHECK).map((input) => this.check(input)))
+ .peek(
+ TraceUtil.promiseify((h) =>
+ h.get().fold(({ isLeft, value }) => {
+ if (!isLeft) {
+ h.trace.trace(healthCheckMetric.success);
+ return;
+ }
+ h.trace.trace(healthCheckMetric.failure);
+ h.trace.addTrace(LogLevel.ERROR).trace(value);
+ }),
+ ),
)
- .fold(
- ({ isLeft, value: message }) =>
- new JsonResponse(req, message, {
- status: isLeft ? 500 : 200,
- }),
- ),
- ),
- )
- .get();
- }
+ .map(
+ TraceUtil.promiseify((h) =>
+ h
+ .get()
+ .mapBoth(
+ () => 'oh no, i need to eat more vegetables (。•́︿•̀。)...',
+ () => 'think im healthy!! (✿˘◡˘) ready to do work~',
+ )
+ .fold(
+ ({ isLeft, value: message }) =>
+ new JsonResponse(req, message, {
+ status: isLeft ? 500 : 200,
+ }),
+ ),
+ ),
+ )
+ .get();
+ }
}