diff --git a/internal/mail/mailbox.go b/internal/mail/mailbox.go index 14dd7b77..d9554824 100644 --- a/internal/mail/mailbox.go +++ b/internal/mail/mailbox.go @@ -72,8 +72,8 @@ func (m *Mailbox) List() ([]*Message, error) { } func (m *Mailbox) listBeads() ([]*Message, error) { - // bd mail inbox --json - cmd := exec.Command("bd", "mail", "inbox", "--json") + // bd message inbox --json + cmd := exec.Command("bd", "message", "inbox", "--json") cmd.Dir = m.workDir cmd.Env = append(cmd.Environ(), "BD_IDENTITY="+m.identity) @@ -173,7 +173,7 @@ func (m *Mailbox) Get(id string) (*Message, error) { } func (m *Mailbox) getBeads(id string) (*Message, error) { - cmd := exec.Command("bd", "mail", "read", id, "--json") + cmd := exec.Command("bd", "message", "read", id, "--json") cmd.Dir = m.workDir var stdout, stderr bytes.Buffer @@ -221,7 +221,7 @@ func (m *Mailbox) MarkRead(id string) error { } func (m *Mailbox) markReadBeads(id string) error { - cmd := exec.Command("bd", "mail", "ack", id) + cmd := exec.Command("bd", "message", "ack", id) cmd.Dir = m.workDir var stderr bytes.Buffer diff --git a/internal/mail/router.go b/internal/mail/router.go index 08268ada..a6c17e3c 100644 --- a/internal/mail/router.go +++ b/internal/mail/router.go @@ -25,22 +25,20 @@ func NewRouter(workDir string) *Router { } } -// Send delivers a message via beads mail. +// Send delivers a message via beads message. func (r *Router) Send(msg *Message) error { // Convert addresses to beads identities toIdentity := addressToIdentity(msg.To) - fromIdentity := addressToIdentity(msg.From) - // Build command: bd mail send -s -m --identity - args := []string{"mail", "send", toIdentity, + // Build command: bd message send -s + // Note: sender identity comes from BEADS_AGENT_NAME env var + args := []string{"message", "send", toIdentity, msg.Body, "-s", msg.Subject, - "-m", msg.Body, - "--identity", fromIdentity, } - // Add --urgent flag for high priority + // Add importance flag for high priority if msg.Priority == PriorityHigh { - args = append(args, "--urgent") + args = append(args, "--importance", "urgent") } cmd := exec.Command("bd", args...)