2 files changed, 47 insertions, 0 deletions
diff --git a/u/server/activity/health.ts b/u/server/activity/health.ts
new file mode 100644
index 0000000..bf1f52c
--- /dev/null
+++ b/u/server/activity/health.ts
@@ -0,0 +1,39 @@
+import {
+  Either,
+  getRequiredEnv,
+  getStdout,
+  type ITraceable,
+  LogLevel,
+  type Mapper,
+  TraceUtil,
+} from "@emprespresso/pengueno";
+
+type HealthCheckInput = "healthy?";
+type HealthCheckOutput = "healthy!";
+
+const HealthCheckActivity = <Trace>(
+  check: Mapper<
+    ITraceable<HealthCheckInput, Trace>,
+    Promise<Either<Error, HealthCheckOutput>>
+  >,
+) =>
+(req: ITraceable<Request, Trace>) =>
+  req.bimap(TraceUtil.withFunctionTrace(HealthCheckActivity))
+    .flatMap((r) => r.move(<HealthCheckInput> "healthy?"))
+    .map(check)
+    .map(TraceUtil.promiseify(({ item: health, trace }) => {
+      health.mapBoth((e) => {
+        trace.addTrace(LogLevel.ERROR).trace(`${e}`);
+        return new Response(
+          "oh no, i need to eat more vegetables (｡•́︿•̀｡)...\n",
+          { status: 500 },
+        );
+      }, (_healthy) => {
+        const msg = `think im healthy!! (✿˘◡˘) ready to do work~`;
+        trace.trace(msg);
+        return new Response(
+          msg + "\n",
+          { status: 200 },
+        );
+      });
+    }));
diff --git a/u/server/activity/mod.ts b/u/server/activity/mod.ts
new file mode 100644
index 0000000..6908c26
--- /dev/null
+++ b/u/server/activity/mod.ts
@@ -0,0 +1,8 @@
+import type { RequestFilter } from "@emprespresso/pengueno";
+
+export class r200 extends Response {
+  public override readonly status = 200;
+}
+
+export interface IActivity<Trace> extends RequestFilter<r200, Trace> {
+}