[Poke] Plugin to downgrade a list of workspaces to NO_PLAN

Description
---
Fraudulent workspaces are often found by batches. Manually swiching
each of them to NO_PLAN can be a pain.

This plugin allows deleting a list of workspaces

Risk
---
User error to downgrade wrong workspaces. Mitigated by warning message

Deploy
---
front

front/lib/api/poke/plugins/global/batch_downgrade.ts

@@ -0,0 +1,64 @@
+import { Err, Ok } from "@dust-tt/types";
+
+import { createPlugin } from "@app/lib/api/poke/types";
+import { Workspace } from "@app/lib/models/workspace";
+import { Op } from "sequelize";
+import { internalSubscribeWorkspaceToFreeNoPlan } from "@app/lib/plans/subscription";
+import { launchScheduleWorkspaceScrubWorkflow } from "@app/temporal/scrub_workspace/client";
+
+export const batchDowngradePlugin = createPlugin(
+  {
+    id: "batch-downgrade",
+    name: "Batch Downgrade Workspaces",
+    description:
+      "Downgrade a list of workspaces to NO_PLAN, used to block access to fraudulent users",
+    resourceTypes: ["global"],
+    args: {
+      sIds: {
+        type: "string",
+        label: "Workspace sIds",
+        description:
+          "Comma-separated list of sIds of the workspaces to downgrade",
+      },
+    },
+  },
+  async (_1, _2, args) => {
+    const { sIds } = args;
+
+    const sIdsArray = sIds.split(",").map((sId) => sId.trim());
+
+    const workspaces = await Workspace.findAll({
+      where: {
+        sId: {
+          [Op.in]: sIdsArray,
+        },
+      },
+    });
+
+    const missingWorkspaces = sIdsArray.filter(
+      (sId) => !workspaces.some((w) => w.sId === sId)
+    );
+
+    if (missingWorkspaces.length > 0) {
+      return new Err(
+        new Error(`Workspaces not found: ${missingWorkspaces.join(", ")}`)
+      );
+    }
+
+    for (const workspace of workspaces) {
+      await internalSubscribeWorkspaceToFreeNoPlan({
+        workspaceId: workspace.sId,
+      });
+
+      // On downgrade, start a worklflow to pause all connectors + scrub the data after a specified retention period.
+      await launchScheduleWorkspaceScrubWorkflow({
+        workspaceId: workspace.sId,
+      });
+    }
+
+    return new Ok({
+      display: "text",
+      value: `Workspaces downgraded.`,
+    });
+  }
+);

front/lib/api/poke/plugins/global/index.ts

@@ -1 +1,2 @@
 export * from "./create_workspace";
+export * from "./batch_downgrade";