1 files changed, 41 insertions, 31 deletions

diff --git a/hooks/server/job/activity.ts b/hooks/server/job/activity.ts
index 14ea459..173cedf 100644
--- a/hooks/server/job/activity.ts
+++ b/hooks/server/job/activity.ts
@@ -22,7 +22,8 @@ const wellFormedJobMetric = Metric.fromName("Job.WellFormed");
 const jobJsonTransformer = (
   j: ITraceable<unknown, ServerTrace>,
 ): IEither<PenguenoError, Job> =>
-  j.bimap(TraceUtil.withMetricTrace(wellFormedJobMetric))
+  j
+    .bimap(TraceUtil.withMetricTrace(wellFormedJobMetric))
     .map((tJson) => {
       if (!isJob(tJson) || !validateExecutionEntries(tJson)) {
         const err = "seems like a pwetty mawfomed job \\(-.-)/";
@@ -33,10 +34,12 @@ const jobJsonTransformer = (
     })
     .peek((tJob) =>
       tJob.trace.trace(
-        tJob.get().fold((err) =>
-          err ? wellFormedJobMetric.failure : wellFormedJobMetric.success
-        ),
-      )
+        tJob
+          .get()
+          .fold((err) =>
+            err ? wellFormedJobMetric.failure : wellFormedJobMetric.success,
+          ),
+      ),
     )
     .get();
 
@@ -51,18 +54,19 @@ export class JobHookActivityImpl implements IJobHookActivity {
   ) {}
 
   private trace(r: ITraceable<PenguenoRequest, ServerTrace>) {
-    return r.bimap(TraceUtil.withClassTrace(this))
-      .bimap(
-        TraceUtil.withMetricTrace(jobHookRequestMetric),
-      );
+    return r
+      .bimap(TraceUtil.withClassTrace(this))
+      .bimap(TraceUtil.withMetricTrace(jobHookRequestMetric));
   }
 
   public processHook(r: ITraceable<PenguenoRequest, ServerTrace>) {
-    return this.trace(r).map(jsonModel(jobJsonTransformer))
+    return this.trace(r)
+      .map(jsonModel(jobJsonTransformer))
       .map(async (tEitherJobJson) => {
         const eitherJob = await tEitherJobJson.get();
         return eitherJob.flatMapAsync(async (job) => {
-          const eitherQueued = await tEitherJobJson.move(job)
+          const eitherQueued = await tEitherJobJson
+            .move(job)
             .map(this.queuer.queue)
             .get();
           return eitherQueued.mapLeft((e) => new PenguenoError(e.message, 500));
@@ -70,29 +74,35 @@ export class JobHookActivityImpl implements IJobHookActivity {
       })
       .peek(
         TraceUtil.promiseify((tJob) =>
-          tJob.get().fold(
-            (err: PenguenoError | undefined, _val: string | undefined) => {
-              if (!err) {
-                tJob.trace.trace(jobHookRequestMetric.success);
-                tJob.trace.trace(`all queued up and weady to go :D !! ${_val}`);
-                return;
-              }
-              tJob.trace.trace(
-                err.source === ErrorSource.SYSTEM
-                  ? jobHookRequestMetric.failure
-                  : jobHookRequestMetric.warn,
-              );
-              tJob.trace.addTrace(err.source).trace(`${err}`);
-            },
-          )
+          tJob
+            .get()
+            .fold(
+              (err: PenguenoError | undefined, _val: string | undefined) => {
+                if (!err) {
+                  tJob.trace.trace(jobHookRequestMetric.success);
+                  tJob.trace.trace(
+                    `all queued up and weady to go :D !! ${_val}`,
+                  );
+                  return;
+                }
+                tJob.trace.trace(
+                  err.source === ErrorSource.SYSTEM
+                    ? jobHookRequestMetric.failure
+                    : jobHookRequestMetric.warn,
+                );
+                tJob.trace.addTrace(err.source).trace(`${err}`);
+              },
+            ),
         ),
       )
       .map(
-        TraceUtil.promiseify((tEitherQueuedJob) =>
-          new JsonResponse(r, tEitherQueuedJob.get(), {
-            status: tEitherQueuedJob.get()
-              .fold(({ status }, _val) => _val ? 200 : status),
-          })
+        TraceUtil.promiseify(
+          (tEitherQueuedJob) =>
+            new JsonResponse(r, tEitherQueuedJob.get(), {
+              status: tEitherQueuedJob
+                .get()
+                .fold(({ status }, _val) => (_val ? 200 : status)),
+            }),
         ),
       )
       .get();