Add app subscription migration commands

.changeset/quiet-badgers-poll.md

@@ -0,0 +1,5 @@
+---
+'@shopify/app': patch
+---
+
+Show subscription migration operation progress while watching status and submissions.

.changeset/schedule-subscription-migrations.md

@@ -0,0 +1,5 @@
+---
+'@shopify/app': minor
+---
+
+Add commands for scheduling and managing app subscription migrations.

packages/app/package.json

@@ -64,6 +64,7 @@
     "@shopify/theme-check-node": "3.27.0",
     "@shopify/toml-patch": "0.3.0",
     "chokidar": "3.6.0",
+    "csv-parse": "7.0.2",
     "diff": "5.2.2",
     "esbuild": "0.28.1",
     "graphql-request": "6.1.0",

packages/app/src/cli/api/graphql/subscription_migrations.ts

@@ -0,0 +1,71 @@
+import {gql} from 'graphql-request'
+
+// 250 matches the maximum migration submission batch size; operation results are currently bounded by that contract.
+// eslint-disable-next-line @shopify/cli/no-inline-graphql
+export const AppSubscriptionMigrationOperationCreateMutation = gql`
+  mutation AppSubscriptionMigrationOperationCreate($input: AppSubscriptionMigrationOperationCreateInput!) {
+    appSubscriptionMigrationOperationCreate(input: $input) {
+      operation {
+        id
+        status
+        total
+        results(first: 250) {
+          edges {
+            node {
+              shopId
+              code
+            }
+          }
+        }
+      }
+      userErrors {
+        message
+        field
+      }
+    }
+  }
+`
+
+// eslint-disable-next-line @shopify/cli/no-inline-graphql
+export const AppSubscriptionMigrationOperationQuery = gql`
+  query AppSubscriptionMigrationOperation($apiKey: String!, $id: ID!) {
+    appSubscriptionMigrationOperation(apiKey: $apiKey, id: $id) {
+      id
+      status
+      total
+      results(first: 250) {
+        edges {
+          node {
+            shopId
+            code
+          }
+        }
+      }
+    }
+  }
+`
+
+// eslint-disable-next-line @shopify/cli/no-inline-graphql
+export const AppSubscriptionMigrationOperationCancelMutation = gql`
+  mutation AppSubscriptionMigrationOperationCancel($input: AppSubscriptionMigrationOperationCancelInput!) {
+    appSubscriptionMigrationOperationCancel(input: $input) {
+      operation {
+        id
+        status
+        total
+        results(first: 250) {
+          edges {
+            node {
+              shopId
+              code
+            }
+          }
+        }
+      }
+      userErrors {
+        message
+        field
+      }
+    }
+  }
+`

packages/app/src/cli/commands/app/subscription-migrations/cancel.ts

@@ -0,0 +1,41 @@
+import {operationFlags} from './flags.js'
+import {cancelMigrationOperations} from '../../../services/subscription-migrations/cancel-operations.js'
+import {outputOperations} from '../../../services/subscription-migrations/command-output.js'
+import {resolveSubscriptionMigrationClientId} from '../../../services/subscription-migrations/resolve-client-id.js'
+import BaseCommand from '@shopify/cli-kit/node/base-command'
+
+export default class Cancel extends BaseCommand {
+  static summary = 'Cancels app subscription migration operations.'
+
+  static descriptionWithMarkdown = `Cancels app subscription migration operations.
+
+Canceling stops additional unprocessed shops, but does not undo shops that have already been scheduled or migrated. Use \`unschedule\` for reversible schedules.
+
+Repeat \`--id\` to cancel every operation GID returned by a multi-batch submission. Use \`--json\` to output the resulting operation states and per-shop results as structured JSON.
+
+By default, the command uses the Client ID from the active app configuration. Use \`--path\` to select an app directory or \`--config\` to select a configuration. Pass \`--client-id\` to explicitly override the active configuration; this only selects the app and does not change Partners authentication.`
+
+  static description = this.descriptionWithoutMarkdown()
+
+  static examples = [
+    '<%= config.bin %> <%= command.id %> --id <operation-id>',
+    '<%= config.bin %> <%= command.id %> --path ../my-app --config staging --id <operation-id-1> --id <operation-id-2>',
+    '<%= config.bin %> <%= command.id %> --client-id <client-id> --id <operation-id> --json',
+  ]
+
+  static flags = {...operationFlags}
+
+  async run(): Promise<void> {
+    const {flags} = await this.parse(Cancel)
+    const clientId = await resolveSubscriptionMigrationClientId({
+      clientId: flags['client-id'],
+      directory: flags.path,
+      configName: flags.config,
+    })
+    const operations = await cancelMigrationOperations({
+      clientId,
+      operationIds: flags.id,
+    })
+    outputOperations(operations, flags.json)
+  }
+}