%%%---------------------------------------------------------------------- %%% %%% ejabberd, Copyright (C) 2002-2024 ProcessOne %%% %%% This program is free software; you can redistribute it and/or %%% modify it under the terms of the GNU General Public License as %%% published by the Free Software Foundation; either version 2 of the %%% License, or (at your option) any later version. %%% %%% This program is distributed in the hope that it will be useful, %%% but WITHOUT ANY WARRANTY; without even the implied warranty of %%% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU %%% General Public License for more details. %%% %%% You should have received a copy of the GNU General Public License along %%% with this program; if not, write to the Free Software Foundation, Inc., %%% 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. %%% %%%---------------------------------------------------------------------- -define(MAX_USERS_DEFAULT, 200). -define(SETS, gb_sets). -record(lqueue, { queue = p1_queue:new() :: p1_queue:queue(lqueue_elem()), max = 0 :: integer() }). -type lqueue() :: #lqueue{}. -type lqueue_elem() :: {binary(), message(), boolean(), erlang:timestamp(), non_neg_integer()}. -record(config, { title = <<"">> :: binary(), description = <<"">> :: binary(), allow_change_subj = true :: boolean(), allow_query_users = true :: boolean(), allowpm = anyone :: anyone | participants | moderators | none, allow_private_messages_from_visitors = anyone :: anyone | moderators | nobody , allow_visitor_status = true :: boolean(), allow_visitor_nickchange = true :: boolean(), public = true :: boolean(), public_list = true :: boolean(), persistent = false :: boolean() | {destroying, boolean()}, moderated = true :: boolean(), captcha_protected = false :: boolean(), members_by_default = true :: boolean(), members_only = false :: boolean(), allow_user_invites = false :: boolean(), allow_subscription = false :: boolean(), password_protected = false :: boolean(), password = <<"">> :: binary(), anonymous = true :: boolean(), presence_broadcast = [moderator, participant, visitor] :: [moderator | participant | visitor], allow_voice_requests = true :: boolean(), voice_request_min_interval = 1800 :: non_neg_integer(), max_users = ?MAX_USERS_DEFAULT :: non_neg_integer() | none, logging = false :: boolean(), vcard = <<"">> :: binary(), vcard_xupdate = undefined :: undefined | external | binary(), captcha_whitelist = (?SETS):empty() :: gb_sets:set(), mam = false :: boolean(), pubsub = <<"">> :: binary(), enable_hats = false :: boolean(), lang = ejabberd_option:language() :: binary() }). -type config() :: #config{}. -type role() :: moderator | participant | visitor | none. -type affiliation() :: admin | member | outcast | owner | none. -record(user, { jid :: jid(), nick :: binary(), role :: role(), %%is_subscriber = false :: boolean(), %%subscriptions = [] :: [binary()], last_presence :: presence() | undefined }). -record(subscriber, {jid :: jid(), nick = <<>> :: binary(), nodes = [] :: [binary()]}). -record(muc_subscribers, {subscribers = #{} :: subscribers(), subscriber_nicks = #{} :: subscriber_nicks(), subscriber_nodes = #{} :: subscriber_nodes() }). -type subscribers() :: #{ljid() => #subscriber{}}. -type subscriber_nicks() :: #{binary() => [ljid()]}. -type subscriber_nodes() :: #{binary() => subscribers()}. -record(activity, { message_time = 0 :: integer(), presence_time = 0 :: integer(), message_shaper = none :: ejabberd_shaper:shaper(), presence_shaper = none :: ejabberd_shaper:shaper(), message :: message() | undefined, presence :: {binary(), presence()} | undefined }). -record(state, { room = <<"">> :: binary(), host = <<"">> :: binary(), server_host = <<"">> :: binary(), access = {none,none,none,none,none} :: {atom(), atom(), atom(), atom(), atom()}, jid = #jid{} :: jid(), config = #config{} :: config(), users = #{} :: users(), muc_subscribers = #muc_subscribers{} :: #muc_subscribers{}, last_voice_request_time = treap:empty() :: treap:treap(), robots = #{} :: robots(), nicks = #{} :: nicks(), affiliations = #{} :: affiliations(), roles = #{} :: roles(), history = #lqueue{} :: lqueue(), subject = [] :: [text()], subject_author = {<<"">>, #jid{}} :: {binary(), jid()}, hats_users = #{} :: map(), % FIXME on OTP 21+: #{ljid() => #{binary() => binary()}}, just_created = erlang:system_time(microsecond) :: true | integer(), activity = treap:empty() :: treap:treap(), room_shaper = none :: ejabberd_shaper:shaper(), room_queue :: p1_queue:queue({message | presence, jid()}) | undefined, hibernate_timer = none :: reference() | none | hibernating }). -type users() :: #{ljid() => #user{}}. -type robots() :: #{jid() => {binary(), stanza()}}. -type nicks() :: #{binary() => [ljid()]}. -type affiliations() :: #{ljid() => affiliation() | {affiliation(), binary()}}. -type roles() :: #{ljid() => role() | {role(), binary()}}.