firebase · blidd-google · Nov 12, 2024 · Nov 7, 2024 · Nov 7, 2024 · Nov 7, 2024
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -0,0 +1 @@
+- Fix Task Queue Emulator error handling to display error message properly. (#7916)
diff --git a/src/emulator/tasksEmulator.ts b/src/emulator/tasksEmulator.ts
@@ -24,7 +24,7 @@
    oidcToken?: {
      serviceAccountEmail: string;
    };
    body: any;
    headers: { [key: string]: string };
  };
 }
@@ -163,8 +163,8 @@
    return this.running;
  }

  getStatistics() {
    const stats: Record<string, any> = {};
    for (const [key, queue] of Object.entries(this.queues)) {
      stats[key] = queue.getStatistics();
    }
@@ -203,7 +203,11 @@
       const locationId = req.params.location_id;
       const queueName = req.params.queue_name;
       if (!this.validateQueueId(queueName)) {
-        res.status(400).send("Invalid Queue ID");
+        res.status(400).json({
+          error:
+            "Queue ID must start with a letter followed by up to 62 letters, numbers, " +
+            "hyphens, or underscores and must end with a letter or a number",
+        });
         return;
       }
 
@@ -233,7 +237,7 @@
         defaultUri: body.defaultUri,
       };
       if (taskQueueConfig.rateLimits.maxConcurrentDispatches > 5000) {
-        res.status(400).send("cannot set maxConcurrentDispatches to a value over 5000");
+        res.status(400).json({ error: "cannot set maxConcurrentDispatches to a value over 5000" });
         return;
       }
 
@@ -261,10 +265,10 @@
        return;
      }

      req.body.task.name =
        req.body.task.name ??
        `/projects/${projectId}/locations/${locationId}/queues/${queueName}/tasks/${Math.floor(Math.random() * Number.MAX_SAFE_INTEGER)}`;
      req.body.task.httpRequest.body = JSON.parse(atob(req.body.task.httpRequest.body));

      const task = req.body.task as Task;
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		- Fix Task Queue Emulator error handling to display error message properly. (#7916)