diff options
| -rw-r--r-- | server/job.ts | 4 | ||||
| -rw-r--r-- | u/server/filter/json.ts | 2 | ||||
| -rw-r--r-- | u/server/request.ts | 7 |
3 files changed, 6 insertions, 7 deletions
diff --git a/server/job.ts b/server/job.ts index af11ac0..06359d1 100644 --- a/server/job.ts +++ b/server/job.ts @@ -29,7 +29,7 @@ const jobJsonTransformer = ( .bimap(TraceUtil.withMetricTrace(wellFormedJobMetric)) .map((tJson) => { if (!isJob(tJson) || !validateExecutionEntries(tJson)) { - const err = "seems like a pwetty mawfomed job \\(-.-)/"; + const err = "seems like a pwetty mawfomed job (-.-)"; tJson.trace.addTrace(LogLevel.WARN).trace(err); return Either.left<PenguenoError, Job>(new PenguenoError(err, 400)); } @@ -70,7 +70,7 @@ export class JobHookActivityImpl implements IJobHookActivity { return eitherJob.flatMapAsync(async (job) => { const eitherQueued = await tEitherJobJson .move(job) - .map(this.queuer.queue) + .map((job) => this.queuer.queue(job)) .get(); return eitherQueued.mapLeft((e) => new PenguenoError(e.message, 500)); }); diff --git a/u/server/filter/json.ts b/u/server/filter/json.ts index 06cf1bf..145d1be 100644 --- a/u/server/filter/json.ts +++ b/u/server/filter/json.ts @@ -47,7 +47,7 @@ export const jsonModel = TraceUtil.promiseify((traceableEitherJson) => traceableEitherJson .get() - .mapRight(traceableEitherJson.move) + .mapRight((j) => traceableEitherJson.move(j)) .flatMap(jsonTransformer), ), ) diff --git a/u/server/request.ts b/u/server/request.ts index 10357ca..72e812a 100644 --- a/u/server/request.ts +++ b/u/server/request.ts @@ -13,12 +13,11 @@ const penguenoGreeting = () => export class PenguenoRequest extends Request { private constructor( - _input: URL, - _requestInit: RequestInit, + _input: Request, public readonly id: string, public readonly at: Date, ) { - super(_input, _requestInit); + super(_input); } public baseResponseHeaders(): Record<string, string> { @@ -41,7 +40,7 @@ export class PenguenoRequest extends Request { const url = new URL(request.url); const { pathname } = url; const logTraceable = LogTraceable.of( - new PenguenoRequest(url, { ...request }, id, new Date()), + new PenguenoRequest(request, id, new Date()), ).bimap( TraceUtil.withTrace(`RequestId = ${id}, Method = ${request.method}, Path = ${pathname}`), ); |