send edited msg

pkg/connector/client.go

@@ -48,6 +48,7 @@ func (c *GChatClient) Disconnect() {
 }
 
 var dmCaps = &bridgev2.NetworkRoomCapabilities{
+	Edits:   true,
 	Replies: true,
 }
 

pkg/connector/handlematrix.go

@@ -13,6 +13,7 @@ import (
 )
 
 var (
+	_ bridgev2.EditHandlingNetworkAPI     = (*GChatClient)(nil)
 	_ bridgev2.ReactionHandlingNetworkAPI = (*GChatClient)(nil)
 )
 
@@ -144,6 +145,44 @@ func (c *GChatClient) HandleMatrixMessage(ctx context.Context, msg *bridgev2.Mat
 	}, nil
 }
 
+func (c *GChatClient) HandleMatrixEdit(ctx context.Context, msg *bridgev2.MatrixEdit) error {
+	groupId, err := portalToGroupId(msg.Portal)
+	if err != nil {
+		return err
+	}
+
+	text, entities := c.msgConv.ToGChat(ctx, msg.Content)
+	msgId := string(msg.EditTarget.ID)
+	threadId := string(msg.EditTarget.ThreadRoot)
+	topicId := msgId
+	if threadId != "" {
+		topicId = threadId
+	}
+	res, err := c.client.EditMessage(ctx, &proto.EditMessageRequest{
+		MessageId: &proto.MessageId{
+			ParentId: &proto.MessageParentId{
+				Parent: &proto.MessageParentId_TopicId{
+					TopicId: &proto.TopicId{
+						GroupId: groupId,
+						TopicId: topicId,
+					},
+				},
+			},
+			MessageId: msgId,
+		},
+		TextBody:    text,
+		Annotations: entities,
+		MessageInfo: &proto.MessageInfo{
+			AcceptFormatAnnotations: true,
+		},
+	})
+	if err != nil {
+		return err
+	}
+	_ = res
+	return nil
+}
+
 func (c *GChatClient) PreHandleMatrixReaction(_ context.Context, msg *bridgev2.MatrixReaction) (bridgev2.MatrixReactionPreResponse, error) {
 	emoji := msg.Content.RelatesTo.Key
 	return bridgev2.MatrixReactionPreResponse{

pkg/gchatmeow/api.go

@@ -135,15 +135,19 @@ func (c *Client) paginatedWorld(ctx context.Context) (*proto.PaginatedWorldRespo
 func (c *Client) CreateTopic(ctx context.Context, request *proto.CreateTopicRequest) (*proto.CreateTopicResponse, error) {
 	request.RequestHeader = c.gcRequestHeader
 	response := &proto.CreateTopicResponse{}
-	err := c.gcRequest(ctx, "create_topic", request, response)
-	return response, err
+	return response, c.gcRequest(ctx, "create_topic", request, response)
 }
 
 func (c *Client) CreateMessage(ctx context.Context, request *proto.CreateMessageRequest) (*proto.CreateMessageResponse, error) {
 	request.RequestHeader = c.gcRequestHeader
 	response := &proto.CreateMessageResponse{}
-	err := c.gcRequest(ctx, "create_message", request, response)
-	return response, err
+	return response, c.gcRequest(ctx, "create_message", request, response)
+}
+
+func (c *Client) EditMessage(ctx context.Context, request *proto.EditMessageRequest) (*proto.EditMessageResponse, error) {
+	request.RequestHeader = c.gcRequestHeader
+	response := &proto.EditMessageResponse{}
+	return response, c.gcRequest(ctx, "edit_message", request, response)
 }
 
 func (c *Client) GetGroup(ctx context.Context, request *proto.GetGroupRequest) (*proto.GetGroupResponse, error) {