handlematrix: implement account data interfaces

Author: tulir

go.mod

@@ -9,7 +9,7 @@ require (
 	github.com/rs/zerolog v1.34.0
 	go.mau.fi/util v0.9.2-0.20251001114608-d99877b9cc10
 	go.mau.fi/webp v0.2.0
-	go.mau.fi/whatsmeow v0.0.0-20250930215512-38f9aaa3ba7c
+	go.mau.fi/whatsmeow v0.0.0-20251002120845-b3cd0a5002d4
 	golang.org/x/image v0.31.0
 	golang.org/x/net v0.44.0
 	golang.org/x/sync v0.17.0

go.sum

@@ -81,8 +81,8 @@ go.mau.fi/util v0.9.2-0.20251001114608-d99877b9cc10 h1:EvX/di02gOriKN0xGDJuQ5mgi
 go.mau.fi/util v0.9.2-0.20251001114608-d99877b9cc10/go.mod h1:M0bM9SyaOWJniaHs9hxEzz91r5ql6gYq6o1q5O1SsjQ=
 go.mau.fi/webp v0.2.0 h1:QVMenHw7JDb4vall5sV75JNBQj9Hw4u8AKbi1QetHvg=
 go.mau.fi/webp v0.2.0/go.mod h1:VSg9MyODn12Mb5pyG0NIyNFhujrmoFSsZBs8syOZD1Q=
-go.mau.fi/whatsmeow v0.0.0-20250930215512-38f9aaa3ba7c h1:mlDr3/zLUCf8aylmGwds0mnAb4SNYimpb43ylQQlY3Q=
-go.mau.fi/whatsmeow v0.0.0-20250930215512-38f9aaa3ba7c/go.mod h1:dvltpCF0rOHbbur25DHbQ3Ovi747z2Pm11S2M7p1T74=
+go.mau.fi/whatsmeow v0.0.0-20251002120845-b3cd0a5002d4 h1:uysENrRsp3Ko6LjrOIsNnCT2l3lTibrUkp+CCx1IxG4=
+go.mau.fi/whatsmeow v0.0.0-20251002120845-b3cd0a5002d4/go.mod h1:dvltpCF0rOHbbur25DHbQ3Ovi747z2Pm11S2M7p1T74=
 go.mau.fi/zeroconfig v0.2.0 h1:e/OGEERqVRRKlgaro7E6bh8xXiKFSXB3eNNIud7FUjU=
 go.mau.fi/zeroconfig v0.2.0/go.mod h1:J0Vn0prHNOm493oZoQ84kq83ZaNCYZnq+noI1b1eN8w=
 golang.org/x/crypto v0.42.0 h1:chiH31gIWm57EkTXpwnqf8qeuMUi0yekh6mT2AvFlqI=

pkg/connector/client.go

@@ -197,7 +197,7 @@ func (wa *WhatsAppClient) Connect(ctx context.Context) {
 		zerolog.Ctx(ctx).Err(err).Msg("Failed to update proxy")
 	}
 	wa.startLoops()
-	wa.Client.BackgroundEventCtx = wa.Main.Bridge.BackgroundCtx
+	wa.Client.BackgroundEventCtx = wa.UserLogin.Log.WithContext(wa.Main.Bridge.BackgroundCtx)
 	if err := wa.Client.Connect(); err != nil {
 		zerolog.Ctx(ctx).Err(err).Msg("Failed to connect to WhatsApp")
 		state := status.BridgeState{

pkg/connector/handlematrix.go

@@ -15,6 +15,8 @@ import (
 	"go.mau.fi/util/ptr"
 	"go.mau.fi/util/variationselector"
 	"go.mau.fi/whatsmeow"
+	"go.mau.fi/whatsmeow/appstate"
+	"go.mau.fi/whatsmeow/proto/waCommon"
 	"go.mau.fi/whatsmeow/proto/waE2E"
 	"go.mau.fi/whatsmeow/types"
 	"golang.org/x/image/draw"
@@ -40,6 +42,9 @@ var (
 	_ bridgev2.RoomNameHandlingNetworkAPI       = (*WhatsAppClient)(nil)
 	_ bridgev2.RoomTopicHandlingNetworkAPI      = (*WhatsAppClient)(nil)
 	_ bridgev2.RoomAvatarHandlingNetworkAPI     = (*WhatsAppClient)(nil)
+	_ bridgev2.MuteHandlingNetworkAPI           = (*WhatsAppClient)(nil)
+	_ bridgev2.TagHandlingNetworkAPI            = (*WhatsAppClient)(nil)
+	_ bridgev2.MarkedUnreadHandlingNetworkAPI   = (*WhatsAppClient)(nil)
 )
 
 func (wa *WhatsAppClient) HandleMatrixPollStart(ctx context.Context, msg *bridgev2.MatrixPollStart) (*bridgev2.MatrixMessageResponse, error) {
@@ -566,3 +571,57 @@ func convertRoomAvatar(data []byte) ([]byte, error) {
 	}
 	return buf.Bytes(), nil
 }
+
+func (wa *WhatsAppClient) HandleMute(ctx context.Context, msg *bridgev2.MatrixMute) error {
+	chatJID, err := waid.ParsePortalID(msg.Portal.ID)
+	if err != nil {
+		return err
+	}
+	mutedUntil := msg.Content.GetMutedUntilTime()
+	muted := mutedUntil.After(time.Now())
+	muteTS := ptr.Ptr(mutedUntil.UnixMilli())
+	if !muted || mutedUntil == event.MutedForever {
+		muteTS = nil
+	}
+	return wa.Client.SendAppState(ctx, appstate.BuildMuteAbs(chatJID, muted, muteTS))
+}
+
+func (wa *WhatsAppClient) HandleRoomTag(ctx context.Context, msg *bridgev2.MatrixRoomTag) error {
+	chatJID, err := waid.ParsePortalID(msg.Portal.ID)
+	if err != nil {
+		return err
+	}
+	_, isFavorite := msg.Content.Tags[event.RoomTagFavourite]
+	return wa.Client.SendAppState(ctx, appstate.BuildPin(chatJID, isFavorite))
+}
+
+func (wa *WhatsAppClient) HandleMarkedUnread(ctx context.Context, msg *bridgev2.MatrixMarkedUnread) error {
+	chatJID, err := waid.ParsePortalID(msg.Portal.ID)
+	if err != nil {
+		return err
+	}
+	msgs, err := wa.Main.Bridge.DB.Message.GetLastNInPortal(ctx, msg.Portal.PortalKey, 1)
+	if err != nil {
+		return fmt.Errorf("failed to get last message in portal: %w", err)
+	}
+	var lastTS time.Time
+	var lastKey *waCommon.MessageKey
+	if len(msgs) == 1 {
+		lastTS = msgs[0].Timestamp
+		parsed, _ := waid.ParseMessageID(msgs[0].ID)
+		if parsed != nil {
+			fromMe := parsed.Sender.ToNonAD() == wa.JID.ToNonAD() || parsed.Sender.ToNonAD() == wa.GetStore().GetLID().ToNonAD()
+			var participant *string
+			if chatJID.Server == types.GroupServer {
+				participant = ptr.Ptr(parsed.Sender.String())
+			}
+			lastKey = &waCommon.MessageKey{
+				RemoteJID:   ptr.Ptr(chatJID.String()),
+				FromMe:      &fromMe,
+				ID:          &parsed.ID,
+				Participant: participant,
+			}
+		}
+	}
+	return wa.Client.SendAppState(ctx, appstate.BuildMarkChatAsRead(chatJID, msg.Content.Unread, lastTS, lastKey))
+}