Function RejoinCluster

clientapi/routing/cluster.go:21–70

RejoinCluster

(req *http.Request, device *api.Device, roomId string,
	cfg *config.ClientAPI,
	profileAPI api.ClientUserAPI, rsAPI roomserverAPI.ClientRoomserverAPI,
	asAPI appserviceAPI.AppServiceInternalAPI, federation *gomatrixserverlib.FederationClient)

// RejoinCluster 
func RejoinCluster(req *http.Request, device *api.Device, roomId string,
	cfg *config.ClientAPI,
	profileAPI api.ClientUserAPI, rsAPI roomserverAPI.ClientRoomserverAPI,
	asAPI appserviceAPI.AppServiceInternalAPI, federation *gomatrixserverlib.FederationClient) util.JSONResponse {
	local, _, err := gomatrixserverlib.SplitID('@', device.UserID)
	if err != nil {
		return util.ErrorResponse(err)
	}
	
	isinEquipmentGroup, err := new_feature.JudgeIsinEquipmentGroup(roomId, local)
	if err != nil {
		return util.ErrorResponse(err)
	}
	if isinEquipmentGroup {
		
		conflictUsers, err := new_db.GetConflictUsers(device.UserID, roomId)
		if err != nil {
			util.GetLogger(req.Context()).Error(err)
		}
		if len(conflictUsers) > 0 {
			for i, _ := range conflictUsers { 
				SendLeaveAsRoomOwner(req.Context(), profileAPI, roomId, conflictUsers[i], "cluster_addr_conflict", cfg, rsAPI, asAPI, time.Now())
			}
		}
		
		_, domain, err := gomatrixserverlib.SplitID('!', roomId)
		if err != nil {
			return util.ErrorResponse(err)
		}
		if domain == cfg.Matrix.ServerName {
			
			return SendInviteAsRoomOwner(req.Context(), profileAPI, roomId, device.UserID, "from_cluster", cfg, rsAPI, asAPI, time.Now())
		} else {
			// ，federationapiinvite
			
			res, err := federation.SendInviteAsOwner(req.Context(), domain, make(map[string]interface{}))
			if err != nil {
				return util.ErrorResponse(err)
			}
			return util.JSONResponse{
				Code: http.StatusOK,
				JSON: res,
			}
		}
	}
	return util.JSONResponse{
		Code: http.StatusForbidden,
		JSON: jsonerror.Unknown("not in the cluster"),
	}
}
func SendInviteAsRoomOwner(ctx context.Context,
	profileAPI userapi.ClientUserAPI,
	roomID, userID, reason string,