Function SendOwnerInvite

federationapi/routing/new_func.go:165–242

(httpReq *http.Request, userAPI userapi.FederationUserAPI, cfg *config.FederationAPI, rsAPI roomserverAPI.FederationRoomserverAPI,
)

}

func SendOwnerInvite(httpReq *http.Request, userAPI userapi.FederationUserAPI, cfg *config.FederationAPI, rsAPI roomserverAPI.FederationRoomserverAPI,
) util.JSONResponse {
	ctx := httpReq.Context()
	req := inviteAsOwnerReq{}
	resErr := httputil.UnmarshalJSONRequest(httpReq, &req)
	if resErr != nil {
		return *resErr
	}
	if req.RoomId == "" || req.TargetUserId == "" {
		return util.JSONResponse{
			Code: http.StatusBadRequest,
			JSON: jsonerror.BadJSON("invalid params"),
		}
	}
	groupOwner, err := new_db.GetGroupOwner(req.RoomId)
	if err != nil {
		return util.ErrorResponse(err)
	}
	var userPro userapi.QueryProfileResponse
	err = userAPI.QueryProfile(ctx, &userapi.QueryProfileRequest{
		req.TargetUserId,
	}, &userPro)
	if err != nil {
		return util.ErrorResponse(err)
	}
	builder := gomatrixserverlib.EventBuilder{
		Sender:   groupOwner,
		RoomID:   req.RoomId,
		Type:     "m.room.member",
		StateKey: &req.TargetUserId,
	}
	content := gomatrixserverlib.MemberContent{
		Membership:  gomatrixserverlib.Invite,
		DisplayName: userPro.DisplayName,
		AvatarURL:   userPro.AvatarURL,
		Reason:      req.Reason,
		IsDirect:    false,
	}
	if err = builder.SetContent(content); err != nil {
		return util.ErrorResponse(err)
	}
	event, err := eventutil.QueryAndBuildEvent(ctx, &builder, cfg.Matrix, time.Now(), rsAPI, nil)
	if err == errMissingUserID {
		return util.JSONResponse{
			Code: http.StatusBadRequest,
			JSON: jsonerror.BadJSON(err.Error()),
		}
	} else if err == eventutil.ErrRoomNoExists {
		return util.JSONResponse{
			Code: http.StatusNotFound,
			JSON: jsonerror.NotFound(err.Error()),
		}
	} else if err != nil {
		util.GetLogger(ctx).WithError(err).Error("buildMembershipEvent failed")
		return jsonerror.InternalServerError()
	}

	var inviteRes roomserverAPI.PerformInviteResponse