Skip to content

feat: add --status flag to intents cleanup command #83

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
George-iam merged 2 commits into from
Apr 3, 2026
+22 −5
Merged

feat: add --status flag to intents cleanup command #83

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a4212f8
feat: add --status flag to intents cleanup command
George-iam Apr 3, 2026
854ae83
feat: bump cleanup timeout to 300s for bulk operations
George-iam Apr 3, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
27 changes: 22 additions & 5 deletions cmd/axme/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1784,27 +1784,43 @@ func newIntentsCleanupCmd(rt *runtime) *cobra.Command {
var dryRun bool
var reason string
var limitN int
var statusFilter string
cmd := &cobra.Command{
Use: "cleanup",
Short: "Cancel stuck/zombie intents that have been inactive for too long",
Long: `Bulk-cancel intents stuck in non-terminal status (DELIVERED, WAITING, etc.)
for longer than the specified duration.
Long: `Bulk-cancel intents stuck in non-terminal status for longer than the
specified duration.

Use --dry-run (default) to preview what would be canceled.
Use --status to target specific statuses (comma-separated).

Examples:
axme intents cleanup --older-than 24 --dry-run
axme intents cleanup --older-than 12 --dry-run=false
axme intents cleanup --status IN_PROGRESS,WAITING --older-than 8 --dry-run=false
axme intents cleanup --older-than 1 --dry-run=false --reason "test cleanup"`,
RunE: func(cmd *cobra.Command, args []string) error {
ctx := rt.effectiveContext()
// Parse comma-separated status filter into a slice
var statuses []string
for _, s := range strings.Split(statusFilter, ",") {
s = strings.TrimSpace(s)
if s != "" {
statuses = append(statuses, s)
}
}
payload := map[string]any{
"older_than_hours": olderThan,
"dry_run": dryRun,
"reason": reason,
"limit": limitN,
"status_filter": statuses,
}
// Use extended timeout for bulk cancel (may process hundreds of intents)
origClient := rt.httpClient
rt.httpClient = &http.Client{Timeout: 300 * time.Second}
status, body, _, err := rt.request(cmd.Context(), ctx, "POST", "/v1/intents/bulk-cancel", nil, payload, true)
rt.httpClient = origClient
if err != nil {
return err
}
Expand All @@ -1822,7 +1838,7 @@ Examples:

if dryRun {
count := int(asFloat(body["would_cancel"]))
fmt.Printf("Dry run: %d intents would be canceled\n", count)
fmt.Printf("Dry run: %d intents would be canceled (statuses: %s)\n", count, statusFilter)
ids := asSlice(body["intent_ids"])
for _, id := range ids {
fmt.Printf(" %s\n", asString(id))
Expand All @@ -1832,15 +1848,16 @@ Examples:
}
} else {
count := int(asFloat(body["canceled"]))
fmt.Printf("✓ Canceled %d zombie intents (reason: %s)\n", count, reason)
fmt.Printf("Canceled %d zombie intents (reason: %s)\n", count, reason)
}
return nil
},
}
cmd.Flags().Float64Var(&olderThan, "older-than", 24, "Cancel intents inactive for more than this many hours")
cmd.Flags().BoolVar(&dryRun, "dry-run", true, "Preview only — do not actually cancel")
cmd.Flags().BoolVar(&dryRun, "dry-run", true, "Preview only - do not actually cancel")
cmd.Flags().StringVar(&reason, "reason", "zombie cleanup via CLI", "Cancellation reason")
cmd.Flags().IntVar(&limitN, "limit", 500, "Maximum number of intents to cancel")
cmd.Flags().StringVar(&statusFilter, "status", "DELIVERED,WAITING,IN_PROGRESS,SUBMITTED,ACKNOWLEDGED", "Comma-separated statuses to target")
return cmd
}

Expand Down
Loading