quick-watch-for-cli

Author: ericlee878

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

@@ -1,7 +1,7 @@
 import {executeBulkOperation} from './execute-bulk-operation.js'
 import {runBulkOperationQuery} from './run-query.js'
 import {runBulkOperationMutation} from './run-mutation.js'
-import {watchBulkOperation} from './watch-bulk-operation.js'
+import {watchBulkOperation, quickWatchBulkOperation} from './watch-bulk-operation.js'
 import {downloadBulkOperationResults} from './download-bulk-operation-results.js'
 import {BulkOperationRunQueryMutation} from '../../api/graphql/bulk-operations/generated/bulk-operation-run-query.js'
 import {BulkOperationRunMutationMutation} from '../../api/graphql/bulk-operations/generated/bulk-operation-run-mutation.js'
@@ -52,6 +52,7 @@ describe('executeBulkOperation', () => {
 
   beforeEach(() => {
     vi.mocked(ensureAuthenticatedAdminAsApp).mockResolvedValue(mockAdminSession)
+    vi.mocked(quickWatchBulkOperation).mockResolvedValue(createdBulkOperation)
   })
 
   afterEach(() => {
@@ -331,7 +332,7 @@ describe('executeBulkOperation', () => {
     })
   })
 
-  test('waits for operation to finish and renders success when watch is provided and operation finishes with COMPLETED status', async () => {
+  test('uses watchBulkOperation (not quickWatchBulkOperation) when watch flag is true', async () => {
     const query = '{ products { edges { node { id } } } }'
     const initialResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
       bulkOperation: createdBulkOperation,
@@ -346,7 +347,9 @@ describe('executeBulkOperation', () => {
 
     vi.mocked(runBulkOperationQuery).mockResolvedValue(initialResponse)
     vi.mocked(watchBulkOperation).mockResolvedValue(completedOperation)
-    vi.mocked(downloadBulkOperationResults).mockResolvedValue('{"id":"gid://shopify/Product/123"}')
+    vi.mocked(downloadBulkOperationResults).mockResolvedValue(
+      '{"data":{"products":{"edges":[{"node":{"id":"gid://shopify/Product/123"}}],"userErrors":[]}},"__lineNumber":0}',
+    )
 
     await executeBulkOperation({
       remoteApp: mockRemoteApp,
@@ -355,6 +358,13 @@ describe('executeBulkOperation', () => {
       watch: true,
     })
 
+    expect(watchBulkOperation).toHaveBeenCalledWith(
+      mockAdminSession,
+      createdBulkOperation.id,
+      expect.any(Object),
+      expect.any(Function),
+    )
+    expect(quickWatchBulkOperation).not.toHaveBeenCalled()
     expect(renderSuccess).toHaveBeenCalledWith(
       expect.objectContaining({
         headline: expect.stringContaining('Bulk operation succeeded:'),
@@ -394,10 +404,62 @@ describe('executeBulkOperation', () => {
     expect(downloadBulkOperationResults).not.toHaveBeenCalled()
   })
 
+  test('uses quickWatchBulkOperation (not watchBulkOperation) when watch flag is false', async () => {
+    const query = '{ products { edges { node { id } } } }'
+    const mockResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
+      bulkOperation: createdBulkOperation,
+      userErrors: [],
+    }
+
+    vi.mocked(runBulkOperationQuery).mockResolvedValue(mockResponse)
+    vi.mocked(quickWatchBulkOperation).mockResolvedValue(createdBulkOperation)
+
+    await executeBulkOperation({
+      remoteApp: mockRemoteApp,
+      storeFqdn,
+      query,
+      watch: false,
+    })
+
+    expect(quickWatchBulkOperation).toHaveBeenCalledWith(mockAdminSession, createdBulkOperation.id)
+    expect(watchBulkOperation).not.toHaveBeenCalled()
+  })
+
+  test('renders info message when quickWatchBulkOperation returns RUNNING status', async () => {
+    const query = '{ products { edges { node { id } } } }'
+    const runningOperation = {
+      ...createdBulkOperation,
+      status: 'RUNNING' as const,
+      objectCount: '50',
+    }
+    const mockResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
+      bulkOperation: createdBulkOperation,
+      userErrors: [],
+    }
+
+    vi.mocked(runBulkOperationQuery).mockResolvedValue(mockResponse)
+    vi.mocked(quickWatchBulkOperation).mockResolvedValue(runningOperation)
+
+    await executeBulkOperation({
+      remoteApp: mockRemoteApp,
+      storeFqdn,
+      query,
+      watch: false,
+    })
+
+    expect(renderSuccess).toHaveBeenCalledWith(
+      expect.objectContaining({
+        headline: 'Bulk operation is running.',
+        body: ['Monitor its progress with:', {command: expect.stringContaining('shopify app bulk status')}],
+      }),
+    )
+  })
+
   test('writes results to file when --output-file flag is provided', async () => {
     const query = '{ products { edges { node { id } } } }'
     const outputFile = '/tmp/results.jsonl'
-    const resultsContent = '{"id":"gid://shopify/Product/123"}\n{"id":"gid://shopify/Product/456"}'
+    const resultsContent =
+      '{"data":{"productCreate":{"product":{"id":"gid://shopify/Product/123"},"userErrors":[]}},"__lineNumber":0}\n{"data":{"productCreate":{"product":{"id":"gid://shopify/Product/456"},"userErrors":[]}},"__lineNumber":1}'
 
     const initialResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
       bulkOperation: createdBulkOperation,
@@ -427,7 +489,8 @@ describe('executeBulkOperation', () => {
 
   test('writes results to stdout when --output-file flag is not provided', async () => {
     const query = '{ products { edges { node { id } } } }'
-    const resultsContent = '{"id":"gid://shopify/Product/123"}\n{"id":"gid://shopify/Product/456"}'
+    const resultsContent =
+      '{"data":{"productCreate":{"product":{"id":"gid://shopify/Product/123"},"userErrors":[]}},"__lineNumber":0}\n{"data":{"productCreate":{"product":{"id":"gid://shopify/Product/456"},"userErrors":[]}},"__lineNumber":1}'
 
     const initialResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
       bulkOperation: createdBulkOperation,
@@ -512,4 +575,110 @@ describe('executeBulkOperation', () => {
 
     expect(renderSuccess).not.toHaveBeenCalled()
   })
+
+  test('renders warning when completed operation results contain userErrors', async () => {
+    const query = '{ products { edges { node { id } } } }'
+    const resultsWithErrors = '{"data":{"productUpdate":{"userErrors":[{"message":"invalid input"}]}},"__lineNumber":0}'
+
+    const initialResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
+      bulkOperation: createdBulkOperation,
+      userErrors: [],
+    }
+    const completedOperation = {
+      ...createdBulkOperation,
+      status: 'COMPLETED' as const,
+      url: 'https://example.com/download',
+      objectCount: '1',
+    }
+
+    vi.mocked(runBulkOperationQuery).mockResolvedValue(initialResponse)
+    vi.mocked(watchBulkOperation).mockResolvedValue(completedOperation)
+    vi.mocked(downloadBulkOperationResults).mockResolvedValue(resultsWithErrors)
+
+    await executeBulkOperation({
+      remoteApp: mockRemoteApp,
+      storeFqdn,
+      query,
+      watch: true,
+    })
+
+    expect(renderWarning).toHaveBeenCalledWith(
+      expect.objectContaining({
+        headline: 'Bulk operation completed with errors.',
+        body: 'Check results for error details.',
+      }),
+    )
+    expect(renderSuccess).not.toHaveBeenCalled()
+  })
+
+  test('renders success when completed operation results have no userErrors', async () => {
+    const query = '{ products { edges { node { id } } } }'
+    const resultsWithoutErrors = '{"data":{"productUpdate":{"product":{"id":"123"},"userErrors":[]}},"__lineNumber":0}'
+
+    const initialResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
+      bulkOperation: createdBulkOperation,
+      userErrors: [],
+    }
+    const completedOperation = {
+      ...createdBulkOperation,
+      status: 'COMPLETED' as const,
+      url: 'https://example.com/download',
+      objectCount: '1',
+    }
+
+    vi.mocked(runBulkOperationQuery).mockResolvedValue(initialResponse)
+    vi.mocked(watchBulkOperation).mockResolvedValue(completedOperation)
+    vi.mocked(downloadBulkOperationResults).mockResolvedValue(resultsWithoutErrors)
+
+    await executeBulkOperation({
+      remoteApp: mockRemoteApp,
+      storeFqdn,
+      query,
+      watch: true,
+    })
+
+    expect(renderSuccess).toHaveBeenCalledWith(
+      expect.objectContaining({
+        headline: expect.stringContaining('Bulk operation succeeded'),
+      }),
+    )
+    expect(renderWarning).not.toHaveBeenCalled()
+  })
+
+  test('renders warning when results written to file contain userErrors', async () => {
+    const query = '{ products { edges { node { id } } } }'
+    const outputFile = '/tmp/results.jsonl'
+    const resultsWithErrors = '{"data":{"productUpdate":{"userErrors":[{"message":"invalid input"}]}},"__lineNumber":0}'
+
+    const initialResponse: BulkOperationRunQueryMutation['bulkOperationRunQuery'] = {
+      bulkOperation: createdBulkOperation,
+      userErrors: [],
+    }
+    const completedOperation = {
+      ...createdBulkOperation,
+      status: 'COMPLETED' as const,
+      url: 'https://example.com/download',
+      objectCount: '1',
+    }
+
+    vi.mocked(runBulkOperationQuery).mockResolvedValue(initialResponse)
+    vi.mocked(watchBulkOperation).mockResolvedValue(completedOperation)
+    vi.mocked(downloadBulkOperationResults).mockResolvedValue(resultsWithErrors)
+
+    await executeBulkOperation({
+      remoteApp: mockRemoteApp,
+      storeFqdn,
+      query,
+      watch: true,
+      outputFile,
+    })
+
+    expect(writeFile).toHaveBeenCalledWith(outputFile, resultsWithErrors)
+    expect(renderWarning).toHaveBeenCalledWith(
+      expect.objectContaining({
+        headline: 'Bulk operation completed with errors.',
+        body: `Results written to ${outputFile}. Check file for error details.`,
+      }),
+    )
+  })
 })

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

@@ -1,6 +1,6 @@
 import {runBulkOperationQuery} from './run-query.js'
 import {runBulkOperationMutation} from './run-mutation.js'
-import {watchBulkOperation, type BulkOperation} from './watch-bulk-operation.js'
+import {watchBulkOperation, quickWatchBulkOperation, type BulkOperation} from './watch-bulk-operation.js'
 import {formatBulkOperationStatus} from './format-bulk-operation-status.js'
 import {downloadBulkOperationResults} from './download-bulk-operation-results.js'
 import {OrganizationApp} from '../../models/organization.js'
@@ -91,7 +91,8 @@ export async function executeBulkOperation(input: ExecuteBulkOperationInput): Pr
         await renderBulkOperationResult(operation, outputFile)
       }
     } else {
-      await renderBulkOperationResult(createdOperation, outputFile)
+      const operation = await quickWatchBulkOperation(adminSession, createdOperation.id)
+      await renderBulkOperationResult(operation, outputFile)
     }
   } else {
     renderWarning({
@@ -123,16 +124,38 @@ async function renderBulkOperationResult(operation: BulkOperation, outputFile?:
         customSections,
       })
       break
+    case 'RUNNING':
+      renderSuccess({
+        headline: 'Bulk operation is running.',
+        body: statusCommandHelpMessage(operation.id),
+        customSections,
+      })
+      break
     case 'COMPLETED':
       if (operation.url) {
         const results = await downloadBulkOperationResults(operation.url)
+        const hasUserErrors = resultsContainUserErrors(results)
 
         if (outputFile) {
           await writeFile(outputFile, results)
-          renderSuccess({headline, body: [`Results written to ${outputFile}`], customSections})
         } else {
           outputResult(results)
-          renderSuccess({headline, customSections})
+        }
+
+        if (hasUserErrors) {
+          renderWarning({
+            headline: 'Bulk operation completed with errors.',
+            body: outputFile
+              ? `Results written to ${outputFile}. Check file for error details.`
+              : 'Check results for error details.',
+            customSections,
+          })
+        } else {
+          renderSuccess({
+            headline,
+            body: outputFile ? [`Results written to ${outputFile}`] : undefined,
+            customSections,
+          })
         }
       } else {
         renderSuccess({headline, customSections})
@@ -144,6 +167,20 @@ async function renderBulkOperationResult(operation: BulkOperation, outputFile?:
   }
 }
 
+function resultsContainUserErrors(results: string): boolean {
+  const lines = results.trim().split('\n')
+
+  return lines.some((line) => {
+    try {
+      const parsed = JSON.parse(line)
+      const operationResult = Object.values(parsed.data)[0] as any
+      return Array.isArray(operationResult?.userErrors) && operationResult.userErrors.length > 0
+    } catch {
+      return true
+    }
+  })
+}
+
 function validateGraphQLDocument(graphqlOperation: string, variablesJsonl?: string): void {
   const document = parse(graphqlOperation)
   const operationDefinitions = document.definitions.filter((def) => def.kind === 'OperationDefinition')