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

Rebuilt after the refactoring of the base channel implementation.

Browse source
This commit is contained in:
Aditya Kalro 2026-02-25 20:50:40 -08:00
parent 04806bffe3
commit 49612adf8a
1 changed files with 16 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
pkg/channels/whatsapp_native.go
View file

@ -146,7 +146,7 @@ func (c *WhatsAppNativeChannel) Start(ctx context.Context) error {
} }
c.runCtx, c.runCancel = context.WithCancel(ctx) c.runCtx, c.runCancel = context.WithCancel(ctx)
c.setRunning(true) c.SetRunning(true)
logger.InfoCF("channels", "WhatsApp native channel connected", nil) logger.InfoCF("channels", "WhatsApp native channel connected", nil)
return nil return nil
} }
@ -169,7 +169,7 @@ func (c *WhatsAppNativeChannel) Stop(ctx context.Context) error {
if container != nil { if container != nil {
_ = container.Close() _ = container.Close()
} }
c.setRunning(false) c.SetRunning(false)
return nil return nil
} }
@ -267,8 +267,21 @@ func (c *WhatsAppNativeChannel) handleIncoming(evt *events.Message) {
metadata["peer_id"] = senderID metadata["peer_id"] = senderID
} }
peerKind := "direct"
if evt.Info.Chat.Server == types.GroupServer {
peerKind = "group"
}
peer := bus.Peer{Kind: peerKind, ID: chatID}
messageID := evt.Info.ID
sender := bus.SenderInfo{
Platform: "whatsapp",
PlatformID: senderID,
CanonicalID: "whatsapp:" + senderID,
DisplayName: evt.Info.PushName,
}
logger.DebugCF("channels", "WhatsApp message received", map[string]any{"sender_id": senderID, "content_preview": utils.Truncate(content, 50)}) logger.DebugCF("channels", "WhatsApp message received", map[string]any{"sender_id": senderID, "content_preview": utils.Truncate(content, 50)})
c.HandleMessage(senderID, chatID, content, mediaPaths, metadata) c.HandleMessage(c.runCtx, peer, messageID, senderID, chatID, content, mediaPaths, metadata, sender)
} }
func (c *WhatsAppNativeChannel) Send(ctx context.Context, msg bus.OutboundMessage) error { func (c *WhatsAppNativeChannel) Send(ctx context.Context, msg bus.OutboundMessage) error {