impr: log failed worker queue jobs (@fehmer) (monkeytypegame#6295)

!nuf closes monkeytypegame#6294

Author: fehmer

backend/src/workers/email-worker.ts

@@ -33,8 +33,15 @@ async function jobHandler(job: Job<EmailTask<EmailType>>): Promise<void> {
   Logger.success(`Job: ${type} - completed in ${elapsed}ms`);
 }
 
-export default (redisConnection?: IORedis.Redis): Worker =>
-  new Worker(EmailQueue.queueName, jobHandler, {
+export default (redisConnection?: IORedis.Redis): Worker => {
+  const worker = new Worker(EmailQueue.queueName, jobHandler, {
     autorun: false,
     connection: redisConnection as ConnectionOptions,
   });
+  worker.on("failed", (job, error) => {
+    Logger.error(
+      `Job: ${job.data.type} - failed with error "${error.message}"`
+    );
+  });
+  return worker;
+};

backend/src/workers/later-worker.ts

@@ -208,8 +208,15 @@ async function jobHandler(job: Job<LaterTask<LaterTaskType>>): Promise<void> {
   Logger.success(`Job: ${taskName} - completed in ${elapsed}ms`);
 }
 
-export default (redisConnection?: IORedis.Redis): Worker =>
-  new Worker(LaterQueue.queueName, jobHandler, {
+export default (redisConnection?: IORedis.Redis): Worker => {
+  const worker = new Worker(LaterQueue.queueName, jobHandler, {
     autorun: false,
     connection: redisConnection as ConnectionOptions,
   });
+  worker.on("failed", (job, error) => {
+    Logger.error(
+      `Job: ${job.data.taskName} - failed with error "${error.message}"`
+    );
+  });
+  return worker;
+};