prosody-hg: plugins/muc/muc.lib.lua comparison

comparison plugins/muc/muc.lib.lua @ 8842:463505cc75d5

MUC: Revert unstable MUC commits since 0.10.1 These have caused too many issue reports to be included in the stable branch at this time. Affected issues: #345, #397 Reverted commits: dcd53a565c01 6d4b0895f76d 1b10802a770e 564e897f0790 a7221ada9368 aaff40ec7001 05a3275b6873 c2b99fa134b3 8da11142fabf

author	Matthew Wild <mwild1@gmail.com>
date	Wed, 30 May 2018 21:33:53 +0100
parents	dcd53a565c01
children	041ddc670934 c47f220580fd

comparison

equal deleted inserted replaced

-:bc8558bbc797
+:463505cc75d5
 		local maxchars = history_tag and tonumber(history_tag.attr.maxchars);
 		if maxchars then maxchars = math.floor(maxchars); end
 		local maxstanzas = math.floor(history_tag and tonumber(history_tag.attr.maxstanzas) or #history);
-		if not history_tag then maxstanzas = self._data.default_history_messages; end
+		if not history_tag then maxstanzas = 20; end
 		local seconds = history_tag and tonumber(history_tag.attr.seconds);
 		if seconds then seconds = datetime.datetime(os.time() - math.floor(seconds)); end
 		local since = history_tag and history_tag.attr.since;
 	if length == default_history_length then
 		length = nil;
 	end
 	self._data.history_length = length;
 end
--- Fix for clients who don't support XEP-0045 correctly
--- Default number of history messages the room returns
-function room_mt:get_defaulthistorymessages()
-return self._data.default_history_messages or default_history_length;
-end
-function room_mt:set_defaulthistorymessages(number)
-number = math.min(tonumber(number) or default_history_length, self._data.history_length or default_history_length);
-if number == default_history_length then
-number = nil;
-end
-self._data.default_history_messages = number;
-end
 local valid_whois = { moderators = true, anyone = true };
 function room_mt:set_whois(whois)
 		{
 			name = 'muc#roomconfig_historylength',
 			type = 'text-single',
 			label = 'Maximum Number of History Messages Returned by Room',
 			value = tostring(self:get_historylength())
-		},
-		{
-			name = 'muc#roomconfig_defaulthistorymessages',
-			type = 'text-single',
-			label = 'Default Number of History Messages Returned by Room',
-			value = tostring(self:get_defaulthistorymessages())
 		}
 	});
 	return module:fire_event("muc-config-form", { room = self, actor = actor, form = form }) or form;
 end
 	handle_option("moderated", "muc#roomconfig_moderatedroom");
 	handle_option("members_only", "muc#roomconfig_membersonly");
 	handle_option("public", "muc#roomconfig_publicroom");
 	handle_option("changesubject", "muc#roomconfig_changesubject");
 	handle_option("historylength", "muc#roomconfig_historylength");
-	handle_option("defaulthistorymessages", "muc#roomconfig_defaulthistorymessages");
 	handle_option("whois", "muc#roomconfig_whois", valid_whois);
 	handle_option("password", "muc#roomconfig_roomsecret");
 	if self.save then self:save(true); end
 	if self.locked then
 		elseif xmlns == "http://jabber.org/protocol/muc#admin" then
 			local actor = stanza.attr.from;
 			local affiliation = self:get_affiliation(actor);
 			local current_nick = self._jid_nick[actor];
 			local role = current_nick and self._occupants[current_nick].role or self:get_default_role(affiliation);
-			if type == "set" then
+			local item = stanza.tags[1].tags[1];
-				local at_least_one_item_provided = false;
+			if item and item.name == "item" then
-				local callback = function() origin.send(st.reply(stanza)); end
+				if type == "set" then
+					local callback = function() origin.send(st.reply(stanza)); end
-				-- Gather all changes to affiliations and roles
-				local jid_affiliation = {};
-				local jidnick_role = {};
-				for item in stanza.tags[1]:childtags("item") do
-					at_least_one_item_provided = true;
 					if item.attr.jid then -- Validate provided JID
 						item.attr.jid = jid_prep(item.attr.jid);
 						if not item.attr.jid then
 							origin.send(st.error_reply(stanza, "modify", "jid-malformed"));
 							return;
 						if occupant then item.attr.jid = occupant.jid; end
 					elseif not item.attr.nick and item.attr.jid then
 						local nick = self._jid_nick[item.attr.jid];
 						if nick then item.attr.nick = select(3, jid_split(nick)); end
 					end
 					local reason = item.tags[1] and item.tags[1].name == "reason" and #item.tags[1] == 1 and item.tags[1][1];
 					if item.attr.affiliation and item.attr.jid and not item.attr.role then
-						jid_affiliation[item.attr.jid] = { ["affiliation"] = item.attr.affiliation, ["reason"] = reason };
+						local success, errtype, err = self:set_affiliation(actor, item.attr.jid, item.attr.affiliation, callback, reason);
+						if not success then origin.send(st.error_reply(stanza, errtype, err)); end
 					elseif item.attr.role and item.attr.nick and not item.attr.affiliation then
-						jidnick_role[self.jid.."/"..item.attr.nick] = { ["role"] = item.attr.role, ["reason"] = reason };
+						local success, errtype, err = self:set_role(actor, self.jid.."/"..item.attr.nick, item.attr.role, callback, reason);
+						if not success then origin.send(st.error_reply(stanza, errtype, err)); end
 					else
 						origin.send(st.error_reply(stanza, "cancel", "bad-request"));
-						return;
 					end
-				end
+				elseif type == "get" then
-				if not at_least_one_item_provided then
-					origin.send(st.error_reply(stanza, "cancel", "bad-request"));
-					return;
-				else
-					local can_set_affiliations, errtype_aff, err_aff = self:can_set_affiliations(actor, jid_affiliation)
-					local can_set_roles, errtype_role, err_role = self:can_set_roles(actor, jidnick_role)
-					if can_set_affiliations and can_set_roles then
-						local nb_affiliation_changes = 0;
-						for _ in pairs(jid_affiliation) do nb_affiliation_changes = nb_affiliation_changes + 1; end
-						local nb_role_changes = 0;
-						for _ in pairs(jidnick_role) do nb_role_changes = nb_role_changes + 1; end
-						if nb_affiliation_changes > 0 and nb_role_changes > 0 then
-							origin.send(st.error_reply(stanza, "cancel", "bad-request"));
-						end
-						if nb_affiliation_changes > 0 then
-							self:set_affiliations(actor, jid_affiliation, callback);
-						end
-						if nb_role_changes > 0 then
-							self:set_roles(actor, jidnick_role, callback);
-						end
-					else
-						if not can_set_affiliations then
-							origin.send(st.error_reply(stanza, errtype_aff, err_aff));
-						elseif not can_set_roles then
-							origin.send(st.error_reply(stanza, errtype_role, err_role));
-						else
-							origin.send(st.error_reply(stanza, "cancel", "bad-request"));
-						end
-						return;
-					end
-				end
-			elseif type == "get" then
-				local item = stanza.tags[1].tags[1];
-				if item and item.name == "item" then
 					local _aff = item.attr.affiliation;
 					local _rol = item.attr.role;
 					if _aff and not _rol then
 						if affiliation == "owner" or (affiliation == "admin" and _aff ~= "owner" and _aff ~= "admin")
 						or (affiliation and affiliation ~= "outcast" and self:get_members_only() and self:get_whois() == "anyone") then
 							origin.send(st.error_reply(stanza, "auth", "forbidden"));
 						end
 					else
 						origin.send(st.error_reply(stanza, "cancel", "bad-request"));
 					end
-				else
+				end
-					origin.send(st.error_reply(stanza, "cancel", "bad-request"));
+			elseif type == "set" or type == "get" then
-				end
+				origin.send(st.error_reply(stanza, "cancel", "bad-request"));
 			end
 		elseif xmlns == "http://jabber.org/protocol/muc#owner" and (type == "get" or type == "set") and stanza.tags[1].name == "query" then
 			if self:get_affiliation(stanza.attr.from) ~= "owner" then
 				origin.send(st.error_reply(stanza, "auth", "forbidden", "Only owners can configure rooms"));
 			elseif stanza.attr.type == "get" then
 	local bare = node and node.."@"..host or host;
 	local result = self._affiliations[bare]; -- Affiliations are granted, revoked, and maintained based on the user's bare JID.
 	if not result and self._affiliations[host] == "outcast" then result = "outcast"; end -- host banned
 	return result;
 end
---- Checks whether the given affiliation changes in jid_affiliation can be applied by actor.
+function room_mt:set_affiliation(actor, jid, affiliation, callback, reason)
--- Note: Empty tables can always be applied and won't have any effect.
+	jid = jid_bare(jid);
-function room_mt:can_set_affiliations(actor, jid_affiliation)
+	if affiliation == "none" then affiliation = nil; end
-	local actor_affiliation;
+	if affiliation and affiliation ~= "outcast" and affiliation ~= "owner" and affiliation ~= "admin" and affiliation ~= "member" then
+		return nil, "modify", "not-acceptable";
+	end
 	if actor ~= true then
-		actor_affiliation = self:get_affiliation(actor);
+		local actor_affiliation = self:get_affiliation(actor);
-	end
-	-- First let's see if there are any problems with the affiliations given
-	-- in jid_affiliation
-	for jid, value in pairs(jid_affiliation) do
-		local affiliation = value["affiliation"];
-		if jid ~= jid_bare(jid) then
-			return false, "modify", "not-acceptable";
-		end
-		jid = jid_bare(jid);
-		if affiliation == "none" then affiliation = nil; end
-		if affiliation and affiliation ~= "outcast" and affiliation ~= "owner" and affiliation ~= "admin" and affiliation ~= "member" then
-			return false, "modify", "not-acceptable";
-		end
 		local target_affiliation = self:get_affiliation(jid);
-		if target_affiliation == affiliation then
+		if target_affiliation == affiliation then -- no change, shortcut
-			-- no change, no error checking necessary
+			if callback then callback(); end
+			return true;
+		end
+		if actor_affiliation ~= "owner" then
+			if affiliation == "owner" or affiliation == "admin" or actor_affiliation ~= "admin" or target_affiliation == "owner" or target_affiliation == "admin" then
+				return nil, "cancel", "not-allowed";
+			end
+		elseif target_affiliation == "owner" and jid_bare(actor) == jid then -- self change
+			local is_last = true;
+			for j, aff in pairs(self._affiliations) do if j ~= jid and aff == "owner" then is_last = false; break; end end
+			if is_last then
+				return nil, "cancel", "conflict";
+			end
+		end
+	end
+	self._affiliations[jid] = affiliation;
+	local role = self:get_default_role(affiliation);
+	local x = st.stanza("x", {xmlns = "http://jabber.org/protocol/muc#user"})
+			:tag("item", {affiliation=affiliation or "none", role=role or "none"})
+				:tag("reason"):text(reason or ""):up()
+			:up();
+	local presence_type = nil;
+	if not role then -- getting kicked
+		presence_type = "unavailable";
+		if affiliation == "outcast" then
+			x:tag("status", {code="301"}):up(); -- banned
 		else
-			if actor ~= true and actor_affiliation ~= "owner" then
+			x:tag("status", {code="321"}):up(); -- affiliation change
-				if affiliation == "owner" or affiliation == "admin" or actor_affiliation ~= "admin" or target_affiliation == "owner" or target_affiliation == "admin" then
+		end
-					return false, "cancel", "not-allowed";
-				end
-			elseif target_affiliation == "owner" and jid_bare(actor) == jid then -- self change
-				local is_last = true;
-				for j, aff in pairs(self._affiliations) do if j ~= jid and aff == "owner" then is_last = false; break; end end
-				if is_last then
-					return false, "cancel", "conflict";
-				end
-			end
-		end
-	end
-	return true;
-end
---- Updates the room affiliations by applying the ones given here.
--- Takes the affiliations given in jid_affiliation and applies them to
--- the room, overwriting a potentially existing affiliation for any given
--- jid.
--- @param jid_affiliation A table associating a jid with a table consisting
---                        of two subkeys: `affilation` and `reason`. The jids
---                        within must not be malformed.
-function room_mt:set_affiliations(actor, jid_affiliation, callback)
-	local can_set, err_type, err_condition = self:can_set_affiliations(actor, jid_affiliation)
-	if not can_set then
-		return false, err_type, err_condition;
 	end
 	-- Your own presence should have status 110
+	local self_x = st.clone(x);
+	self_x:tag("status", {code="110"});
 	local modified_nicks = {};
-	local nb_modified_nicks = 0;
+	for nick, occupant in pairs(self._occupants) do
-	-- Now we can be sure that jid_affiliation causes no problems
+		if jid_bare(occupant.jid) == jid then
-	-- We can actually set them
+			if not role then -- getting kicked
-	for jid, value in pairs(jid_affiliation) do
+				self._occupants[nick] = nil;
-		local affiliation = value["affiliation"];
-		local reason = value["reason"];
-		self._affiliations[jid] = affiliation;
-		local role = self:get_default_role(affiliation);
-		local x = st.stanza("x", {xmlns = "http://jabber.org/protocol/muc#user"})
-				:tag("item", {affiliation=affiliation or "none", role=role or "none"})
-					:tag("reason"):text(reason or ""):up()
-				:up();
-		local self_x = st.clone(x);
-		self_x:tag("status", {code="110"}):up();
-		local presence_type = nil;
-		if not role then -- getting kicked
-			presence_type = "unavailable";
-			if affiliation == "outcast" then
-				-- banned
-				x:tag("status", {code="301"}):up();
-				self_x:tag("status", {code="301"}):up();
 			else
-				-- affiliation change
+				occupant.affiliation, occupant.role = affiliation, role;
-				x:tag("status", {code="321"}):up();
+			end
-				self_x:tag("status", {code="321"}):up();
+			for jid,pres in pairs(occupant.sessions) do -- remove for all sessions of the nick
-			end
+				if not role then self._jid_nick[jid] = nil; end
-		end
+				local p = st.clone(pres);
-		for nick, occupant in pairs(self._occupants) do
+				p.attr.from = nick;
-			if jid_bare(occupant.jid) == jid then
+				p.attr.type = presence_type;
-				if not role then -- getting kicked
+				p.attr.to = jid;
-					self._occupants[nick] = nil;
+				if occupant.jid == jid then
-				else
-					occupant.affiliation, occupant.role = affiliation, role;
-				end
-				for jid,pres in pairs(occupant.sessions) do -- remove for all sessions of the nick
-					if not role then self._jid_nick[jid] = nil; end
-					local p = st.clone(pres);
-					p.attr.from = nick;
-					p.attr.type = presence_type;
-					p.attr.to = jid;
-					self:_route_stanza(p);
-					if occupant.jid == jid then
 					-- Broadcast this presence to everyone else later, with the public <x> variant
-						local bp = st.clone(p);
+					local bp = st.clone(p);
-						bp:add_child(x);
+					bp:add_child(x);
-						modified_nicks[nick] = bp;
+					modified_nicks[nick] = bp;
-						nb_modified_nicks = nb_modified_nicks + 1;
+				end
-					end
+				p:add_child(self_x);
-					p:add_child(self_x);
+				self:_route_stanza(p);
-					self:_route_stanza(p);
+			end
-				end
+		end
-			end
+	end
-		end
+	if self.save then self:save(); end
-	end
+	if callback then callback(); end
-	if nb_modified_nicks > 0 then
-		if self.save then self:save(); end
-		if callback then callback(); end
-	end
 	for nick,p in pairs(modified_nicks) do
 		p.attr.from = nick;
 		self:broadcast_except_nick(p, nick);
 	end
 	return true;
-end
-function room_mt:set_affiliation(actor, jid, affiliation, callback, reason)
-	return self.set_affiliations(actor, { [jid] = { ["affiliation"] = affiliation, ["reason"] = reason } }, callback)
 end
 function room_mt:get_role(nick)
 	local session = self._occupants[nick];
 	return session and session.role or nil;
 			end
 		end
 	end
 	return nil, "cancel", "not-allowed";
 end
+function room_mt:set_role(actor, occupant_jid, role, callback, reason)
---- Checks whether the given role changes in jidnick_role can be applied by actor.
+	if role == "none" then role = nil; end
--- Note: Empty tables can always be applied and won't have any effect.
+	if role and role ~= "moderator" and role ~= "participant" and role ~= "visitor" then return nil, "modify", "not-acceptable"; end
-function room_mt:can_set_roles(actor, jidnick_role)
+	local allowed, err_type, err_condition = self:can_set_role(actor, occupant_jid, role);
-	for jidnick, role_info in pairs(jidnick_role) do
-		local role = role_info["role"];
-		if role == "none" then role = nil; end
-		if role and role ~= "moderator" and role ~= "participant" and role ~= "visitor" then return false, "modify", "not-acceptable"; end
-		local can_set, err_type, err_condition = self:can_set_role(actor, jidnick, role)
-		if not can_set then
-			return false, err_type, err_condition;
-		end
-	end
-	return true;
-end
---- Updates the room roles by applying the ones given here.
--- Takes the roles given in jidnick_role and applies them to
--- the room, overwriting a potentially existing role for any given
--- jid.
--- @param jidnick_role A table associating a jid/nick with a table consisting
---                     of two subkeys: `role` and `reason`. The jids within
---                     must not be malformed.
-function room_mt:set_roles(actor, jidnick_role, callback)
-	local allowed, err_type, err_condition = self:can_set_roles(actor, jidnick_role);
 	if not allowed then return allowed, err_type, err_condition; end
+	local occupant = self._occupants[occupant_jid];
-	local modified_nicks = {};
+	local x = st.stanza("x", {xmlns = "http://jabber.org/protocol/muc#user"})
-	local nb_modified_nicks = 0;
+			:tag("item", {affiliation=occupant.affiliation or "none", nick=select(3, jid_split(occupant_jid)), role=role or "none"})
-	for jidnick, value in pairs(jidnick_role) do
+				:tag("reason"):text(reason or ""):up()
-		local occupant_jid = jidnick;
+			:up();
-		local role = value["role"];
+	local presence_type = nil;
-		local reason = value["reason"];
+	if not role then -- kick
+		presence_type = "unavailable";
-		local occupant = self._occupants[occupant_jid];
+		self._occupants[occupant_jid] = nil;
-		local x = st.stanza("x", {xmlns = "http://jabber.org/protocol/muc#user"})
+		for jid in pairs(occupant.sessions) do -- remove for all sessions of the nick
-				:tag("item", {affiliation=occupant.affiliation or "none", nick=select(3, jid_split(occupant_jid)), role=role or "none"})
+			self._jid_nick[jid] = nil;
-					:tag("reason"):text(reason or ""):up()
+		end
-				:up();
+		x:tag("status", {code = "307"}):up();
-		local presence_type = nil;
+	else
-		if not role or role == "none" then -- kick
+		occupant.role = role;
-			presence_type = "unavailable";
+	end
-			self._occupants[occupant_jid] = nil;
+	local self_x = st.clone(x);
-			for jid in pairs(occupant.sessions) do -- remove for all sessions of the nick
+	self_x:tag("status", {code = "110"}):up();
-				self._jid_nick[jid] = nil;
+	local bp;
-			end
+	for jid,pres in pairs(occupant.sessions) do -- send to all sessions of the nick
-			x:tag("status", {code = "307"}):up();
+		local p = st.clone(pres);
-		else
+		p.attr.from = occupant_jid;
-			occupant.role = role;
+		p.attr.type = presence_type;
-		end
+		p.attr.to = jid;
-		local self_x = st.clone(x);
+		if occupant.jid == jid then
-		self_x:tag("status", {code = "110"}):up();
+			bp = st.clone(p);
-		local bp;
+			bp:add_child(x);
-		for jid,pres in pairs(occupant.sessions) do -- send to all sessions of the nick
+		end
-			local p = st.clone(pres);
+		p:add_child(self_x);
-			p.attr.from = occupant_jid;
+		self:_route_stanza(p);
-			p.attr.type = presence_type;
+	end
-			p.attr.to = jid;
+	if callback then callback(); end
-			self:_route_stanza(p);
+	if bp then
-			if occupant.jid == jid then
+		self:broadcast_except_nick(bp, occupant_jid);
-				bp = st.clone(p);
-				bp:add_child(x);
-				modified_nicks[occupant_jid] = bp;
-				nb_modified_nicks = nb_modified_nicks + 1;
-			end
-			p:add_child(self_x);
-			self:route_stanza(p);
-		end
-	end
-	if nb_modified_nicks > 0 then
-		if callback then callback(); end
-	end
-	for nick,p in pairs(modified_nicks) do
-		self:broadcast_except_nick(p, nick);
 	end
 	return true;
 end
 function room_mt:_route_stanza(stanza)
 	end
 	if muc_child then
 		for _, item in pairs(muc_child.tags) do
 			if item.name == "item" then
 				if from_occupant == to_occupant then
-					item.attr.jid = jid_bare(stanza.attr.to);
+					item.attr.jid = stanza.attr.to;
 				else
-					item.attr.jid = jid_bare(from_occupant.jid);
+					item.attr.jid = from_occupant.jid;
 				end
 			end
 		end
 	end
 	self:route_stanza(stanza);

Mercurial > prosody-hg

comparison plugins/muc/muc.lib.lua @ 8842:463505cc75d5