Add link to dashboard when Queue commands fail due to being unauthorized

.changeset/fast-dryers-unite.md

@@ -0,0 +1,5 @@
+---
+"wrangler": patch
+---
+
+Add link to Queues tab in dashboard when unauthorized to use Queues

packages/wrangler/src/__tests__/queues.test.ts

@@ -1,6 +1,11 @@
 import { type QueueResponse, type PostConsumerBody } from "../queues/client";
 import { mockAccountId, mockApiToken } from "./helpers/mock-account-id";
-import { setMockResponse, unsetAllMocks } from "./helpers/mock-cfetch";
+import {
+	createFetchResult,
+	setMockRawResponse,
+	setMockResponse,
+	unsetAllMocks,
+} from "./helpers/mock-cfetch";
 import { mockConsoleMethods } from "./helpers/mock-console";
 import { runInTempDir } from "./helpers/run-in-tmp";
 import { runWrangler } from "./helpers/run-wrangler";
@@ -157,6 +162,35 @@ describe("wrangler", () => {
 			  `);
 				expect(requests.count).toEqual(1);
 			});
+
+			it("should show link to dash when not enabled", async () => {
+				const queueName = "testQueue";
+				setMockRawResponse(
+					"/accounts/:accountId/workers/queues",
+					([_url, accountId]) => {
+						expect(accountId).toEqual("some-account-id");
+						return createFetchResult(null, false, [
+							{ message: "workers.api.error.unauthorized", code: 10023 },
+						]);
+					}
+				);
+				await expect(
+					runWrangler(`queues create ${queueName}`)
+				).rejects.toThrowError();
+				expect(std.out).toMatchInlineSnapshot(`
+			"Creating queue testQueue.
+			Queues is not currently enabled on this account. Go to https://dash.cloudflare.com/some-account-id/workers/queues to enable it.
+
+			X [ERROR] A request to the Cloudflare API (/accounts/some-account-id/workers/queues) failed.
+
+			  workers.api.error.unauthorized [code: 10023]
+
+			  If you think this is a bug, please open an issue at:
+			  https://github.com/cloudflare/wrangler2/issues/new/choose
+
+			"
+		`);
+			});
 		});
 
 		describe("delete", () => {
@@ -309,6 +343,35 @@ describe("wrangler", () => {
 						Added consumer to queue testQueue."
 					`);
 				});
+
+				it("should show link to dash when not enabled", async () => {
+					const queueName = "testQueue";
+					setMockRawResponse(
+						`/accounts/:accountId/workers/queues/${queueName}/consumers`,
+						([_url, accountId]) => {
+							expect(accountId).toEqual("some-account-id");
+							return createFetchResult(null, false, [
+								{ message: "workers.api.error.unauthorized", code: 10023 },
+							]);
+						}
+					);
+					await expect(
+						runWrangler(`queues consumer add ${queueName} testScript`)
+					).rejects.toThrowError();
+					expect(std.out).toMatchInlineSnapshot(`
+				"Adding consumer to queue testQueue.
+				Queues is not currently enabled on this account. Go to https://dash.cloudflare.com/some-account-id/workers/queues to enable it.
+
+				X [ERROR] A request to the Cloudflare API (/accounts/some-account-id/workers/queues/testQueue/consumers) failed.
+
+				  workers.api.error.unauthorized [code: 10023]
+
+				  If you think this is a bug, please open an issue at:
+				  https://github.com/cloudflare/wrangler2/issues/new/choose
+
+				"
+			`);
+				});
 			});
 
 			describe("delete", () => {

packages/wrangler/src/queues/cli/commands/index.ts

@@ -1,5 +1,6 @@
 import { type BuilderCallback } from "yargs";
 import { type CommonYargsOptions } from "../../../yargs-types";
+import { HandleUnauthorizedError } from "../../utils";
 import { consumers } from "./consumer";
 
 import { options as createOptions, handler as createHandler } from "./create";
@@ -30,4 +31,6 @@ export const queues: BuilderCallback<CommonYargsOptions, unknown> = (yargs) => {
 			await consumers(consumersYargs);
 		}
 	);
+
+	yargs.fail(HandleUnauthorizedError);
 };

packages/wrangler/src/queues/utils.ts

@@ -0,0 +1,18 @@
+import { logger } from "../logger";
+import { type ParseError } from "../parse";
+import { getAccountId } from "../user";
+
+const isFetchError = (err: unknown): err is ParseError => err instanceof Error;
+
+export const HandleUnauthorizedError = async (_msg: string, err: Error) => {
+	//@ts-expect-error non-standard property on Error
+	if (isFetchError(err) && err.code === 10023) {
+		const accountId = await getAccountId();
+		if (accountId) {
+			return logger.log(
+				`Queues is not currently enabled on this account. Go to https://dash.cloudflare.com/${accountId}/workers/queues to enable it.`
+			);
+		}
+	}
+	throw err;
+};