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

Add logging to Matrix channel and update refactor

Browse source 
Co-authored-by: hobbyistlabs-coder <267281733+hobbyistlabs-coder@users.noreply.github.com>
This commit is contained in:
google-labs-jules[bot] 2026-03-16 08:03:25 +00:00
parent e31ba85fae
commit 2af558cebd
2 changed files with 28 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
pkg/channels/matrix/events.go
View file

@ -136,6 +136,13 @@ func (c *MatrixChannel) handleMessageEvent(ctx context.Context, evt *event.Event
"is_group": fmt.Sprintf("%t", isGroup), "is_group": fmt.Sprintf("%t", isGroup),
"sender_raw": senderID, "sender_raw": senderID,
} }
logger.DebugCF("matrix", "Received message", map[string]any{
"sender_id": senderID,
"room_id": roomID,
"is_group": isGroup,
})
if replyTo := msgEvt.GetRelatesTo().GetReplyTo(); replyTo != "" { if replyTo := msgEvt.GetRelatesTo().GetReplyTo(); replyTo != "" {
metadata["reply_to_msg_id"] = replyTo.String() metadata["reply_to_msg_id"] = replyTo.String()
} }

21
pkg/channels/matrix/messages.go
View file

@ -13,6 +13,7 @@ import (
"jane/pkg/bus" "jane/pkg/bus"
"jane/pkg/channels" "jane/pkg/channels"
"jane/pkg/logger"
) )
func markdownToHTML(md string) string { func markdownToHTML(md string) string {
@ -38,8 +39,16 @@ func (c *MatrixChannel) Send(ctx context.Context, msg bus.OutboundMessage) error
_, err := c.client.SendMessageEvent(ctx, roomID, event.EventMessage, c.messageContent(content)) _, err := c.client.SendMessageEvent(ctx, roomID, event.EventMessage, c.messageContent(content))
if err != nil { if err != nil {
logger.ErrorCF("matrix", "Failed to send message", map[string]any{
"room_id": roomID.String(),
"error": err.Error(),
})
return fmt.Errorf("matrix send: %w", channels.ErrTemporary) return fmt.Errorf("matrix send: %w", channels.ErrTemporary)
} }
logger.DebugCF("matrix", "Sent message", map[string]any{
"room_id": roomID.String(),
})
return nil return nil
} }
@ -93,5 +102,17 @@ func (c *MatrixChannel) EditMessage(ctx context.Context, chatID string, messageI
editContent.SetEdit(id.EventID(messageID)) editContent.SetEdit(id.EventID(messageID))
_, err := c.client.SendMessageEvent(ctx, roomID, event.EventMessage, editContent) _, err := c.client.SendMessageEvent(ctx, roomID, event.EventMessage, editContent)
if err != nil {
logger.ErrorCF("matrix", "Failed to edit message", map[string]any{
"room_id": roomID.String(),
"message_id": messageID,
"error": err.Error(),
})
} else {
logger.DebugCF("matrix", "Edited message", map[string]any{
"room_id": roomID.String(),
"message_id": messageID,
})
}
return err return err
} }