Add gt park/resume commands for async gate coordination (gt-twjr5.5)
Implements agent parking and resumption on gates: - gt park <gate-id>: Parks work on a gate, saves context - gt resume: Checks for cleared gates and restores work - gt gate wake: Sends wake mail to waiters when gate closes These commands enable agents to safely suspend work while waiting for external conditions (timers, CI, human approval) and resume when gates clear. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Steve Yegge
249
internal/cmd/park.go
Normal file
249
internal/cmd/park.go
Normal file
@@ -0,0 +1,249 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"os"
|
||||
"os/exec"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/spf13/cobra"
|
||||
"github.com/steveyegge/gastown/internal/mail"
|
||||
"github.com/steveyegge/gastown/internal/style"
|
||||
"github.com/steveyegge/gastown/internal/wisp"
|
||||
"github.com/steveyegge/gastown/internal/workspace"
|
||||
)
|
||||
|
||||
// Park command parks work on a gate, allowing agent to exit safely.
|
||||
// When the gate closes, waiters are notified and can resume.
|
||||
|
||||
var parkCmd = &cobra.Command{
|
||||
Use: "park <gate-id>",
|
||||
GroupID: GroupWork,
|
||||
Short: "Park work on a gate for async resumption",
|
||||
Long: `Park current work on a gate, allowing the agent to exit safely.
|
||||
|
||||
When you need to wait for an external condition (timer, CI, human approval),
|
||||
park your work on a gate. When the gate closes, you'll receive wake mail.
|
||||
|
||||
The park command:
|
||||
1. Saves your current hook state (molecule/bead you're working on)
|
||||
2. Adds you as a waiter on the gate
|
||||
3. Stores context notes in the parked state
|
||||
|
||||
After parking, you can exit the session safely. Use 'gt resume' to check
|
||||
for cleared gates and continue work.
|
||||
|
||||
Examples:
|
||||
# Create a timer gate and park work on it
|
||||
bd gate create --await timer:30m --title "Coffee break"
|
||||
gt park <gate-id> -m "Taking a break, will resume auth work"
|
||||
|
||||
# Park on a human approval gate
|
||||
bd gate create --await human:deploy-approval --notify ops/
|
||||
gt park <gate-id> -m "Deploy staged, awaiting approval"
|
||||
|
||||
# Park on a GitHub Actions gate
|
||||
bd gate create --await gh:run:123456789
|
||||
gt park <gate-id> -m "Waiting for CI to complete"`,
|
||||
Args: cobra.ExactArgs(1),
|
||||
RunE: runPark,
|
||||
}
|
||||
|
||||
var (
|
||||
parkMessage string
|
||||
parkDryRun bool
|
||||
)
|
||||
|
||||
func init() {
|
||||
parkCmd.Flags().StringVarP(&parkMessage, "message", "m", "", "Context notes for resumption")
|
||||
parkCmd.Flags().BoolVarP(&parkDryRun, "dry-run", "n", false, "Show what would be done without executing")
|
||||
rootCmd.AddCommand(parkCmd)
|
||||
}
|
||||
|
||||
// ParkedWork represents work state saved when parking on a gate.
|
||||
type ParkedWork struct {
|
||||
// AgentID is the agent that parked (e.g., "gastown/crew/max")
|
||||
AgentID string `json:"agent_id"`
|
||||
|
||||
// GateID is the gate we're parked on
|
||||
GateID string `json:"gate_id"`
|
||||
|
||||
// BeadID is the bead/molecule we were working on
|
||||
BeadID string `json:"bead_id,omitempty"`
|
||||
|
||||
// Formula is the formula attached to the work (if any)
|
||||
Formula string `json:"formula,omitempty"`
|
||||
|
||||
// Context is additional context notes from the agent
|
||||
Context string `json:"context,omitempty"`
|
||||
|
||||
// ParkedAt is when the work was parked
|
||||
ParkedAt time.Time `json:"parked_at"`
|
||||
}
|
||||
|
||||
func runPark(cmd *cobra.Command, args []string) error {
|
||||
gateID := args[0]
|
||||
|
||||
// Verify gate exists and is open
|
||||
gateCheck := exec.Command("bd", "gate", "show", gateID, "--json")
|
||||
gateOutput, err := gateCheck.Output()
|
||||
if err != nil {
|
||||
return fmt.Errorf("gate '%s' not found or not accessible", gateID)
|
||||
}
|
||||
|
||||
// Parse gate info to verify it's open
|
||||
var gateInfo struct {
|
||||
ID string `json:"id"`
|
||||
Status string `json:"status"`
|
||||
}
|
||||
if err := json.Unmarshal(gateOutput, &gateInfo); err != nil {
|
||||
return fmt.Errorf("parsing gate info: %w", err)
|
||||
}
|
||||
if gateInfo.Status == "closed" {
|
||||
return fmt.Errorf("gate '%s' is already closed - nothing to park on", gateID)
|
||||
}
|
||||
|
||||
// Detect agent identity
|
||||
agentID, _, cloneRoot, err := resolveSelfTarget()
|
||||
if err != nil {
|
||||
return fmt.Errorf("detecting agent identity: %w", err)
|
||||
}
|
||||
|
||||
// Read current hook state (if any)
|
||||
var beadID, formula, hookContext string
|
||||
if hook, err := wisp.ReadHook(cloneRoot, agentID); err == nil {
|
||||
beadID = hook.BeadID
|
||||
formula = hook.Formula
|
||||
hookContext = hook.Context
|
||||
}
|
||||
|
||||
// Build context combining hook context and new message
|
||||
context := ""
|
||||
if hookContext != "" && parkMessage != "" {
|
||||
context = hookContext + "\n---\n" + parkMessage
|
||||
} else if hookContext != "" {
|
||||
context = hookContext
|
||||
} else if parkMessage != "" {
|
||||
context = parkMessage
|
||||
}
|
||||
|
||||
// Create parked work record
|
||||
parked := &ParkedWork{
|
||||
AgentID: agentID,
|
||||
GateID: gateID,
|
||||
BeadID: beadID,
|
||||
Formula: formula,
|
||||
Context: context,
|
||||
ParkedAt: time.Now(),
|
||||
}
|
||||
|
||||
if parkDryRun {
|
||||
fmt.Printf("Would park on gate %s\n", gateID)
|
||||
fmt.Printf(" Agent: %s\n", agentID)
|
||||
if beadID != "" {
|
||||
fmt.Printf(" Bead: %s\n", beadID)
|
||||
}
|
||||
if formula != "" {
|
||||
fmt.Printf(" Formula: %s\n", formula)
|
||||
}
|
||||
if context != "" {
|
||||
fmt.Printf(" Context: %s\n", context)
|
||||
}
|
||||
fmt.Printf("Would add %s as waiter on gate\n", agentID)
|
||||
return nil
|
||||
}
|
||||
|
||||
// Add agent as waiter on the gate
|
||||
waitCmd := exec.Command("bd", "gate", "wait", gateID, "--notify", agentID)
|
||||
if err := waitCmd.Run(); err != nil {
|
||||
// Not fatal - might already be a waiter
|
||||
fmt.Printf("%s Note: could not add as waiter (may already be registered)\n", style.Dim.Render("⚠"))
|
||||
}
|
||||
|
||||
// Store parked work in a file (alongside hook files)
|
||||
parkedPath := wisp.WispPath(cloneRoot, fmt.Sprintf("parked-%s.json", strings.ReplaceAll(agentID, "/", "_")))
|
||||
parkedJSON, err := json.MarshalIndent(parked, "", " ")
|
||||
if err != nil {
|
||||
return fmt.Errorf("marshaling parked work: %w", err)
|
||||
}
|
||||
if err := os.WriteFile(parkedPath, parkedJSON, 0644); err != nil {
|
||||
return fmt.Errorf("writing parked state: %w", err)
|
||||
}
|
||||
|
||||
fmt.Printf("%s Parked work on gate %s\n", style.Bold.Render("🅿️"), gateID)
|
||||
if beadID != "" {
|
||||
fmt.Printf(" Working on: %s\n", beadID)
|
||||
}
|
||||
if context != "" {
|
||||
// Truncate for display
|
||||
displayContext := context
|
||||
if len(displayContext) > 80 {
|
||||
displayContext = displayContext[:77] + "..."
|
||||
}
|
||||
fmt.Printf(" Context: %s\n", displayContext)
|
||||
}
|
||||
fmt.Printf("\n%s You can now safely exit. Run 'gt resume' to check for cleared gates.\n",
|
||||
style.Dim.Render("→"))
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// readParkedWork reads the parked work state for an agent.
|
||||
func readParkedWork(cloneRoot, agentID string) (*ParkedWork, error) {
|
||||
parkedPath := wisp.WispPath(cloneRoot, fmt.Sprintf("parked-%s.json", strings.ReplaceAll(agentID, "/", "_")))
|
||||
data, err := os.ReadFile(parkedPath)
|
||||
if os.IsNotExist(err) {
|
||||
return nil, nil
|
||||
}
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
var parked ParkedWork
|
||||
if err := json.Unmarshal(data, &parked); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return &parked, nil
|
||||
}
|
||||
|
||||
// clearParkedWork removes the parked work state for an agent.
|
||||
func clearParkedWork(cloneRoot, agentID string) error {
|
||||
parkedPath := wisp.WispPath(cloneRoot, fmt.Sprintf("parked-%s.json", strings.ReplaceAll(agentID, "/", "_")))
|
||||
err := os.Remove(parkedPath)
|
||||
if os.IsNotExist(err) {
|
||||
return nil
|
||||
}
|
||||
return err
|
||||
}
|
||||
|
||||
// sendGateWakeMail sends wake mail to all waiters when a gate closes.
|
||||
// This should be called after gate close (from Deacon or gate eval).
|
||||
func sendGateWakeMail(gateID, closeReason string, waiters []string) error {
|
||||
// Find town root for mail routing
|
||||
townRoot, err := workspace.FindFromCwd()
|
||||
if err != nil {
|
||||
return fmt.Errorf("finding town root: %w", err)
|
||||
}
|
||||
|
||||
router := mail.NewRouter(townRoot)
|
||||
|
||||
for _, waiter := range waiters {
|
||||
msg := &mail.Message{
|
||||
From: "deacon/",
|
||||
To: waiter,
|
||||
Subject: fmt.Sprintf("🚦 GATE CLEARED: %s", gateID),
|
||||
Body: fmt.Sprintf("Gate %s has closed.\n\nReason: %s\n\nRun 'gt resume' to continue your parked work.", gateID, closeReason),
|
||||
Type: mail.TypeNotification,
|
||||
Priority: mail.PriorityHigh,
|
||||
Wisp: true,
|
||||
}
|
||||
if err := router.Send(msg); err != nil {
|
||||
// Log but don't fail on individual send errors
|
||||
fmt.Fprintf(os.Stderr, "Warning: failed to send wake mail to %s: %v\n", waiter, err)
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
Reference in New Issue
Block a user