keep format-bulk-operation-status

Author: jordanverasamy

packages/app/src/cli/services/bulk-operations/execute-bulk-operation.ts

@@ -114,7 +114,7 @@ export async function executeBulkOperation(input: ExecuteBulkOperationInput): Pr
 =======
     if (watch) {
       const finalOperation = await renderSingleTask<BulkOperation>({
-        title: outputContent`starting bulk operation...`,
+        title: outputContent`Starting bulk operation...`,
         task: async (updateStatus) => {
           let lastObjectCount = ''
           while (true) {
@@ -126,19 +126,20 @@ export async function executeBulkOperation(input: ExecuteBulkOperationInput): Pr
               version: '2026-01',
             })
 
+            if (!response.bulkOperation) {
+              throw new Error('bulk operation not found')
+            }
+
             const op = response.bulkOperation as BulkOperation
 
             if (op.status === 'RUNNING') {
               const currentObjectCount = String(op.objectCount)
               if (currentObjectCount !== lastObjectCount) {
-                const status = outputContent`bulk operation in progress... ${outputToken.gray(
-                  `(${currentObjectCount} objects)`,
-                )}`
-                updateStatus(status)
+                updateStatus(formatBulkOperationStatus(op))
                 lastObjectCount = currentObjectCount
               }
             } else if (op.status === 'CREATED') {
-              updateStatus(outputContent`starting...`)
+              updateStatus(formatBulkOperationStatus(op))
             }
 
             if (TERMINAL_STATUSES.includes(op.status)) {

packages/app/src/cli/services/bulk-operations/format-bulk-operation-status.ts

@@ -1,27 +1,30 @@
 import {GetBulkOperationByIdQuery} from '../../api/graphql/bulk-operations/generated/get-bulk-operation-by-id.js'
+import {outputContent, outputToken, TokenizedString} from '@shopify/cli-kit/node/output'
 
 type BulkOperation = NonNullable<GetBulkOperationByIdQuery['bulkOperation']> & {
   status: string
   objectCount: unknown
 }
 
-export function formatBulkOperationStatus(operation: BulkOperation): string {
+export function formatBulkOperationStatus(operation: BulkOperation): TokenizedString {
   switch (operation.status) {
     case 'RUNNING':
-      return `bulk operation in progress... (${String(operation.objectCount)} objects)`
+      return outputContent`Bulk operation in progress... ${outputToken.gray(
+        `(${String(operation.objectCount)} objects)`,
+      )}`
     case 'CREATED':
-      return 'starting...'
+      return outputContent`Starting...`
     case 'COMPLETED':
-      return 'bulk operation succeeded.'
+      return outputContent`Bulk operation succeeded.`
     case 'FAILED':
-      return `bulk operation failed. (error: ${operation.errorCode ?? 'unknown'})`
+      return outputContent`Bulk operation failed. ${outputToken.gray(`(error: ${operation.errorCode ?? 'unknown'})`)}`
     case 'CANCELING':
-      return 'bulk operation canceling...'
+      return outputContent`Bulk operation canceling...`
     case 'CANCELED':
-      return 'bulk operation canceled.'
+      return outputContent`Bulk operation canceled.`
     case 'EXPIRED':
-      return 'bulk operation expired.'
+      return outputContent`Bulk operation expired.`
     default:
-      return `bulk operation status: ${operation.status}`
+      return outputContent`Bulk operation status: ${operation.status}`
   }
 }