summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorElizabeth Hunt <me@liz.coffee>2025-06-14 22:00:48 -0700
committerElizabeth Hunt <me@liz.coffee>2025-06-14 22:00:48 -0700
commitcfbd074b8f593ea464dcbeae210eea4b86ec93a3 (patch)
treec44104e557de7552b9ce150de6f7042d2b8684a5
parentbca56b29efe8540f74e1e198116c74e027e16cc3 (diff)
downloadci-cfbd074b8f593ea464dcbeae210eea4b86ec93a3.tar.gz
ci-cfbd074b8f593ea464dcbeae210eea4b86ec93a3.zip
Fixes this being undefined bruh
-rw-r--r--server/job.ts4
-rw-r--r--u/server/filter/json.ts2
-rw-r--r--u/server/request.ts7
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}`),
);