Consolidated switch statement

Author: matt-aitken

apps/webapp/app/v3/taskRunHeartbeatFailed.server.ts

@@ -49,37 +49,11 @@ export class TaskRunHeartbeatFailedService extends BaseService {
     const service = new FailedTaskRunService();
 
     switch (taskRun.status) {
-      case "PENDING": {
-        const backInQueue = await marqs?.nackMessage(taskRun.id);
-
-        if (backInQueue) {
-          logger.debug(
-            `[TaskRunHeartbeatFailedService] ${taskRun.status} run is back in the queue run`,
-            {
-              taskRun,
-            }
-          );
-        } else {
-          logger.debug(
-            `[TaskRunHeartbeatFailedService] ${taskRun.status} run not back in the queue, failing`,
-            { taskRun }
-          );
-          await service.call(taskRun.friendlyId, {
-            ok: false,
-            id: taskRun.friendlyId,
-            retry: undefined,
-            error: {
-              type: "INTERNAL_ERROR",
-              code: TaskRunErrorCodes.TASK_RUN_HEARTBEAT_TIMEOUT,
-              message: "Did not receive a heartbeat from the worker in time",
-            },
-          });
-        }
-
-        break;
-      }
+      case "PENDING":
       case "EXECUTING":
-      case "RETRYING_AFTER_FAILURE": {
+      case "RETRYING_AFTER_FAILURE":
+      case "WAITING_TO_RESUME":
+      case "PAUSED": {
         const backInQueue = await marqs?.nackMessage(taskRun.id);
 
         if (backInQueue) {
@@ -119,36 +93,6 @@ export class TaskRunHeartbeatFailedService extends BaseService {
 
         break;
       }
-      case "WAITING_TO_RESUME":
-      case "PAUSED": {
-        const backInQueue = await marqs?.nackMessage(taskRun.id);
-
-        if (backInQueue) {
-          logger.debug(
-            `[TaskRunHeartbeatFailedService] ${taskRun.status} run is back in the queue run`,
-            {
-              taskRun,
-            }
-          );
-        } else {
-          logger.debug(
-            `[TaskRunHeartbeatFailedService] ${taskRun.status} run not back in the queue, failing`,
-            { taskRun }
-          );
-          await service.call(taskRun.friendlyId, {
-            ok: false,
-            id: taskRun.friendlyId,
-            retry: undefined,
-            error: {
-              type: "INTERNAL_ERROR",
-              code: TaskRunErrorCodes.TASK_RUN_HEARTBEAT_TIMEOUT,
-              message: "Did not receive a heartbeat from the worker in time",
-            },
-          });
-        }
-
-        break;
-      }
       case "SYSTEM_FAILURE":
       case "INTERRUPTED":
       case "CRASHED":