cleaning up some issues with multitenancy support

big_tests/dynamic_domains.spec

@@ -50,6 +50,8 @@
 
 {suites, "tests", offline_stub_SUITE}.
 
+{suites, "tests", domain_isolation_SUITE}.
+
 {suites, "tests", sm_SUITE}.
 {skip_cases, "tests", sm_SUITE,
  [basic_ack,

doc/modules/mod_domain_isolation.md

@@ -1,14 +1,3 @@
 ## Module Description
 
 This module limits message passing between domains.
-
-## Options
-
-### `modules.mod_domain_isolation.extra_domains`
-
-Allows to specify more domains, the rules are applied to.
-No filtering is done to subdomains, unless they are specified in the `extra_domains` list.
-
- * **Syntax:** a list of domain templates (as lists)
- * **Default:** `[]`
- * **Example:** `extra_domains = ["muclight.@HOST@"]`

include/mongoose.hrl

@@ -22,7 +22,7 @@
 %% If the ejabberd application description isn't loaded, returns atom: undefined
 -define(MONGOOSE_VERSION, element(2, application:get_key(mongooseim,vsn))).
 
--define(MYHOSTS, ejabberd_config:get_global_option(hosts)).
+-define(MYHOSTS, ejabberd_config:get_global_option_or_default(hosts, [])).
 -define(ALL_HOST_TYPES, ejabberd_config:get_global_option_or_default(hosts, []) ++
                         ejabberd_config:get_global_option_or_default(host_types, [])).
 -define(MYNAME,  ejabberd_config:get_global_option(default_server_domain)).

src/gen_mod.erl

@@ -140,6 +140,7 @@ start_module_for_host_type(HostType, Module, Opts0) ->
     try
         lists:map(fun mongoose_service:assert_loaded/1,
                   get_required_services(HostType, Module, Opts)),
+        check_dynamic_domains_support(HostType, Module),
         Res = Module:start(HostType, Opts),
         {links, LinksAfter} = erlang:process_info(self(), links),
         case lists:sort(LinksBefore) =:= lists:sort(LinksAfter) of
@@ -186,6 +187,17 @@ start_module_for_host_type(HostType, Module, Opts0) ->
             end
     end.
 
+check_dynamic_domains_support(HostType, Module) ->
+    case lists:member(HostType, ?MYHOSTS) of
+        true -> ok;
+        false ->
+            case gen_mod:does_module_support(Module, dynamic_domains) of
+                true -> ok;
+                false ->
+                    error({Module, HostType, dynamic_domains_feature_is_not_supported})
+            end
+    end.
+
 is_mim_or_ct_running() ->
     ?MODULE:is_app_running(mongooseim)
     %% Common tests would be very confused if we kill the whole node

src/mam/mod_mam.erl

@@ -42,7 +42,7 @@
          archive_id/2]).
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% ejabberd handlers
 -export([disco_local_features/1,
@@ -211,6 +211,10 @@ stop(HostType) ->
     remove_iq_handlers(HostType),
     ok.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 %% ----------------------------------------------------------------------
 %% hooks and handlers
 

src/mam/mod_mam_cache_user.erl

@@ -17,7 +17,7 @@
 -behaviour(mongoose_module_metrics).
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% ejabberd handlers
 -export([cached_archive_id/3,
@@ -55,7 +55,6 @@ su_key(#jid{lserver = LServer, luser = LUser}) ->
 %% ----------------------------------------------------------------------
 %% gen_mod callbacks
 %% Starting and stopping functions for users' archives
-
 -spec start(HostType :: mongooseim:host_type(), Opts :: gen_mod:module_opts()) -> ok.
 start(HostType, _Opts) ->
     start_server(),
@@ -67,6 +66,10 @@ stop(HostType) ->
     ejabberd_hooks:delete(hooks(HostType)),
     ok.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 writer_child_spec() ->
     MFA = {?MODULE, start_link, []},
     {?MODULE, MFA, permanent, 5000, worker, [?MODULE]}.

src/mam/mod_mam_meta.erl

@@ -20,7 +20,7 @@
 
 -type deps() :: #{module() => proplists:proplist()}.
 
--export([start/2, stop/1, config_spec/0,
+-export([start/2, stop/1, config_spec/0, supported_features/0,
          deps/2, get_mam_module_configuration/3, get_mam_module_opt/4]).
 
 -export([config_metrics/1]).
@@ -31,6 +31,10 @@
 %% API
 %%--------------------------------------------------------------------
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 -spec start(Host :: jid:server(), Opts :: list()) -> any().
 start(_Host, _Opts) ->
     ok.

src/mam/mod_mam_mnesia_prefs.erl

@@ -13,7 +13,7 @@
 %% Exports
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% MAM hook handlers
 -behaviour(ejabberd_gen_mam_prefs).
@@ -73,6 +73,9 @@ stop(Host) ->
             ok
     end.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
 
 %% ----------------------------------------------------------------------
 %% Add hooks for mod_mam

src/mam/mod_mam_muc.erl

@@ -40,7 +40,7 @@
          archive_id/2]).
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% ejabberd room handlers
 -export([disco_muc_features/1,
@@ -158,6 +158,10 @@ stop(HostType) ->
     remove_iq_handlers(HostType),
     ok.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 %% ----------------------------------------------------------------------
 %% hooks and handlers for MUC
 

src/mam/mod_mam_muc_cache_user.erl

@@ -1,7 +1,7 @@
 -module(mod_mam_muc_cache_user).
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% ejabberd handlers
 -export([cached_archive_id/3,
@@ -49,6 +49,10 @@ stop(HostType) ->
     clean_mnesia(HostType),
     ok.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 %% ----------------------------------------------------------------------
 %% Init
 

src/mam/mod_mam_muc_rdbms_arch.erl

@@ -10,7 +10,7 @@
 %% Exports
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% MAM hook handlers
 -behaviour(ejabberd_gen_mam_archive).
@@ -61,6 +61,10 @@ start(HostType, _Opts) ->
 stop(HostType) ->
     stop_hooks(HostType).
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 -spec get_mam_muc_gdpr_data(ejabberd_gen_mam_archive:mam_pm_gdpr_data(),
                             host_type(), jid:jid()) ->
     ejabberd_gen_mam_archive:mam_muc_gdpr_data().

src/mam/mod_mam_muc_rdbms_async_pool_writer.erl

@@ -10,7 +10,7 @@
 %% Exports
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% MAM hook handlers
 -behaviour(ejabberd_gen_mam_archive).
@@ -95,6 +95,10 @@ stop(HostType) ->
     stop_muc(HostType),
     stop_workers(HostType).
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 %% ----------------------------------------------------------------------
 %% Add hooks for mod_mam_muc
 

src/mam/mod_mam_rdbms_arch.erl

@@ -10,7 +10,7 @@
 %% Exports
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% MAM hook handlers
 -behaviour(ejabberd_gen_mam_archive).
@@ -76,6 +76,10 @@ start(HostType, Opts) ->
 stop(HostType) ->
     stop_hooks(HostType).
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 -spec get_mam_pm_gdpr_data(ejabberd_gen_mam_archive:mam_pm_gdpr_data(),
                            host_type(), jid:jid()) ->
     ejabberd_gen_mam_archive:mam_pm_gdpr_data().

src/mam/mod_mam_rdbms_async_pool_writer.erl

@@ -21,7 +21,7 @@
 %% Exports
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% MAM hook handlers
 -behaviour(ejabberd_gen_mam_archive).
@@ -119,6 +119,10 @@ stop(HostType) ->
     end,
     stop_workers(HostType).
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 %% ----------------------------------------------------------------------
 %% Add hooks for mod_mam
 

src/mam/mod_mam_rdbms_prefs.erl

@@ -10,7 +10,7 @@
 %% Exports
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% MAM hook handlers
 -behaviour(ejabberd_gen_mam_prefs).
@@ -34,7 +34,6 @@
 %% ----------------------------------------------------------------------
 %% gen_mod callbacks
 %% Starting and stopping functions for users' archives
-
 -spec start(mongooseim:host_type(), _) -> ok.
 start(HostType, _Opts) ->
     prepare_queries(HostType),
@@ -46,6 +45,10 @@ stop(HostType) ->
     ejabberd_hooks:delete(hooks(HostType)),
     ok.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 hooks(HostType) ->
     PM = gen_mod:get_module_opt(HostType, ?MODULE, pm, false),
     MUC = gen_mod:get_module_opt(HostType, ?MODULE, muc, false),

src/mam/mod_mam_rdbms_user.erl

@@ -11,7 +11,7 @@
 -module(mod_mam_rdbms_user).
 
 %% gen_mod handlers
--export([start/2, stop/1]).
+-export([start/2, stop/1, supported_features/0]).
 
 %% ejabberd handlers
 -export([archive_id/3,
@@ -25,7 +25,6 @@
 
 %% ----------------------------------------------------------------------
 %% gen_mod callbacks
-
 -spec start(mongooseim:host_type(), gen_mod:module_opts()) -> ok.
 start(HostType, _Opts) ->
     prepare_queries(),
@@ -37,6 +36,10 @@ stop(HostType) ->
     ejabberd_hooks:delete(hooks(HostType)),
     ok.
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    [dynamic_domains].
+
 hooks(HostType) ->
     [{Hook, HostType, ?MODULE, Fun, N}
      || {true, Hook, Fun, N} <- hooks2(HostType)].

src/mod_commands.erl

@@ -4,7 +4,7 @@
 -behaviour(gen_mod).
 -behaviour(mongoose_module_metrics).
 
--export([start/0, stop/0,
+-export([start/0, stop/0, supported_features/0,
          start/2, stop/1,
          register/3,
          unregister/2,
@@ -43,6 +43,13 @@ stop() ->
 start(_, _) -> start().
 stop(_) -> stop().
 
+-spec supported_features() -> [atom()].
+supported_features() ->
+    %% TODO: this module should be reworked into service
+    %% from the quick look it seems that the conversion for dynamic domains is done,
+    %% but there's no testing for this module enabled at dynamic_domains.spec yet.
+    [dynamic_domains].
+
 %%%
 %%% mongoose commands
 %%%
@@ -504,8 +511,8 @@ run_subscription(Type, CallerJid, OtherJid) ->
                                lserver => LServer,
                                element => El }),
     % set subscription to
-    Acc2 = mongoose_hooks:roster_out_subscription(
-             LServer, Acc1, CallerJid, OtherJid, Type),
+    Acc2 = mongoose_hooks:roster_out_subscription(HostType, Acc1, CallerJid,
+                                                  OtherJid, Type),
     ejabberd_router:route(CallerJid, OtherJid, Acc2),
     ok.