Workflows commands (#7015)

* add commands

* add command description

* change private beta message to open beta

* refactor to use defineCommand util

* add changeset

* update snapshots

* remove extraneous periods

* remove redundant file

Co-authored-by: Luís Duarte <[email protected]>

Author: RamIdeas

.changeset/moody-seals-smash.md

@@ -0,0 +1,5 @@
+---
+"wrangler": minor
+---
+
+add `wrangler workflows ...` commands

packages/wrangler/package.json

@@ -75,7 +75,9 @@
 		"@esbuild-plugins/node-modules-polyfill": "^0.2.2",
 		"blake3-wasm": "^2.1.5",
 		"chokidar": "^3.5.3",
+		"date-fns": "^4.1.0",
 		"esbuild": "0.17.19",
+		"itty-time": "^1.0.6",
 		"miniflare": "workspace:*",
 		"nanoid": "^3.3.3",
 		"path-to-regexp": "^6.3.0",

packages/wrangler/src/__tests__/core/command-registration.test.ts

@@ -191,6 +191,7 @@ describe("Command Registration", () => {
 			  wrangler pubsub                          📮 Manage Pub/Sub brokers [private beta]
 			  wrangler dispatch-namespace              🏗️  Manage dispatch namespaces
 			  wrangler ai                              🤖 Manage AI models
+			  wrangler workflows                       🔁 Manage Workflows [open-beta]
 			  wrangler login                           🔓 Login to Cloudflare
 			  wrangler logout                          🚪 Logout from Cloudflare
 			  wrangler whoami                          🕵️  Retrieve your user information

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

@@ -61,6 +61,7 @@ describe("wrangler", () => {
 				  wrangler pubsub                 📮 Manage Pub/Sub brokers [private beta]
 				  wrangler dispatch-namespace     🏗️  Manage dispatch namespaces
 				  wrangler ai                     🤖 Manage AI models
+				  wrangler workflows              🔁 Manage Workflows [open-beta]
 				  wrangler login                  🔓 Login to Cloudflare
 				  wrangler logout                 🚪 Logout from Cloudflare
 				  wrangler whoami                 🕵️  Retrieve your user information
@@ -117,6 +118,7 @@ describe("wrangler", () => {
 				  wrangler pubsub                 📮 Manage Pub/Sub brokers [private beta]
 				  wrangler dispatch-namespace     🏗️  Manage dispatch namespaces
 				  wrangler ai                     🤖 Manage AI models
+				  wrangler workflows              🔁 Manage Workflows [open-beta]
 				  wrangler login                  🔓 Login to Cloudflare
 				  wrangler logout                 🚪 Logout from Cloudflare
 				  wrangler whoami                 🕵️  Retrieve your user information

packages/wrangler/src/__tests__/versions/versions.help.test.ts

@@ -37,6 +37,7 @@ describe("versions --help", () => {
 			  wrangler pubsub                    📮 Manage Pub/Sub brokers [private beta]
 			  wrangler dispatch-namespace        🏗️  Manage dispatch namespaces
 			  wrangler ai                        🤖 Manage AI models
+			  wrangler workflows                 🔁 Manage Workflows [open-beta]
 			  wrangler login                     🔓 Login to Cloudflare
 			  wrangler logout                    🚪 Logout from Cloudflare
 			  wrangler whoami                    🕵️  Retrieve your user information

packages/wrangler/src/core/teams.d.ts

@@ -14,4 +14,5 @@ export type Teams =
 	| "Product: AI"
 	| "Product: Hyperdrive"
 	| "Product: Vectorize"
+	| "Product: Workflows"
 	| "Product: Cloudchamber";

packages/wrangler/src/index.ts

@@ -43,6 +43,7 @@ import { generateHandler, generateOptions } from "./generate";
 import { hyperdrive } from "./hyperdrive/index";
 import { initHandler, initOptions } from "./init";
 import "./kv";
+import "./workflows";
 import { logBuildFailure, logger, LOGGER_LEVELS } from "./logger";
 import * as metrics from "./metrics";
 import { mTlsCertificateCommands } from "./mtls-certificate/cli";
@@ -608,6 +609,9 @@ export function createCLIParser(argv: string[]) {
 		return ai(aiYargs.command(subHelp));
 	});
 
+	// workflows
+	register.registerNamespace("workflows");
+
 	// pipelines
 	wrangler.command("pipelines", false, (pipelinesYargs) => {
 		return pipelines(pipelinesYargs.command(subHelp));

packages/wrangler/src/workflows/commands/delete.ts

@@ -0,0 +1,33 @@
+import { fetchResult } from "../../cfetch";
+import { defineCommand } from "../../core";
+import { logger } from "../../logger";
+import { requireAuth } from "../../user";
+
+defineCommand({
+	command: "wrangler workflows delete",
+	metadata: {
+		description:
+			"Delete workflow - when deleting a workflow, it will also delete it's own instances",
+		owner: "Product: Workflows",
+		status: "open-beta",
+	},
+
+	args: {
+		name: {
+			describe: "Name of the workflow",
+			type: "string",
+			demandOption: true,
+		},
+	},
+	positionalArgs: ["name"],
+
+	async handler(args, { config }) {
+		const accountId = await requireAuth(config);
+
+		await fetchResult(`/accounts/${accountId}/workflows/${args.name}`, {
+			method: "DELETE",
+		});
+
+		logger.info(`Workflow "${args.name}" was successfully removed`);
+	},
+});

packages/wrangler/src/workflows/commands/describe.ts

@@ -0,0 +1,59 @@
+import { logRaw } from "@cloudflare/cli";
+import { white } from "@cloudflare/cli/colors";
+import { fetchResult } from "../../cfetch";
+import { defineCommand } from "../../core";
+import { requireAuth } from "../../user";
+import formatLabelledValues from "../../utils/render-labelled-values";
+import type { Version, Workflow } from "../types";
+
+defineCommand({
+	command: "wrangler workflows describe",
+	metadata: {
+		description: "Describe Workflow resource",
+		owner: "Product: Workflows",
+		status: "open-beta",
+	},
+	args: {
+		name: {
+			describe: "Name of the workflow",
+			type: "string",
+			demandOption: true,
+		},
+	},
+	positionalArgs: ["name"],
+	async handler(args, { config }) {
+		const accountId = await requireAuth(config);
+
+		const workflow = await fetchResult<Workflow>(
+			`/accounts/${accountId}/workflows/${args.name}`
+		);
+
+		const versions = await fetchResult<Version[]>(
+			`/accounts/${accountId}/workflows/${args.name}/versions`
+		);
+
+		const latestVersion = versions[0];
+
+		logRaw(
+			formatLabelledValues({
+				Name: workflow.name,
+				Id: workflow.id,
+				"Script Name": workflow.script_name,
+				"Class Name": workflow.class_name,
+				"Created On": workflow.created_on,
+				"Modified On": workflow.modified_on,
+			})
+		);
+		logRaw(white("Latest Version:"));
+		logRaw(
+			formatLabelledValues(
+				{
+					Id: latestVersion.id,
+					"Created On": workflow.created_on,
+					"Modified On": workflow.modified_on,
+				},
+				{ indentationCount: 2 }
+			)
+		);
+	},
+});