Mercurial > prosody-modules

comparison mod_muc_http_defaults/mod_muc_http_defaults.lua @ 4447:07aa101a1ae7

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mod_muc_http_defaults: Get MUC room config from an API
author Kim Alvefur <zash@zash.se>
date Fri, 19 Feb 2021 16:01:41 +0100
parents
children 5879ca1f7853
comparison
equal deleted inserted replaced
4446:3d593b612e07 4447:07aa101a1ae7
1 -- Copyright (C) 2021 Kim Alvefur
2 --
3 -- This file is MIT licensed. Please see the
4 -- COPYING file in the source package for more information.
5 --
6
7 local http = require "net.http";
8 local httperr = require "net.http.errors";
9 local async = require "util.async";
10 local errors = require "util.error";
11 local uh = require "util.http";
12 local jid = require "util.jid";
13 local json = require "util.json";
14 local st = require "util.stanza";
15
16 local render = require "util.interpolation".new("%b{}", uh.urlencode);
17
18 module:depends"muc";
19
20 local url_template = assert(module:get_option_string("muc_create_api_url", nil), "'muc_create_api_url' is a required option");
21 local apiauth = module:get_option_string("muc_create_api_auth", nil);
22
23 local ex = {
24 headers = {
25 accept = "application/json";
26 authorization = apiauth;
27 }
28 };
29
30 local function check_status(response)
31 if math.floor(response.code/100) > 2 then
32 error(httperr.new(response.code, response.body));
33 end
34 return response;
35 end
36
37 local problems = errors.init(module.name, {
38 format = { type = "cancel", condition = "internal-server-error", text = "API server returned invalid data, see logs" },
39 config = { type = "cancel", condition = "internal-server-error", text = "A problem occured while creating the room, see logs" },
40 });
41
42 local function get_json(response)
43 return assert(json.decode(response.body), problems.new("format"));
44 end
45
46 local function apply_config(room, settings)
47 local affiliations = settings.affiliations;
48 if type(affiliations) == "table" then
49
50 -- COMPAT the room creator is unconditionally made 'owner'
51 -- clear existing affiliation
52 for existing_affiliation in pairs(room._affiliation) do
53 room:set_affiliation(true, existing_affiliation, "none");
54 end
55
56 if affiliations[1] ~= nil then -- array of ( jid, affiliation, nick )
57 for _, aff in ipairs(affiliations) do
58 if type(aff) == "table" and type(aff.jid) == "string" and (aff.nick == nil or type(aff.nick) == "string") then
59 local prepped_jid = jid.prep(aff.jid);
60 if prepped_jid then
61 local ok, err = room:set_affiliation(true, prepped_jid, aff.affiliation, aff.nick and { nick = aff.nick });
62 if not ok then
63 module:log("error", "Could not set affiliation in %s: %s", room.jid, err);
64 return nil, problems.new("config");
65 end
66 else
67 module:log("error", "Invalid JID returned from API for %s: %q", room.jid, aff.jid);
68 return nil, problems.new("format");
69 end
70 else
71 module:log("error", "Invalid affiliation item returned from API for %s: %q", room.jid, aff);
72 return nil, problems.new("format");
73 end
74 end
75 else -- map of jid : affiliation
76 for user_jid, aff in pairs(affiliations) do
77 if type(user_jid) == "string" and type(aff) == "string" then
78 local prepped_jid = jid.prep(user_jid);
79 if prepped_jid then
80 local ok, err = room:set_affiliation(true, prepped_jid, aff);
81 if not ok then
82 module:log("error", "Could not set affiliation in %s: %s", room.jid, err);
83 return nil, problems.new("config");
84 end
85 else
86 module:log("error", "Invalid JID returned from API: %q", aff.jid);
87 return nil, problems.new("format");
88 end
89 end
90 end
91 end
92 elseif affiliations ~= nil then
93 module:log("error", "Invalid affiliations returned from API for %s: %q", room.jid, affiliations);
94 return nil, problems.new("format", { field = "affiliations" });
95 end
96
97 local config = settings.config;
98 if type(config) == "table" then
99 -- TODO reject invalid fields instead of ignoring them
100 if type(config.name) == "string" then room:set_name(config.name); end
101 if type(config.description) == "string" then room:set_description(config.description); end
102 if type(config.language) == "string" then room:set_language(config.language); end
103 if type(config.password) == "string" then room:set_password(config.password); end
104 if type(config.subject) == "string" then room:set_subject(config.subject); end
105
106 if type(config.public) == "boolean" then room:set_public(config.public); end
107 if type(config.members_only) == "boolean" then room:set_members_only(config.members_only); end
108 if type(config.allow_member_invites) == "boolean" then room:set_allow_member_invites(config.allow_member_invites); end
109 if type(config.moderated) == "boolean" then room:set_moderated(config.moderated); end
110 if type(config.persistent) == "boolean" then room:set_persistent(config.persistent); end
111 if type(config.changesubject) == "boolean" then room:set_changesubject(config.changesubject); end
112
113 if type(config.historylength) == "number" then room:set_historylength(config.historylength); end
114 if type(config.public_jids) == "boolean" then room:set_whois(config.public_jids and "anyone" or "moderators"); end
115 -- Leaving out presence_broadcast for now
116
117 -- mod_muc_mam
118 if type(config.archiving) == "boolean" then room._config.archiving = config.archiving; end
119 elseif config ~= nil then
120 module:log("error", "Invalid config returned from API for %s: %q", room.jid, config);
121 return nil, problems.new("format", { field = "config" });
122 end
123 return true;
124 end
125
126 module:hook("muc-room-pre-create", function(event)
127 local url = render(url_template, event);
128 module:log("debug", "Calling API at %q for room %s", url, event.room.jid);
129 local ret, err = errors.coerce(async.wait_for(http.request(url, ex):next(check_status):next(get_json)));
130 if not ret then
131 event.room:destroy();
132 event.origin.send(st.error_reply(event.stanza, err));
133 return true;
134 end
135
136 local configured, err = apply_config(event.room, ret);
137 if not configured then
138 event.room:destroy();
139 event.origin.send(st.error_reply(event.stanza, err));
140 return true;
141 end
142 end, -2);