summaryrefslogtreecommitdiff
path: root/u/server/response
diff options
context:
space:
mode:
Diffstat (limited to 'u/server/response')
-rw-r--r--u/server/response/index.ts18
-rw-r--r--u/server/response/json_pengueno.ts29
-rw-r--r--u/server/response/pengueno.ts59
3 files changed, 0 insertions, 106 deletions
diff --git a/u/server/response/index.ts b/u/server/response/index.ts
deleted file mode 100644
index 17a2d97..0000000
--- a/u/server/response/index.ts
+++ /dev/null
@@ -1,18 +0,0 @@
-import { Body } from '@emprespresso/pengueno';
-
-export interface BaseResponse {
- status: number;
- statusText: string;
- headers: Record<string, string>;
-
- body(): Body;
-}
-
-export interface ResponseOpts {
- status: number;
- statusText?: string;
- headers?: Record<string, string>;
-}
-
-export * from './pengueno.js';
-export * from './json_pengueno.js';
diff --git a/u/server/response/json_pengueno.ts b/u/server/response/json_pengueno.ts
deleted file mode 100644
index d0b74a8..0000000
--- a/u/server/response/json_pengueno.ts
+++ /dev/null
@@ -1,29 +0,0 @@
-import {
- isEither,
- ITraceable,
- PenguenoRequest,
- PenguenoResponse,
- ResponseOpts,
- ServerTrace,
-} from '@emprespresso/pengueno';
-
-type Jsonable = any;
-export class JsonResponse extends PenguenoResponse {
- constructor(req: ITraceable<PenguenoRequest, ServerTrace>, e: Jsonable, _opts: ResponseOpts) {
- const opts = { ..._opts, headers: { ..._opts.headers, 'Content-Type': 'application/json' } };
- if (isEither<Jsonable, Jsonable>(e)) {
- super(
- req,
- JSON.stringify(
- e.fold(
- (error) => ({ error, ok: undefined }),
- (ok) => ({ ok }),
- ),
- ),
- opts,
- );
- return;
- }
- super(req, JSON.stringify(Math.floor(opts.status / 100) > 4 ? { error: e } : { ok: e }), opts);
- }
-}
diff --git a/u/server/response/pengueno.ts b/u/server/response/pengueno.ts
deleted file mode 100644
index 5a953db..0000000
--- a/u/server/response/pengueno.ts
+++ /dev/null
@@ -1,59 +0,0 @@
-import {
- BaseResponse,
- Body,
- HttpStatusCodes,
- ITraceable,
- Metric,
- Optional,
- PenguenoRequest,
- ResponseOpts,
- ServerTrace,
-} from '@emprespresso/pengueno';
-
-const getHeaders = (req: PenguenoRequest, extraHeaders: Record<string, string>) => {
- const optHeaders = {
- ...req.getResponseHeaders(),
- ...extraHeaders,
- };
- optHeaders['Content-Type'] = (optHeaders['Content-Type'] ?? 'text/plain') + '; charset=utf-8';
- return optHeaders;
-};
-
-const ResponseCodeMetrics = [0, 1, 2, 3, 4, 5].map((x) => Metric.fromName(`response.${x}xx`).asResult());
-export const getResponseMetrics = (status: number, elapsedMs?: number) => {
- const index = Math.floor(status / 100);
- return ResponseCodeMetrics.flatMap((metric, i) =>
- Optional.from(i)
- .filter((i) => i === index)
- .map(() => [metric.count.withValue(1.0)])
- .flatMap((metricValues) =>
- Optional.from(elapsedMs)
- .map((ms) => metricValues.concat(metric.time.withValue(ms)))
- .orSome(() => metricValues),
- )
- .orSome(() => [metric.count.withValue(0.0)])
- .get(),
- );
-};
-
-export class PenguenoResponse implements BaseResponse {
- public readonly statusText: string;
- public readonly status: number;
- public readonly headers: Record<string, string>;
-
- constructor(
- req: ITraceable<PenguenoRequest, ServerTrace>,
- private readonly _body: Body,
- opts: ResponseOpts,
- ) {
- this.headers = getHeaders(req.get(), opts?.headers ?? {});
- this.status = opts.status;
- this.statusText = opts.statusText ?? HttpStatusCodes[this.status]!;
-
- req.trace.trace(getResponseMetrics(opts.status, req.get().elapsedTimeMs()));
- }
-
- public body() {
- return this._body;
- }
-}