Function createInviteFrom3PIDInvite

federationapi/routing/threepid.go:211–270

createInviteFrom3PIDInvite processes an invite provided by the identity server and creates a m.room.member event (with "invite" membership) from it. Returns an error if there was a problem building the event or fetching the necessary data to do so.

(
	ctx context.Context, rsAPI api.FederationRoomserverAPI,
	cfg *config.FederationAPI,
	inv invite, federation federationAPI.FederationClient,
	userAPI userapi.FederationUserAPI,
)

// Returns an error if there was a problem building the event or fetching the
// necessary data to do so.
func createInviteFrom3PIDInvite(
	ctx context.Context, rsAPI api.FederationRoomserverAPI,
	cfg *config.FederationAPI,
	inv invite, federation federationAPI.FederationClient,
	userAPI userapi.FederationUserAPI,
) (*gomatrixserverlib.Event, error) {
	verReq := api.QueryRoomVersionForRoomRequest{RoomID: inv.RoomID}
	verRes := api.QueryRoomVersionForRoomResponse{}
	if err := rsAPI.QueryRoomVersionForRoom(ctx, &verReq, &verRes); err != nil {
		return nil, err
	}

	_, server, err := gomatrixserverlib.SplitID('@', inv.MXID)
	if err != nil {
		return nil, err
	}

	if server != cfg.Matrix.ServerName {
		return nil, errNotLocalUser
	}

	// Build the event
	builder := &gomatrixserverlib.EventBuilder{
		Type:     "m.room.member",
		Sender:   inv.Sender,
		RoomID:   inv.RoomID,
		StateKey: &inv.MXID,
	}

	var res userapi.QueryProfileResponse
	err = userAPI.QueryProfile(ctx, &userapi.QueryProfileRequest{
		UserID: inv.MXID,
	}, &res)
	if err != nil {
		return nil, err
	}

	content := gomatrixserverlib.MemberContent{
		AvatarURL:   res.AvatarURL,
		DisplayName: res.DisplayName,
		Membership:  gomatrixserverlib.Invite,
		ThirdPartyInvite: &gomatrixserverlib.MemberThirdPartyInvite{
			Signed: inv.Signed,
		},
	}

	if err = builder.SetContent(content); err != nil {
		return nil, err
	}

	event, err := buildMembershipEvent(ctx, builder, rsAPI, cfg)
	if err == errNotInRoom {
		return nil, sendToRemoteServer(ctx, inv, federation, cfg, *builder)
	}
	if err != nil {
		return nil, err
	}