diff options
Diffstat (limited to 'u/server/response')
-rw-r--r-- | u/server/response/index.ts | 18 | ||||
-rw-r--r-- | u/server/response/json_pengueno.ts | 29 | ||||
-rw-r--r-- | u/server/response/pengueno.ts | 59 |
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; - } -} |