handlematrix: support inviting user to group chat (#82)

Author: rnons

pkg/connector/handlematrix.go

@@ -49,6 +49,7 @@ var (
 	_ bridgev2.TypingHandlingNetworkAPI      = (*TwitterClient)(nil)
 	_ bridgev2.ChatViewingNetworkAPI         = (*TwitterClient)(nil)
 	_ bridgev2.DeleteChatHandlingNetworkAPI  = (*TwitterClient)(nil)
+	_ bridgev2.MembershipHandlingNetworkAPI  = (*TwitterClient)(nil)
 	_ bridgev2.RoomAvatarHandlingNetworkAPI  = (*TwitterClient)(nil)
 )
 
@@ -290,3 +291,28 @@ func (tc *TwitterClient) HandleMatrixRoomAvatar(ctx context.Context, msg *bridge
 	}
 	return false, errors.New("avatar not found")
 }
+
+func (tc *TwitterClient) HandleMatrixMembership(ctx context.Context, msg *bridgev2.MatrixMembershipChange) (bool, error) {
+	if msg.Type != bridgev2.Invite {
+		return false, errors.New("unsupported membership change type")
+	}
+	if msg.Portal.RoomType == database.RoomTypeDM {
+		return false, errors.New("cannot change members for DM")
+	}
+
+	var participantID string
+	switch target := msg.Target.(type) {
+	case *bridgev2.Ghost:
+		participantID = string(target.ID)
+	case *bridgev2.UserLogin:
+		participantID = string(target.ID)
+	}
+	_, err := tc.client.AddParticipants(ctx, &payload.AddParticipantsPayload{
+		ConversationID:    string(msg.Portal.ID),
+		AddedParticipants: []string{participantID},
+	})
+	if err != nil {
+		return false, err
+	}
+	return true, nil
+}

pkg/twittermeow/data/endpoints/endpoints.go

@@ -33,6 +33,7 @@ const (
 	PIN_CONVERSATION_URL              = BASE_URL + "/i/api/graphql/o0aymgGiJY-53Y52YSUGVA/DMPinnedInboxAppend_Mutation"
 	UNPIN_CONVERSATION_URL            = BASE_URL + "/i/api/graphql/_TQxP2Rb0expwVP9ktGrTQ/DMPinnedInboxDelete_Mutation"
 	GET_PINNED_CONVERSATIONS_URL      = BASE_URL + "/i/api/graphql/_gBQBgClVuMQb8efxWkbbQ/DMPinnedInboxQuery"
+	ADD_PARTICIPANTS_URL              = BASE_URL + "/i/api/graphql/oBwyQ0_xVbAQ8FAyG0pCRA/AddParticipantsMutation"
 	ADD_REACTION_URL                  = BASE_URL + "/i/api/graphql/VyDyV9pC2oZEj6g52hgnhA/useDMReactionMutationAddMutation"
 	REMOVE_REACTION_URL               = BASE_URL + "/i/api/graphql/bV_Nim3RYHsaJwMkTXJ6ew/useDMReactionMutationRemoveMutation"
 	SEND_TYPING_NOTIFICATION          = BASE_URL + "/i/api/graphql/HL96-xZ3Y81IEzAdczDokg/useTypingNotifierMutation"

pkg/twittermeow/data/payload/json.go

@@ -50,6 +50,11 @@ type PinAndUnpinConversationVariables struct {
 	Label          LabelType `json:"label,omitempty"`
 }
 
+type AddParticipantsPayload struct {
+	ConversationID    string   `json:"conversationId"`
+	AddedParticipants []string `json:"addedParticipants"`
+}
+
 type ReactionActionPayload struct {
 	ConversationID string   `json:"conversationId"`
 	MessageID      string   `json:"messageId"`

pkg/twittermeow/data/response/messaging.go

@@ -66,3 +66,12 @@ type ReactionResponse struct {
 		} `json:"create_dm_reaction,omitempty"`
 	} `json:"data,omitempty"`
 }
+
+type AddParticipantsResponse struct {
+	Data struct {
+		AddParticipants struct {
+			Typename   string   `json:"__typename,omitempty"`
+			AddedUsers []string `json:"added_users,omitempty"`
+		} `json:"add_participants,omitempty"`
+	} `json:"data,omitempty"`
+}

pkg/twittermeow/messaging.go

@@ -374,3 +374,32 @@ func (c *Client) UpdateConversationAvatar(ctx context.Context, conversationID st
 
 	return nil
 }
+
+func (c *Client) AddParticipants(ctx context.Context, variables *payload.AddParticipantsPayload) (*response.AddParticipantsResponse, error) {
+	graphQlPayload := payload.GraphQLPayload{
+		Variables: variables,
+		QueryID:   "oBwyQ0_xVbAQ8FAyG0pCRA",
+	}
+
+	url := endpoints.ADD_PARTICIPANTS_URL
+
+	jsonBody, err := graphQlPayload.Encode()
+	if err != nil {
+		return nil, err
+	}
+
+	_, respBody, err := c.makeAPIRequest(ctx, apiRequestOpts{
+		URL:            url,
+		Method:         http.MethodPost,
+		WithClientUUID: true,
+		Body:           jsonBody,
+		Origin:         endpoints.BASE_URL,
+		ContentType:    types.ContentTypeJSON,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	data := response.AddParticipantsResponse{}
+	return &data, json.Unmarshal(respBody, &data)
+}