indexer-cli: add delete options all and status filter

graphprotocol · Nov 30, 2022 · 92831bc · 92831bc
1 parent 546d72c
commit 92831bc
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 11 deletions.
diff --git a/packages/indexer-cli/src/__tests__/references/indexer-help.stdout b/packages/indexer-cli/src/__tests__/references/indexer-help.stdout
@@ -25,7 +25,7 @@ Manage indexer configuration
   indexer actions queue              Queue an action item                                             
   indexer actions get                List one or more actions                                         
   indexer actions execute            Execute approved items in the action queue                       
-  indexer actions delete             Delete an item in the queue                                      
+  indexer actions delete             Delete one or many actions in the queue                          
   indexer actions cancel             Cancel an item in the queue                                      
   indexer actions approve            Approve an action item                                           
   indexer actions                    Manage indexer actions                                           

diff --git a/packages/indexer-cli/src/commands/indexer/actions/delete.ts b/packages/indexer-cli/src/commands/indexer/actions/delete.ts
@@ -4,27 +4,29 @@ import chalk from 'chalk'
 import { loadValidatedConfig } from '../../../config'
 import { createIndexerManagementClient } from '../../../client'
 import { fixParameters } from '../../../command-helpers'
-import { deleteActions } from '../../../actions'
+import { deleteActions, fetchActions } from '../../../actions'
 
 const HELP = `
+${chalk.bold('graph indexer actions delete')} [options] all
 ${chalk.bold('graph indexer actions delete')} [options] [<actionID1> ...]
 
 ${chalk.dim('Options:')}
 
-  -h, --help                    Show usage information
-  -o, --output table|json|yaml  Choose the output format: table (default), JSON, or YAML 
+  -h, --help                                                        Show usage information
+      --status  queued|approved|pending|success|failed|canceled     Filter by status
+  -o, --output table|json|yaml                                      Choose the output format: table (default), JSON, or YAML 
 `
 
 module.exports = {
   name: 'delete',
   alias: [],
-  description: 'Delete an item in the queue',
+  description: 'Delete one or many actions in the queue',
   run: async (toolbox: GluegunToolbox) => {
     const { print, parameters } = toolbox
 
     const inputSpinner = toolbox.print.spin('Processing inputs')
 
-    const { h, help, o, output } = parameters.options
+    const { status, h, help, o, output } = parameters.options
     const [...actionIDs] = fixParameters(parameters, { h, help }) || []
 
     const outputFormat = o || output || 'table'
@@ -35,20 +37,37 @@ module.exports = {
       return
     }
 
-    let numericActionIDs: number[]
-
     try {
       if (!['json', 'yaml', 'table'].includes(outputFormat)) {
         throw Error(
           `Invalid output format "${outputFormat}", must be one of ['json', 'yaml', 'table']`,
         )
       }
 
-      if (!actionIDs || actionIDs.length === 0) {
-        throw Error(`Missing required argument: 'actionID'`)
+      if (
+        status &&
+        !['queued', 'approved', 'pending', 'success', 'failed', 'canceled'].includes(
+          status,
+        )
+      ) {
+        throw Error(
+          `Invalid '--status' provided, must be one of ['queued', 'approved', 'pending', 'success', 'failed', 'canceled]`,
+        )
+      }
+
+      if (actionIDs[0] == 'all') {
+        if (status || actionIDs.length > 1) {
+          throw Error(
+            `Invalid query, cannot specify '--status' filter or multiple ids in addition to 'action = all'`,
+          )
+        }
       }
 
-      numericActionIDs = actionIDs.map(action => +action)
+      if (!status && (!actionIDs || actionIDs.length === 0)) {
+        throw Error(
+          `Required at least one argument: actionID(s), 'all', or '--status' filter`,
+        )
+      }
 
       inputSpinner.succeed('Processed input parameters')
     } catch (error) {
@@ -63,6 +82,13 @@ module.exports = {
       const config = loadValidatedConfig()
       const client = await createIndexerManagementClient({ url: config.api })
 
+      const numericActionIDs: number[] =
+        actionIDs[0] == 'all'
+          ? (await fetchActions(client, {})).map(action => action.id)
+          : status
+          ? (await fetchActions(client, { status })).map(action => action.id)
+          : actionIDs.map(action => +action)
+
       const numDeleted = await deleteActions(client, numericActionIDs)
 
       actionSpinner.succeed(`${numDeleted} actions deleted`)