opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(email): update Send signature to match Channel interface

Browse source 
Channel.Send now returns ([]string, error); update EmailChannel.Send
to match the interface so the build no longer fails.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
github-actions[bot] 2026-04-03 08:02:58 +02:00
parent 3b361f8de7
commit 561f483521
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
pkg/channels/email/email.go
View file

@ -86,17 +86,17 @@ func (c *EmailChannel) Stop(ctx context.Context) error {
// Send delivers an outbound message via SMTP. // Send delivers an outbound message via SMTP.
// msg.ChatID is the recipient email address. // msg.ChatID is the recipient email address.
func (c *EmailChannel) Send(ctx context.Context, msg bus.OutboundMessage) error { func (c *EmailChannel) Send(ctx context.Context, msg bus.OutboundMessage) ([]string, error) {
if !c.IsRunning() { if !c.IsRunning() {
return channels.ErrNotRunning return nil, channels.ErrNotRunning
} }
to := msg.ChatID to := msg.ChatID
if to == "" { if to == "" {
return fmt.Errorf("chat ID (recipient address) is empty: %w", channels.ErrSendFailed) return nil, fmt.Errorf("chat ID (recipient address) is empty: %w", channels.ErrSendFailed)
} }
if strings.TrimSpace(msg.Content) == "" { if strings.TrimSpace(msg.Content) == "" {
return nil return nil, nil
} }
subject := c.config.DefaultSubject subject := c.config.DefaultSubject
@ -128,24 +128,24 @@ func (c *EmailChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
tlsCfg := &tls.Config{ServerName: c.config.SMTPHost} tlsCfg := &tls.Config{ServerName: c.config.SMTPHost}
conn, err := tls.Dial("tcp", addr, tlsCfg) conn, err := tls.Dial("tcp", addr, tlsCfg)
if err != nil { if err != nil {
return fmt.Errorf("smtp tls dial: %w", channels.ErrTemporary) return nil, fmt.Errorf("smtp tls dial: %w", channels.ErrTemporary)
} }
client, err := smtp.NewClient(conn, c.config.SMTPHost) client, err := smtp.NewClient(conn, c.config.SMTPHost)
if err != nil { if err != nil {
return fmt.Errorf("smtp new client: %w", channels.ErrTemporary) return nil, fmt.Errorf("smtp new client: %w", channels.ErrTemporary)
} }
defer client.Close() defer client.Close()
if err := sendViaSMTPClient(client, auth, c.config.SMTPFrom, to, []byte(body)); err != nil { if err := sendViaSMTPClient(client, auth, c.config.SMTPFrom, to, []byte(body)); err != nil {
return err return nil, err
} }
} else { } else {
if err := smtp.SendMail(addr, auth, c.config.SMTPFrom, []string{to}, []byte(body)); err != nil { if err := smtp.SendMail(addr, auth, c.config.SMTPFrom, []string{to}, []byte(body)); err != nil {
return fmt.Errorf("smtp send: %w: %w", err, channels.ErrTemporary) return nil, fmt.Errorf("smtp send: %w: %w", err, channels.ErrTemporary)
} }
} }
logger.DebugCF("email", "Message sent", map[string]any{"to": to}) logger.DebugCF("email", "Message sent", map[string]any{"to": to})
return nil return nil, nil
} }
func sendViaSMTPClient(client *smtp.Client, auth smtp.Auth, from, to string, body []byte) error { func sendViaSMTPClient(client *smtp.Client, auth smtp.Auth, from, to string, body []byte) error {