summaryrefslogtreecommitdiff
path: root/u/server/filter/json.ts
diff options
context:
space:
mode:
authorElizabeth <me@liz.coffee>2025-06-02 22:54:40 -0700
committerElizabeth <me@liz.coffee>2025-06-02 22:54:40 -0700
commit0662f62db82026e44cfff7ec42776eb6c2c06cfa (patch)
treef59bc8eb82e5c075d2c59e547a42ceefdc1c3ffc /u/server/filter/json.ts
parent2ae2ebc8aa7c4600f499ab7d2264dcb1d16db4ae (diff)
downloadci-0662f62db82026e44cfff7ec42776eb6c2c06cfa.tar.gz
ci-0662f62db82026e44cfff7ec42776eb6c2c06cfa.zip
Significant logging improvements
Diffstat (limited to 'u/server/filter/json.ts')
-rw-r--r--u/server/filter/json.ts12
1 files changed, 6 insertions, 6 deletions
diff --git a/u/server/filter/json.ts b/u/server/filter/json.ts
index 79eabac..06cf1bf 100644
--- a/u/server/filter/json.ts
+++ b/u/server/filter/json.ts
@@ -22,12 +22,13 @@ export const jsonModel =
): RequestFilter<MessageT> =>
(r: ITraceable<PenguenoRequest, ServerTrace>) =>
r
- .bimap(TraceUtil.withMetricTrace(ParseJsonMetric))
+ .bimap(TraceUtil.withFunctionTrace(jsonModel))
+ .bimap(TraceUtil.withMetricTrace(ParseJsonMetric))
.map((j) =>
- Either.fromFailableAsync<Error, MessageT>(j.get().json()).then(
+ Either.fromFailableAsync<Error, MessageT>(() => j.get().json()).then(
(either) =>
either.mapLeft((errReason) => {
- j.trace.addTrace(LogLevel.WARN).trace(`${errReason}`);
+ j.trace.addTrace(LogLevel.WARN).trace(errReason);
return new PenguenoError(
"seems to be invalid JSON (>//<) can you fix?",
400,
@@ -37,9 +38,8 @@ export const jsonModel =
)
.peek(
TraceUtil.promiseify((traceableEither) =>
- traceableEither.get().mapBoth(
- () => traceableEither.trace.trace(ParseJsonMetric.failure),
- () => traceableEither.trace.trace(ParseJsonMetric.success),
+ traceableEither.get().fold(({ isLeft }) =>
+ traceableEither.trace.trace(ParseJsonMetric[isLeft ? "failure" : "success"])
),
),
)