feat: Routes visitor's presences to jicofo.

resources/prosody-plugins/mod_muc_visitors.lua

@@ -1,7 +1,34 @@
 local util = module:require "util";
 local is_healthcheck_room = util.is_healthcheck_room;
 local um_is_admin = require "core.usermanager".is_admin;
+local jid_node = require 'util.jid'.node;
 local jid_resource = require "util.jid".resource;
+local jid_split = require "util.jid".split;
+local st = require "util.stanza";
+
+-- Add the following config to the main muc component
+--      muc_room_default_presence_broadcast = {
+--         visitor = false;
+--         participant = true;
+--         moderator = true;
+--     };
+-- This will filter presence of visitors to be broadcast to any visitor or participant including jicofo
+-- We handle the jicofo part specially and forward the presence
+--
+-- To activate the module create a separate virtualhost, like
+-- VirtualHost "visitors.jitmeet.example.com"
+--     authentication = "anonymous"
+--     modules_enabled = {
+--         "bosh";
+--         "ping"; -- Enable mod_ping
+--         "external_services";
+--         "conference_duration";
+--         "muc_visitors";
+--     }
+--     c2s_require_encryption = false
+--     main_muc = "conference.jitmeet.example.com"
+
+local main_muc_component_config = module:get_option_string('main_muc');
 
 local function is_admin(_jid)
     return um_is_admin(_jid, module.host);
@@ -11,28 +38,68 @@ function starts_with(str, start)
     return str:sub(1, #start) == start
 end
 
-module:hook("muc-occupant-pre-join", function (event)
-    local room, occupant = event.room, event.occupant;
-
-    if is_healthcheck_room(room.jid) or is_admin(occupant.bare_jid) then
-        return;
+-- process a host module directly if loaded or hooks to wait for its load
+function process_host_module(name, callback)
+    local function process_host(host)
+        if host == name then
+            callback(module:context(host), host);
+        end
     end
 
-    local nick = jid_resource(event.occupant.nick);
---     module:log('info', 'prejoin:%s %s', nick, starts_with(nick, 'damencho'));
+    if prosody.hosts[name] == nil then
+        module:log('debug', 'No host/component found, will wait for it: %s', name)
 
-    if starts_with(nick, 'damencho') then
-        -- visitor
-        occupant.role = 'visitor';
+        -- when a host or component is added
+        prosody.events.add_handler('host-activated', process_host);
+    else
+        process_host(name);
     end
-end, 3);
+end
+process_host_module(
+    main_muc_component_config,
+    function(host_module, host)
+        main_muc_service = prosody.hosts[host].modules.muc;
 
--- module:hook("pre-stanza", function(event)
---     local stanza = event.stanza;
---
---     if stanza.name == "presence" then
--- --     string.find(stanza.attr.to, "damencho")
---         module:log('info', 'pre-stanza:%s %s', stanza.attr.to, stanza);
--- --         return true;
---     end
--- end);
+        host_module:hook('muc-occupant-pre-join', function (event)
+            local room, occupant = event.room, event.occupant;
+
+            if is_healthcheck_room(room.jid) or is_admin(occupant.bare_jid) then
+                return;
+            end
+
+            local _, host = jid_split(occupant.bare_jid);
+            if host == module.host then
+                occupant.role = 'visitor';
+            end
+        end, 3);
+
+        host_module:hook('muc-broadcast-presence', function (event)
+            local occupant = event.occupant;
+            local _, host = jid_split(occupant.bare_jid);
+
+            -- we are interested only of visitors presence to send it to jicofo
+            if host ~= module.host then
+                return;
+            end
+
+            local actor, base_presence, nick, reason, room, x
+                = event.actor, event.stanza, event.nick, event.reason, event.room, event.x;
+            for room_nick, n_occupant in room:each_occupant() do
+
+                if jid_node(n_occupant.jid) == 'focus' then
+                    local actor_nick;
+                    if actor then
+                        actor_nick = jid_resource(room:get_occupant_jid(actor));
+                    end
+
+                    local full_x = st.clone(x.full or x);
+                    room:build_item_list(occupant, full_x, false, nick, actor_nick, actor, reason);
+                    local full_p = st.clone(base_presence):add_child(full_x);
+
+                    room:route_to_occupant(n_occupant, full_p);
+                    return;
+                end
+            end
+        end);
+    end
+);