379 lines
13 KiB
Lua
379 lines
13 KiB
Lua
-- This module added under the main virtual host domain
|
|
-- It needs a lobby muc component
|
|
--
|
|
-- VirtualHost "jitmeet.example.com"
|
|
-- modules_enabled = {
|
|
-- "muc_lobby_rooms"
|
|
-- }
|
|
-- lobby_muc = "lobby.jitmeet.example.com"
|
|
-- main_muc = "conference.jitmeet.example.com"
|
|
--
|
|
-- Component "lobby.jitmeet.example.com" "muc"
|
|
-- storage = "memory"
|
|
-- muc_room_cache_size = 1000
|
|
-- restrict_room_creation = true
|
|
-- muc_room_locking = false
|
|
-- muc_room_default_public_jids = true
|
|
--
|
|
-- we use async to detect Prosody 0.10 and earlier
|
|
local have_async = pcall(require, 'util.async');
|
|
|
|
if not have_async then
|
|
module:log('warn', 'Lobby rooms will not work with Prosody version 0.10 or less.');
|
|
return;
|
|
end
|
|
|
|
local formdecode = require "util.http".formdecode;
|
|
local jid_split = require 'util.jid'.split;
|
|
local jid_bare = require 'util.jid'.bare;
|
|
local json = require 'util.json';
|
|
local filters = require 'util.filters';
|
|
local st = require 'util.stanza';
|
|
local MUC_NS = 'http://jabber.org/protocol/muc';
|
|
local DISCO_INFO_NS = 'http://jabber.org/protocol/disco#info';
|
|
local DISPLAY_NAME_REQUIRED_FEATURE = 'http://jitsi.org/protocol/lobbyrooms#displayname_required';
|
|
local LOBBY_IDENTITY_TYPE = 'lobbyrooms';
|
|
local NOTIFY_JSON_MESSAGE_TYPE = 'lobby-notify';
|
|
local NOTIFY_LOBBY_ENABLED = 'LOBBY-ENABLED';
|
|
local NOTIFY_LOBBY_ACCESS_GRANTED = 'LOBBY-ACCESS-GRANTED';
|
|
local NOTIFY_LOBBY_ACCESS_DENIED = 'LOBBY-ACCESS-DENIED';
|
|
|
|
local is_healthcheck_room = module:require 'util'.is_healthcheck_room;
|
|
|
|
local main_muc_component_config = module:get_option_string('main_muc');
|
|
if main_muc_component_config == nil then
|
|
module:log('error', 'lobby not enabled missing main_muc config');
|
|
return ;
|
|
end
|
|
local lobby_muc_component_config = module:get_option_string('lobby_muc');
|
|
if lobby_muc_component_config == nil then
|
|
module:log('error', 'lobby not enabled missing lobby_muc config');
|
|
return ;
|
|
end
|
|
|
|
local whitelist;
|
|
local check_display_name_required;
|
|
local function load_config()
|
|
whitelist = module:get_option_set('muc_lobby_whitelist', {});
|
|
check_display_name_required
|
|
= module:get_option_boolean('muc_lobby_check_display_name_required', true);
|
|
end
|
|
load_config();
|
|
|
|
local lobby_muc_service;
|
|
local main_muc_service;
|
|
|
|
-- Checks whether there is status in the <x node
|
|
function check_status(muc_x, status)
|
|
if not muc_x then
|
|
return false;
|
|
end
|
|
|
|
for statusNode in muc_x:childtags('status') do
|
|
if statusNode.attr.code == status then
|
|
return true;
|
|
end
|
|
end
|
|
|
|
return false;
|
|
end
|
|
|
|
function broadcast_json_msg(room, from, json_msg)
|
|
json_msg.type = NOTIFY_JSON_MESSAGE_TYPE;
|
|
|
|
local occupant = room:get_occupant_by_real_jid(from);
|
|
if occupant then
|
|
room:broadcast_message(
|
|
st.message({ type = 'groupchat', from = occupant.nick })
|
|
:tag('json-message', {xmlns='http://jitsi.org/jitmeet'})
|
|
:text(json.encode(json_msg)):up());
|
|
end
|
|
end
|
|
|
|
-- Sends a json message notifying for lobby enabled/disable
|
|
-- the message from is the actor that did the operation
|
|
function notify_lobby_enabled(room, actor, value)
|
|
broadcast_json_msg(room, actor, {
|
|
event = NOTIFY_LOBBY_ENABLED,
|
|
value = value
|
|
});
|
|
end
|
|
|
|
-- Sends a json message notifying that the jid was granted/denied access in lobby
|
|
-- the message from is the actor that did the operation
|
|
function notify_lobby_access(room, actor, jid, granted)
|
|
local notify_json = {
|
|
value = jid
|
|
};
|
|
if granted then
|
|
notify_json.event = NOTIFY_LOBBY_ACCESS_GRANTED;
|
|
else
|
|
notify_json.event = NOTIFY_LOBBY_ACCESS_DENIED;
|
|
end
|
|
|
|
broadcast_json_msg(room, actor, notify_json);
|
|
end
|
|
|
|
function filter_stanza(stanza)
|
|
if not stanza.attr or not stanza.attr.from or not main_muc_service then
|
|
return stanza;
|
|
end
|
|
-- Allow self-presence (code=110)
|
|
local node, from_domain = jid_split(stanza.attr.from);
|
|
|
|
if from_domain == lobby_muc_component_config then
|
|
if stanza.name == 'presence' then
|
|
local muc_x = stanza:get_child('x', MUC_NS..'#user');
|
|
|
|
if check_status(muc_x, '110') then
|
|
return stanza;
|
|
end
|
|
|
|
-- check is an owner, only owners can receive the presence
|
|
local room = main_muc_service.get_room_from_jid(jid_bare(node .. '@' .. main_muc_component_config));
|
|
if room.get_affiliation(room, stanza.attr.to) == 'owner' then
|
|
return stanza;
|
|
end
|
|
|
|
return nil;
|
|
elseif stanza.name == 'iq' and stanza:get_child('query', DISCO_INFO_NS) then
|
|
-- allow disco info from the lobby component
|
|
return stanza;
|
|
end
|
|
|
|
return nil;
|
|
else
|
|
return stanza;
|
|
end
|
|
end
|
|
function filter_session(session)
|
|
if session.host and session.host == module.host then
|
|
-- domain mapper is filtering on default priority 0, and we need it after that
|
|
filters.add_filter(session, 'stanzas/out', filter_stanza, -1);
|
|
end
|
|
end
|
|
|
|
-- 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
|
|
|
|
if prosody.hosts[name] == nil then
|
|
module:log('debug', 'No host/component found, will wait for it: %s', name)
|
|
|
|
-- when a host or component is added
|
|
prosody.events.add_handler('host-activated', process_host);
|
|
else
|
|
process_host(name);
|
|
end
|
|
end
|
|
|
|
-- operates on already loaded lobby muc module
|
|
function process_lobby_muc_loaded(lobby_muc, host_module)
|
|
module:log('debug', 'Lobby muc loaded');
|
|
lobby_muc_service = lobby_muc;
|
|
|
|
-- enable filtering presences in the lobby muc rooms
|
|
filters.add_filter_hook(filter_session);
|
|
|
|
-- Advertise lobbyrooms support on main domain so client can pick up the address and use it
|
|
module:add_identity('component', LOBBY_IDENTITY_TYPE, lobby_muc_component_config);
|
|
|
|
-- Tag the disco#info response with a feature that display name is required
|
|
-- when the conference name from the web request has a lobby enabled.
|
|
host_module:hook('host-disco-info-node', function (event)
|
|
local session, reply, node = event.origin, event.reply, event.node;
|
|
if node == LOBBY_IDENTITY_TYPE
|
|
and session.jitsi_web_query_room
|
|
and main_muc_service
|
|
and check_display_name_required then
|
|
local room = main_muc_service.get_room_from_jid(
|
|
jid_bare(session.jitsi_web_query_room .. '@' .. main_muc_component_config));
|
|
if room and room._data.lobbyroom then
|
|
reply:tag('feature', { var = DISPLAY_NAME_REQUIRED_FEATURE }):up();
|
|
end
|
|
end
|
|
event.exists = true;
|
|
end);
|
|
|
|
local room_mt = lobby_muc_service.room_mt;
|
|
-- we base affiliations (roles) in lobby muc component to be based on the roles in the main muc
|
|
room_mt.get_affiliation = function(room, jid)
|
|
if not room.main_room then
|
|
module:log('error', 'No main room(%s) for %s!', room.jid, jid);
|
|
return 'none';
|
|
end
|
|
|
|
-- moderators in main room are moderators here
|
|
local role = room.main_room.get_affiliation(room.main_room, jid);
|
|
if role then
|
|
return role;
|
|
end
|
|
|
|
return 'none';
|
|
end
|
|
|
|
-- listens for kicks in lobby room, 307 is the status for kick according to xep-0045
|
|
host_module:hook('muc-broadcast-presence', function (event)
|
|
local actor, occupant, room, x = event.actor, event.occupant, event.room, event.x;
|
|
if check_status(x, '307') then
|
|
-- we need to notify in the main room
|
|
notify_lobby_access(room.main_room, actor, occupant.nick, false);
|
|
end
|
|
end);
|
|
end
|
|
|
|
-- process or waits to process the lobby muc component
|
|
process_host_module(lobby_muc_component_config, function(host_module, host)
|
|
-- lobby muc component created
|
|
module:log('info', 'Lobby component loaded %s', host);
|
|
|
|
local muc_module = prosody.hosts[host].modules.muc;
|
|
if muc_module then
|
|
process_lobby_muc_loaded(muc_module, host_module);
|
|
else
|
|
module:log('debug', 'Will wait for muc to be available');
|
|
prosody.hosts[host].events.add_handler('module-loaded', function(event)
|
|
if (event.module == 'muc') then
|
|
process_lobby_muc_loaded(prosody.hosts[host].modules.muc, host_module);
|
|
end
|
|
end);
|
|
end
|
|
end);
|
|
|
|
-- process or waits to process the main muc component
|
|
process_host_module(main_muc_component_config, function(host_module, host)
|
|
main_muc_service = prosody.hosts[host].modules.muc;
|
|
|
|
-- hooks when lobby is enabled to create its room, only done here or by admin
|
|
host_module:hook('muc-config-submitted', function(event)
|
|
local actor, room = event.actor, event.room;
|
|
local members_only = event.fields['muc#roomconfig_membersonly'] and true or nil;
|
|
if members_only then
|
|
local node = jid_split(room.jid);
|
|
|
|
local lobby_room_jid = node .. '@' .. lobby_muc_component_config;
|
|
if not lobby_muc_service.get_room_from_jid(lobby_room_jid) then
|
|
local new_room = lobby_muc_service.create_room(lobby_room_jid);
|
|
new_room.main_room = room;
|
|
room._data.lobbyroom = new_room;
|
|
event.status_codes['104'] = true;
|
|
notify_lobby_enabled(room, actor, true);
|
|
end
|
|
elseif room._data.lobbyroom then
|
|
room._data.lobbyroom:destroy(room.jid, 'Lobby room closed.');
|
|
room._data.lobbyroom = nil;
|
|
notify_lobby_enabled(room, actor, false);
|
|
end
|
|
end);
|
|
host_module:hook('muc-room-destroyed',function(event)
|
|
local room = event.room;
|
|
if room._data.lobbyroom then
|
|
room._data.lobbyroom:destroy(nil, 'Lobby room closed.');
|
|
room._data.lobbyroom = nil;
|
|
end
|
|
end);
|
|
host_module:hook('muc-disco#info', function (event)
|
|
local room = event.room;
|
|
if (room._data.lobbyroom and room:get_members_only()) then
|
|
table.insert(event.form, {
|
|
name = 'muc#roominfo_lobbyroom';
|
|
label = 'Lobby room jid';
|
|
value = '';
|
|
});
|
|
event.formdata['muc#roominfo_lobbyroom'] = room._data.lobbyroom.jid;
|
|
end
|
|
end);
|
|
|
|
host_module:hook('muc-occupant-pre-join', function (event)
|
|
local room, stanza = event.room, event.stanza;
|
|
|
|
if is_healthcheck_room(room.jid) or not room:get_members_only() then
|
|
return;
|
|
end
|
|
|
|
local join = stanza:get_child('x', MUC_NS);
|
|
if not join then
|
|
return;
|
|
end
|
|
|
|
local invitee = event.stanza.attr.from;
|
|
local invitee_bare_jid = jid_bare(invitee);
|
|
local _, invitee_domain = jid_split(invitee);
|
|
local whitelistJoin = false;
|
|
|
|
-- whitelist participants
|
|
if whitelist:contains(invitee_domain) or whitelist:contains(invitee_bare_jid) then
|
|
whitelistJoin = true;
|
|
end
|
|
|
|
local password = join:get_child_text('password', MUC_NS);
|
|
if password and room:get_password() and password == room:get_password() then
|
|
whitelistJoin = true;
|
|
end
|
|
|
|
if whitelistJoin then
|
|
local affiliation = room:get_affiliation(invitee);
|
|
if not affiliation or affiliation == 0 then
|
|
event.occupant.role = 'participant';
|
|
room:set_affiliation(true, invitee_bare_jid, 'member');
|
|
room:save();
|
|
|
|
return;
|
|
end
|
|
end
|
|
|
|
-- we want to add the custom lobbyroom field to fill in the lobby room jid
|
|
local invitee = event.stanza.attr.from;
|
|
local affiliation = room:get_affiliation(invitee);
|
|
if not affiliation or affiliation == 'none' then
|
|
local reply = st.error_reply(stanza, 'auth', 'registration-required'):up();
|
|
reply.tags[1].attr.code = '407';
|
|
reply:tag('x', {xmlns = MUC_NS}):up();
|
|
reply:tag('lobbyroom'):text(room._data.lobbyroom.jid);
|
|
event.origin.send(reply:tag('x', {xmlns = MUC_NS}));
|
|
return true;
|
|
end
|
|
end, -4); -- the default hook on members_only module is on -5
|
|
|
|
-- listens for invites for participants to join the main room
|
|
host_module:hook('muc-invite', function(event)
|
|
local room, stanza = event.room, event.stanza;
|
|
local invitee = stanza.attr.to;
|
|
local from = stanza:get_child('x', 'http://jabber.org/protocol/muc#user')
|
|
:get_child('invite').attr.from;
|
|
|
|
if room._data.lobbyroom then
|
|
local occupant = room._data.lobbyroom:get_occupant_by_real_jid(invitee);
|
|
if occupant then
|
|
notify_lobby_access(room, from, occupant.nick, true);
|
|
end
|
|
end
|
|
end);
|
|
end);
|
|
|
|
-- Extract 'room' param from URL when session is created
|
|
function update_session(event)
|
|
local session = event.session;
|
|
|
|
if session.jitsi_web_query_room then
|
|
-- no need for an update
|
|
return;
|
|
end
|
|
|
|
local query = event.request.url.query;
|
|
if query ~= nil then
|
|
local params = formdecode(query);
|
|
-- The room name and optional prefix from the web query
|
|
session.jitsi_web_query_room = params.room;
|
|
session.jitsi_web_query_prefix = params.prefix or '';
|
|
end
|
|
end
|
|
|
|
module:hook_global('bosh-session', update_session);
|
|
module:hook_global('websocket-session', update_session);
|
|
module:hook_global('config-reloaded', load_config);
|