mirror of
https://github.com/processone/ejabberd.git
synced 2024-12-20 17:27:00 +01:00
02064ae12a
It's now possible to use files as internal packet queues. The following options are introduced: * queue_type: the option can be set to `ram` (default) or `file`. The option can be set per virtual host. * queue_dir: path to the directory where queues will be allocated. The default is 'queue' directory inside Mnesia directory. This is a global option and cannot be set per virtual host.
122 lines
4.8 KiB
Erlang
122 lines
4.8 KiB
Erlang
%%%----------------------------------------------------------------------
|
|
%%%
|
|
%%% ejabberd, Copyright (C) 2002-2017 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.
|
|
%%%
|
|
%%%----------------------------------------------------------------------
|
|
|
|
-include("ejabberd.hrl").
|
|
|
|
-define(MAX_USERS_DEFAULT, 200).
|
|
|
|
-define(SETS, gb_sets).
|
|
|
|
-define(DICT, dict).
|
|
|
|
-record(lqueue,
|
|
{
|
|
queue :: p1_queue:queue(),
|
|
max = 0 :: integer()
|
|
}).
|
|
|
|
-type lqueue() :: #lqueue{}.
|
|
|
|
-record(config,
|
|
{
|
|
title = <<"">> :: binary(),
|
|
description = <<"">> :: binary(),
|
|
allow_change_subj = true :: boolean(),
|
|
allow_query_users = true :: boolean(),
|
|
allow_private_messages = true :: boolean(),
|
|
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(),
|
|
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(),
|
|
captcha_whitelist = (?SETS):empty() :: ?TGB_SET,
|
|
mam = false :: boolean()
|
|
}).
|
|
|
|
-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(activity,
|
|
{
|
|
message_time = 0 :: integer(),
|
|
presence_time = 0 :: integer(),
|
|
message_shaper = none :: shaper:shaper(),
|
|
presence_shaper = none :: shaper:shaper(),
|
|
message :: message() | undefined,
|
|
presence :: {binary(), presence()} | undefined
|
|
}).
|
|
|
|
-record(state,
|
|
{
|
|
room = <<"">> :: binary(),
|
|
host = <<"">> :: binary(),
|
|
server_host = <<"">> :: binary(),
|
|
access = {none,none,none,none} :: {atom(), atom(), atom(), atom()},
|
|
jid = #jid{} :: jid(),
|
|
config = #config{} :: config(),
|
|
users = (?DICT):new() :: ?TDICT,
|
|
subscribers = (?DICT):new() :: ?TDICT,
|
|
subscriber_nicks = (?DICT):new() :: ?TDICT,
|
|
last_voice_request_time = treap:empty() :: treap:treap(),
|
|
robots = (?DICT):new() :: ?TDICT,
|
|
nicks = (?DICT):new() :: ?TDICT,
|
|
affiliations = (?DICT):new() :: ?TDICT,
|
|
history :: lqueue(),
|
|
subject = <<"">> :: binary(),
|
|
subject_author = <<"">> :: binary(),
|
|
just_created = false :: boolean(),
|
|
activity = treap:empty() :: treap:treap(),
|
|
room_shaper = none :: shaper:shaper(),
|
|
room_queue :: p1_queue:queue() | undefined
|
|
}).
|