refactor: Remove deprecated gt deacon pending command
The functionality now lives exclusively in gt spawn pending. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
@@ -111,24 +111,8 @@ This command is typically called by the daemon during cold startup.`,
|
||||
RunE: runDeaconTriggerPending,
|
||||
}
|
||||
|
||||
var deaconPendingCmd = &cobra.Command{
|
||||
Use: "pending [session-to-clear]",
|
||||
Short: "[DEPRECATED] Use 'gt spawn pending' instead",
|
||||
Long: `DEPRECATED: Use 'gt spawn pending' instead.
|
||||
|
||||
This command has been moved to 'gt spawn pending' since pending spawn
|
||||
tracking is not Deacon-specific - anyone might need to observe pending
|
||||
polecats (Mayor, humans, debugging, etc.).
|
||||
|
||||
The functionality is identical:
|
||||
gt spawn pending # List all pending with output
|
||||
gt spawn pending gastown/p-abc123 # Clear specific session from pending`,
|
||||
Args: cobra.MaximumNArgs(1),
|
||||
RunE: runDeaconPending,
|
||||
}
|
||||
|
||||
var triggerTimeout time.Duration
|
||||
var pendingLines int
|
||||
|
||||
func init() {
|
||||
deaconCmd.AddCommand(deaconStartCmd)
|
||||
@@ -138,16 +122,11 @@ func init() {
|
||||
deaconCmd.AddCommand(deaconRestartCmd)
|
||||
deaconCmd.AddCommand(deaconHeartbeatCmd)
|
||||
deaconCmd.AddCommand(deaconTriggerPendingCmd)
|
||||
deaconCmd.AddCommand(deaconPendingCmd)
|
||||
|
||||
// Flags for trigger-pending
|
||||
deaconTriggerPendingCmd.Flags().DurationVar(&triggerTimeout, "timeout", 2*time.Second,
|
||||
"Timeout for checking if Claude is ready")
|
||||
|
||||
// Flags for pending
|
||||
deaconPendingCmd.Flags().IntVarP(&pendingLines, "lines", "n", 15,
|
||||
"Number of terminal lines to capture per session")
|
||||
|
||||
rootCmd.AddCommand(deaconCmd)
|
||||
}
|
||||
|
||||
@@ -409,107 +388,3 @@ func runDeaconTriggerPending(cmd *cobra.Command, args []string) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
// runDeaconPending shows pending spawns with captured output for AI observation.
|
||||
// This is the ZFC-compliant way for Deacon to observe polecats.
|
||||
func runDeaconPending(cmd *cobra.Command, args []string) error {
|
||||
townRoot, err := workspace.FindFromCwdOrError()
|
||||
if err != nil {
|
||||
return fmt.Errorf("not in a Gas Town workspace: %w", err)
|
||||
}
|
||||
|
||||
// If session argument provided, clear it from pending
|
||||
if len(args) == 1 {
|
||||
return clearPendingSession(townRoot, args[0])
|
||||
}
|
||||
|
||||
// Step 1: Check inbox for new POLECAT_STARTED messages
|
||||
pending, err := polecat.CheckInboxForSpawns(townRoot)
|
||||
if err != nil {
|
||||
return fmt.Errorf("checking inbox: %w", err)
|
||||
}
|
||||
|
||||
if len(pending) == 0 {
|
||||
fmt.Printf("%s No pending spawns\n", style.Dim.Render("○"))
|
||||
return nil
|
||||
}
|
||||
|
||||
t := tmux.NewTmux()
|
||||
|
||||
fmt.Printf("%s Pending spawns (%d):\n\n", style.Bold.Render("●"), len(pending))
|
||||
|
||||
for i, ps := range pending {
|
||||
// Check if session still exists
|
||||
running, err := t.HasSession(ps.Session)
|
||||
if err != nil {
|
||||
fmt.Printf("Session: %s\n", ps.Session)
|
||||
fmt.Printf(" Status: error checking session: %v\n\n", err)
|
||||
continue
|
||||
}
|
||||
|
||||
if !running {
|
||||
fmt.Printf("Session: %s\n", ps.Session)
|
||||
fmt.Printf(" Status: session no longer exists\n\n")
|
||||
continue
|
||||
}
|
||||
|
||||
// Capture terminal output for AI analysis
|
||||
output, err := t.CapturePane(ps.Session, pendingLines)
|
||||
if err != nil {
|
||||
fmt.Printf("Session: %s\n", ps.Session)
|
||||
fmt.Printf(" Status: error capturing output: %v\n\n", err)
|
||||
continue
|
||||
}
|
||||
|
||||
// Print session info
|
||||
fmt.Printf("Session: %s\n", ps.Session)
|
||||
fmt.Printf(" Rig: %s\n", ps.Rig)
|
||||
fmt.Printf(" Polecat: %s\n", ps.Polecat)
|
||||
if ps.Issue != "" {
|
||||
fmt.Printf(" Issue: %s\n", ps.Issue)
|
||||
}
|
||||
fmt.Printf(" Spawned: %s ago\n", time.Since(ps.SpawnedAt).Round(time.Second))
|
||||
fmt.Printf(" Terminal output (last %d lines):\n", pendingLines)
|
||||
fmt.Println(strings.Repeat("─", 50))
|
||||
fmt.Println(output)
|
||||
fmt.Println(strings.Repeat("─", 50))
|
||||
|
||||
if i < len(pending)-1 {
|
||||
fmt.Println()
|
||||
}
|
||||
}
|
||||
|
||||
fmt.Println()
|
||||
fmt.Printf("%s To trigger a ready polecat:\n", style.Dim.Render("→"))
|
||||
fmt.Printf(" gt nudge <session> \"Begin.\"\n")
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// clearPendingSession removes a session from the pending list.
|
||||
func clearPendingSession(townRoot, session string) error {
|
||||
pending, err := polecat.LoadPending(townRoot)
|
||||
if err != nil {
|
||||
return fmt.Errorf("loading pending: %w", err)
|
||||
}
|
||||
|
||||
var remaining []*polecat.PendingSpawn
|
||||
found := false
|
||||
for _, ps := range pending {
|
||||
if ps.Session == session {
|
||||
found = true
|
||||
continue
|
||||
}
|
||||
remaining = append(remaining, ps)
|
||||
}
|
||||
|
||||
if !found {
|
||||
return fmt.Errorf("session %s not found in pending list", session)
|
||||
}
|
||||
|
||||
if err := polecat.SavePending(townRoot, remaining); err != nil {
|
||||
return fmt.Errorf("saving pending: %w", err)
|
||||
}
|
||||
|
||||
fmt.Printf("%s Cleared %s from pending list\n", style.Bold.Render("✓"), session)
|
||||
return nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user