1 files changed, 0 insertions, 42 deletions
diff --git a/u/server/filter/json.ts b/u/server/filter/json.ts
deleted file mode 100644
index bc53d47..0000000
--- a/u/server/filter/json.ts
+++ /dev/null
@@ -1,42 +0,0 @@
-import {
-    Either,
-    type IEither,
-    type ITraceable,
-    LogLevel,
-    Metric,
-    PenguenoError,
-    type PenguenoRequest,
-    type RequestFilter,
-    type ServerTrace,
-    TraceUtil,
-} from '@emprespresso/pengueno';
-
-export interface JsonTransformer<R, ParsedJson = unknown> {
-    (json: ITraceable<ParsedJson, ServerTrace>): IEither<PenguenoError, R>;
-}
-
-const ParseJsonMetric = Metric.fromName('JsonParse').asResult();
-export const jsonModel =
-    <MessageT>(jsonTransformer: JsonTransformer<MessageT>): RequestFilter<MessageT> =>
-    (r: ITraceable<PenguenoRequest, ServerTrace>) =>
-        r
-            .flatMap(TraceUtil.withFunctionTrace(jsonModel))
-            .flatMap(TraceUtil.withMetricTrace(ParseJsonMetric))
-            .map((j) =>
-                Either.fromFailableAsync<Error, MessageT>(<Promise<MessageT>>j.get().req.json()).then((either) =>
-                    either.mapLeft((errReason) => {
-                        j.trace.traceScope(LogLevel.WARN).trace(errReason);
-                        return new PenguenoError('seems to be invalid JSON (>//<) can you fix?', 400);
-                    }),
-                ),
-            )
-            .flatMapAsync(TraceUtil.promiseify(TraceUtil.traceResultingEither(ParseJsonMetric)))
-            .map(
-                TraceUtil.promiseify((traceableEitherJson) =>
-                    traceableEitherJson
-                        .get()
-                        .mapRight((j) => traceableEitherJson.move(j))
-                        .flatMap(jsonTransformer),
-                ),
-            )
-            .get();