From 215dac80aeff0049363ac6041d18e94fbaee9fa0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Sun, 5 May 2024 14:48:06 +0200
Subject: [PATCH] better logging when promote does not work

---
 apps/worker/src/jobs/events.incoming-event.ts | 2 ++
 packages/queue/src/utils.ts                   | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/apps/worker/src/jobs/events.incoming-event.ts b/apps/worker/src/jobs/events.incoming-event.ts
index 1c94f030..dcfd923e 100644
--- a/apps/worker/src/jobs/events.incoming-event.ts
+++ b/apps/worker/src/jobs/events.incoming-event.ts
@@ -215,6 +215,8 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
             prevEventJobStatus: await prevEventJob
               .getState()
               .catch(() => 'unknown'),
+            prevEvent,
+            currEvent: payload,
           },
           `Failed to promote job`
         );
diff --git a/packages/queue/src/utils.ts b/packages/queue/src/utils.ts
index fbdf7c1c..51afd443 100644
--- a/packages/queue/src/utils.ts
+++ b/packages/queue/src/utils.ts
@@ -5,5 +5,5 @@ export async function findJobByPrefix<T>(
   matcher: string
 ) {
   const delayed = await queue.getJobs('delayed');
-  return delayed.find((job) => job.opts.jobId?.startsWith(matcher));
+  return delayed.find((job) => job?.opts?.jobId?.startsWith(matcher));
 }