b60f016955
Break down monolithic beads.go and mail.go into smaller, single-purpose files: beads package: - beads_agent.go: Agent-related bead operations - beads_delegation.go: Delegation bead handling - beads_dog.go: Dog pool operations - beads_merge_slot.go: Merge slot management - beads_mr.go: Merge request operations - beads_redirect.go: Redirect bead handling - beads_rig.go: Rig bead operations - beads_role.go: Role bead management cmd package: - mail_announce.go: Announcement subcommand - mail_check.go: Mail check subcommand - mail_identity.go: Identity management - mail_inbox.go: Inbox operations - mail_queue.go: Queue subcommand - mail_search.go: Search functionality - mail_send.go: Send subcommand - mail_thread.go: Thread operations Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
94 lines
2.2 KiB
Go
94 lines
2.2 KiB
Go
// Package beads provides dog agent bead management.
|
|
package beads
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
)
|
|
|
|
// CreateDogAgentBead creates an agent bead for a dog.
|
|
// Dogs use a different schema than other agents - they use labels for metadata.
|
|
// Returns the created issue or an error.
|
|
func (b *Beads) CreateDogAgentBead(name, location string) (*Issue, error) {
|
|
title := fmt.Sprintf("Dog: %s", name)
|
|
labels := []string{
|
|
"gt:agent",
|
|
"role_type:dog",
|
|
"rig:town",
|
|
"location:" + location,
|
|
}
|
|
|
|
args := []string{
|
|
"create", "--json",
|
|
"--role-type=dog",
|
|
"--title=" + title,
|
|
"--labels=" + strings.Join(labels, ","),
|
|
}
|
|
|
|
// Default actor from BD_ACTOR env var for provenance tracking
|
|
if actor := os.Getenv("BD_ACTOR"); actor != "" {
|
|
args = append(args, "--actor="+actor)
|
|
}
|
|
|
|
out, err := b.run(args...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var issue Issue
|
|
if err := json.Unmarshal(out, &issue); err != nil {
|
|
return nil, fmt.Errorf("parsing bd create output: %w", err)
|
|
}
|
|
|
|
return &issue, nil
|
|
}
|
|
|
|
// FindDogAgentBead finds the agent bead for a dog by name.
|
|
// Searches for agent beads with role_type:dog and matching title.
|
|
// Returns nil if not found.
|
|
func (b *Beads) FindDogAgentBead(name string) (*Issue, error) {
|
|
// List all agent beads and filter by role_type:dog label
|
|
issues, err := b.List(ListOptions{
|
|
Label: "gt:agent",
|
|
Status: "all",
|
|
Priority: -1, // No priority filter
|
|
})
|
|
if err != nil {
|
|
return nil, fmt.Errorf("listing agents: %w", err)
|
|
}
|
|
|
|
expectedTitle := fmt.Sprintf("Dog: %s", name)
|
|
for _, issue := range issues {
|
|
// Check title match and role_type:dog label
|
|
if issue.Title == expectedTitle {
|
|
for _, label := range issue.Labels {
|
|
if label == "role_type:dog" {
|
|
return issue, nil
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return nil, nil
|
|
}
|
|
|
|
// DeleteDogAgentBead finds and deletes the agent bead for a dog.
|
|
// Returns nil if the bead doesn't exist (idempotent).
|
|
func (b *Beads) DeleteDogAgentBead(name string) error {
|
|
issue, err := b.FindDogAgentBead(name)
|
|
if err != nil {
|
|
return fmt.Errorf("finding dog bead: %w", err)
|
|
}
|
|
if issue == nil {
|
|
return nil // Already doesn't exist - idempotent
|
|
}
|
|
|
|
err = b.DeleteAgentBead(issue.ID)
|
|
if err != nil {
|
|
return fmt.Errorf("deleting bead %s: %w", issue.ID, err)
|
|
}
|
|
return nil
|
|
}
|