mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 13:47:41 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Access get_services from external modules.

Browse source 
Other modules can use module:depends("external_services").get_services;
Based on f4c8310ea7
This commit is contained in:
damencho 2021-06-16 10:19:00 -05:00
parent aa041ffa10
commit 37aba611c8
1 changed files with 41 additions and 30 deletions
Download patch file Download diff file Expand all files Collapse all files

71
plugins/mod_external_services.lua
View file

@ -114,6 +114,45 @@ local services_mt = {
end; end;
} }
function get_services(requested_type, origin, stanza, reply)
local extras = module:get_host_items("external_service");
local services = ( configured_services + extras ) / prepare;
if requested_type then
services:filter(function(item)
return item.type == requested_type;
end);
end
setmetatable(services, services_mt);
if origin and stanza and reply then
module:fire_event("external_service/services", {
origin = origin;
stanza = stanza;
reply = reply;
requested_type = requested_type;
services = services;
});
end
local res_services = {};
for _, srv in ipairs(services) do
table.insert(res_services, {
type = srv.type;
transport = srv.transport;
host = srv.host;
port = srv.port and string.format("%d", srv.port) or nil;
username = srv.username;
password = srv.password;
expires = srv.expires and dt.datetime(srv.expires) or nil;
restricted = srv.restricted and "1" or nil;
})
end
return res_services;
end
local function handle_services(event) local function handle_services(event)
local origin, stanza = event.origin, event.stanza; local origin, stanza = event.origin, event.stanza;
local action = stanza.tags[1]; local action = stanza.tags[1];
@ -126,37 +165,9 @@ local function handle_services(event)
end end
local reply = st.reply(stanza):tag("services", { xmlns = action.attr.xmlns }); local reply = st.reply(stanza):tag("services", { xmlns = action.attr.xmlns });
local extras = module:get_host_items("external_service");
local services = ( configured_services + extras ) / prepare;
local requested_type = action.attr.type; for _, srv in ipairs(get_services(action.attr.type, origin, stanza, reply)) do
if requested_type then reply:tag("service", srv):up();
services:filter(function(item)
return item.type == requested_type;
end);
end
setmetatable(services, services_mt);
module:fire_event("external_service/services", {
origin = origin;
stanza = stanza;
reply = reply;
requested_type = requested_type;
services = services;
});
for _, srv in ipairs(services) do
reply:tag("service", {
type = srv.type;
transport = srv.transport;
host = srv.host;
port = srv.port and string.format("%d", srv.port) or nil;
username = srv.username;
password = srv.password;
expires = srv.expires and dt.datetime(srv.expires) or nil;
restricted = srv.restricted and "1" or nil;
}):up();
end end
origin.send(reply); origin.send(reply);