diff options
author | Elizabeth Alexander Hunt <me@liz.coffee> | 2025-05-15 23:39:29 -0700 |
---|---|---|
committer | Elizabeth Alexander Hunt <me@liz.coffee> | 2025-05-15 23:40:00 -0700 |
commit | 1ab20482ab37d7962c8e69701163270e687df3ca (patch) | |
tree | f0aaac54f8c23269fdeb2bca6f22e296a9e0559f /u/server | |
parent | 3a3fb9c8ab0c798a278f76d40de216fa96f6e2c4 (diff) | |
download | ci-1ab20482ab37d7962c8e69701163270e687df3ca.tar.gz ci-1ab20482ab37d7962c8e69701163270e687df3ca.zip |
more snapshot
Diffstat (limited to 'u/server')
-rw-r--r-- | u/server/activity/health.ts | 18 | ||||
-rw-r--r-- | u/server/activity/mod.ts | 2 | ||||
-rw-r--r-- | u/server/filter/json.ts | 3 | ||||
-rw-r--r-- | u/server/filter/method.ts | 3 | ||||
-rw-r--r-- | u/server/mod.ts | 1 |
5 files changed, 17 insertions, 10 deletions
diff --git a/u/server/activity/health.ts b/u/server/activity/health.ts index bf1f52c..7ee6629 100644 --- a/u/server/activity/health.ts +++ b/u/server/activity/health.ts @@ -1,25 +1,27 @@ import { - Either, - getRequiredEnv, - getStdout, + type IEither, type ITraceable, LogLevel, type Mapper, TraceUtil, } from "@emprespresso/pengueno"; -type HealthCheckInput = "healthy?"; -type HealthCheckOutput = "healthy!"; +export enum HealthCheckInput { + CHECK, +} +export enum HealthCheckOutput { + YAASQUEEN, +} -const HealthCheckActivity = <Trace>( +export const HealthCheckActivity = <Trace>( check: Mapper< ITraceable<HealthCheckInput, Trace>, - Promise<Either<Error, HealthCheckOutput>> + Promise<IEither<Error, HealthCheckOutput>> >, ) => (req: ITraceable<Request, Trace>) => req.bimap(TraceUtil.withFunctionTrace(HealthCheckActivity)) - .flatMap((r) => r.move(<HealthCheckInput> "healthy?")) + .flatMap((r) => r.move(HealthCheckInput.CHECK)) .map(check) .map(TraceUtil.promiseify(({ item: health, trace }) => { health.mapBoth((e) => { diff --git a/u/server/activity/mod.ts b/u/server/activity/mod.ts index 6908c26..9d05d3c 100644 --- a/u/server/activity/mod.ts +++ b/u/server/activity/mod.ts @@ -6,3 +6,5 @@ export class r200 extends Response { export interface IActivity<Trace> extends RequestFilter<r200, Trace> { } + +export * from "./health.ts"; diff --git a/u/server/filter/json.ts b/u/server/filter/json.ts index 3f11915..f8e4607 100644 --- a/u/server/filter/json.ts +++ b/u/server/filter/json.ts @@ -29,4 +29,5 @@ export const json = <BodyT, Trace, JsonT = unknown>( return new Response(err.message, { status: 400 }); }) ), - ).item; + ) + .item; diff --git a/u/server/filter/method.ts b/u/server/filter/method.ts index 2bf45a0..a1401b4 100644 --- a/u/server/filter/method.ts +++ b/u/server/filter/method.ts @@ -34,4 +34,5 @@ export const requireMethod = } return Either.right<Response, HttpMethod>(method); - })).item; + })) + .item; diff --git a/u/server/mod.ts b/u/server/mod.ts index 556771d..52b26e2 100644 --- a/u/server/mod.ts +++ b/u/server/mod.ts @@ -1 +1,2 @@ export * from "./filter/mod.ts"; +export * from "./activity/mod.ts"; |