jitsi-roomsv2/prodsody/jitsi-meet-cfg/prosody/prosody-plugins-custom/mod_jitsi_rooms.lua

---@diagnostic disable: deprecated
local it = require "util.iterators";
local json = require "util.json";
local array = require "util.array";
local iterators = require "util.iterators";
local jid = require "util.jid";
local http = require "util.http";

local async_handler_wrapper = module:require "util".async_handler_wrapper;
local get_room_from_jid = module:require "util".get_room_from_jid;
local muc_domain_prefix = module:get_option_string("muc_mapper_domain_prefix", "conference");
local domain_name = "meet.jitsi"


function get_participants_for_room(room_name)
    local room_address = jid.join(room_name, muc_domain_prefix .. "." .. domain_name);
    local decoded_room_address = http.urldecode(room_address);
    local room = get_room_from_jid(decoded_room_address);
    local occupants_json = array();
    if room then
        local occupants = room._occupants;
        if occupants then
            participant_count = iterators.count(room:each_occupant());
            for _, occupant in room:each_occupant() do
                -- filter focus as we keep it as hidden participant
                if string.sub(occupant.nick, -string.len("/focus")) ~= "/focus" then
                    for _, pr in occupant:each_session() do
                        local nick = pr:get_child_text("nick", "http://jabber.org/protocol/nick") or "";
                        local email = pr:get_child_text("email") or "";
                        local avatarURL = pr:get_child_text("avatarURL") or "" -- does not work :(
                        occupants_json:push({
                            jid = tostring(occupant.nick),
                            email = tostring(email),
                            displayName = tostring(nick),
                            avatarURL = tostring(avatarURL)
                        });
                    end
                end
            end
        end
        log("debug",
            "there are %s occupants in room", tostring(participant_count));
        return occupants_json
    else
        log("debug", "no such room exists");
    end
    return occupants_json
end

function get_all_rooms_with_participants()
    local sessions = prosody.full_sessions;

    local someTable = (it.join(it.keys(sessions)));
    local actual_rooms = someTable[1][2]

    local roomNames = {}
    for _, v in pairs(actual_rooms) do
        local roomName = v["jitsi_web_query_room"]
        if (roomName ~= nil) then
            roomNames[roomName] = true;
        end
    end

    local rooms_with_participants = array();
    for room_name, _ in pairs(roomNames) do
        local room = { roomName = room_name, participants = get_participants_for_room(room_name) }
        rooms_with_participants:push(room)
    end
    return json.encode(rooms_with_participants)
end

--- Handles request for retrieving the room participants details
-- @param event the http event, holds the request query
-- @return GET response, containing a json with participants details
function handle_get_sessions(event)
    handle_room_event()
    return { status_code = 200, body = get_all_rooms_with_participants() };
end

function module.load()
    -- Ensure that mod_http is loaded:
    --
    module:depends("http");

    -- Now publish our HTTP 'app':
    module:log("info", "Hello! You can reach me at: %s", module:http_url());
    module:provides("http", {
        route = {
            ["GET"] = function(event) return async_handler_wrapper(event, handle_get_sessions) end,

        },
    });
end

-------- event stuff
--
--
--
--
--
--
--
--
--

local http = require "net.http";
local is_healthcheck_room = module:require "util".is_healthcheck_room;
--- Start non-blocking HTTP call
-- @param url URL to call
-- @param options options table as expected by net.http where we provide optional headers, body or method.
local function async_http_request(url, options)
    local completed = false;
    local timed_out = false;

    local function cb_(response_body, response_code)
        if not timed_out then -- request completed before timeout
            completed = true;

            module:log("debug", "%s %s returned code %s", options.method, url, response_code);
        end
    end

    http.request(url, options, cb_);
end

--- Checks if event is triggered by healthchecks or focus user.
function is_system_event(event)
    if event == nil or event.room == nil or event.room.jid == nil then
        return true;
    end

    if is_healthcheck_room(event.room.jid) then
        return true;
    end

    if event.occupant and jid.node(event.occupant.jid) == "focus" then
        return true;
    end

    return false;
end

function handle_room_event(event)
    module:log('info', "hallo irgendwas ist passiert");
    if is_system_event(event) then
        return;
    end

    async_http_request("http://jitsi-rooms:8081/roomdata",
        {
            method = "POST",
            body = get_all_rooms_with_participants()
        })
end

--Helper function to wait till a component is loaded before running the given callback
function run_when_component_loaded(component_host_name, callback)
    local function trigger_callback()
        module:log('info', 'Component loaded %s', component_host_name);
        callback(module:context(component_host_name), component_host_name);
    end

    if prosody.hosts[component_host_name] == nil then
        module:log('debug', 'Host %s not yet loaded. Will trigger when it is loaded.', component_host_name);
        prosody.events.add_handler('host-activated', function(host)
            if host == component_host_name then
                trigger_callback();
            end
        end);
    else
        trigger_callback();
    end
end

-- Helper function to wait till a component's muc module is loaded before running the given callback
function run_when_muc_module_loaded(component_host_module, component_host_name, callback)
    local function trigger_callback()
        module:log('info', 'MUC module loaded for %s', component_host_name);
        callback(prosody.hosts[component_host_name].modules.muc, component_host_module);
    end

    if prosody.hosts[component_host_name].modules.muc == nil then
        module:log('debug', 'MUC module for %s not yet loaded. Will trigger when it is loaded.', component_host_name);
        prosody.hosts[component_host_name].events.add_handler('module-loaded', function(event)
            if (event.module == 'muc') then
                trigger_callback();
            end
        end);
    else
        trigger_callback()
    end
end

local main_muc_component_host = muc_domain_prefix .. "." .. domain_name
-- Handle events on main muc module
run_when_component_loaded(main_muc_component_host, function(host_module, host_name)
    run_when_muc_module_loaded(host_module, host_name, function(main_muc, main_module)
        main_muc_service = main_muc; -- so it can be accessed from breakout muc event handlers

        -- the following must run after speakerstats (priority -1)
        main_module:hook("muc-room-created", handle_room_event, -3); -- must run after handle_main_room_created
        main_module:hook("muc-occupant-joined", handle_room_event, -2);
        main_module:hook("muc-occupant-left", handle_room_event, -2);
        main_module:hook("muc-room-destroyed", handle_room_event, -2);
    end);
end);