1 local st = require "util.stanza";
2 local uuid_generate = require "util.uuid".generate;
3 local dataform = require"util.dataforms".new;
5 local xmlns_pubsub = "http://jabber.org/protocol/pubsub";
6 local xmlns_pubsub_errors = "http://jabber.org/protocol/pubsub#errors";
7 local xmlns_pubsub_owner = "http://jabber.org/protocol/pubsub#owner";
12 _M.handlers = handlers;
14 local pubsub_errors = {
15 ["conflict"] = { "cancel", "conflict" };
16 ["invalid-jid"] = { "modify", "bad-request", nil, "invalid-jid" };
17 ["jid-required"] = { "modify", "bad-request", nil, "jid-required" };
18 ["nodeid-required"] = { "modify", "bad-request", nil, "nodeid-required" };
19 ["item-not-found"] = { "cancel", "item-not-found" };
20 ["not-subscribed"] = { "modify", "unexpected-request", nil, "not-subscribed" };
21 ["forbidden"] = { "auth", "forbidden" };
22 ["not-allowed"] = { "cancel", "not-allowed" };
24 local function pubsub_error_reply(stanza, error)
25 local e = pubsub_errors[error];
26 local reply = st.error_reply(stanza, unpack(e, 1, 3));
28 reply:tag(e[4], { xmlns = xmlns_pubsub_errors }):up();
32 _M.pubsub_error_reply = pubsub_error_reply;
34 local node_config_form = require"util.dataforms".new {
38 value = "http://jabber.org/protocol/pubsub#node_config";
42 name = "pubsub#max_items";
43 label = "Max # of items to persist";
47 function handlers.get_items(origin, stanza, items, service)
48 local node = items.attr.node;
49 local item = items:get_child("item");
50 local id = item and item.attr.id;
53 origin.send(pubsub_error_reply(stanza, "nodeid-required"));
56 local ok, results = service:get_items(node, stanza.attr.from, id);
58 origin.send(pubsub_error_reply(stanza, results));
62 local data = st.stanza("items", { node = node });
63 for _, id in ipairs(results) do
64 data:add_child(results[id]);
68 reply = st.reply(stanza)
69 :tag("pubsub", { xmlns = xmlns_pubsub })
72 reply = pubsub_error_reply(stanza, "item-not-found");
78 function handlers.get_subscriptions(origin, stanza, subscriptions, service)
79 local node = subscriptions.attr.node;
80 local ok, ret = service:get_subscriptions(node, stanza.attr.from, stanza.attr.from);
82 origin.send(pubsub_error_reply(stanza, ret));
85 local reply = st.reply(stanza)
86 :tag("pubsub", { xmlns = xmlns_pubsub })
87 :tag("subscriptions");
88 for _, sub in ipairs(ret) do
89 reply:tag("subscription", { node = sub.node, jid = sub.jid, subscription = 'subscribed' }):up();
95 function handlers.set_create(origin, stanza, create, service)
96 local node = create.attr.node;
99 ok, ret = service:create(node, stanza.attr.from);
101 reply = st.reply(stanza);
103 reply = pubsub_error_reply(stanza, ret);
107 node = uuid_generate();
108 ok, ret = service:create(node, stanza.attr.from);
109 until ok or ret ~= "conflict";
111 reply = st.reply(stanza)
112 :tag("pubsub", { xmlns = xmlns_pubsub })
113 :tag("create", { node = node });
115 reply = pubsub_error_reply(stanza, ret);
122 function handlers.set_delete(origin, stanza, delete, service)
123 local node = delete.attr.node;
125 local reply, notifier;
127 origin.send(pubsub_error_reply(stanza, "nodeid-required"));
130 local ok, ret = service:delete(node, stanza.attr.from);
132 reply = st.reply(stanza);
134 reply = pubsub_error_reply(stanza, ret);
140 function handlers.set_subscribe(origin, stanza, subscribe, service)
141 local node, jid = subscribe.attr.node, subscribe.attr.jid;
142 if not (node and jid) then
143 origin.send(pubsub_error_reply(stanza, jid and "nodeid-required" or "invalid-jid"));
147 local options_tag, options = stanza.tags[1]:get_child("options"), nil;
149 options = options_form:data(options_tag.tags[1]);
152 local options_tag, options; -- FIXME
153 local ok, ret = service:add_subscription(node, stanza.attr.from, jid, options);
156 reply = st.reply(stanza)
157 :tag("pubsub", { xmlns = xmlns_pubsub })
158 :tag("subscription", {
161 subscription = "subscribed"
164 reply:add_child(options_tag);
167 reply = pubsub_error_reply(stanza, ret);
172 function handlers.set_unsubscribe(origin, stanza, unsubscribe, service)
173 local node, jid = unsubscribe.attr.node, unsubscribe.attr.jid;
174 if not (node and jid) then
175 origin.send(pubsub_error_reply(stanza, jid and "nodeid-required" or "invalid-jid"));
178 local ok, ret = service:remove_subscription(node, stanza.attr.from, jid);
181 reply = st.reply(stanza);
183 reply = pubsub_error_reply(stanza, ret);
189 function handlers.set_publish(origin, stanza, publish, service)
190 local node = publish.attr.node;
192 origin.send(pubsub_error_reply(stanza, "nodeid-required"));
195 local item = publish:get_child("item");
196 local id = (item and item.attr.id);
198 id = uuid_generate();
203 local ok, ret = service:publish(node, stanza.attr.from, id, item);
206 reply = st.reply(stanza)
207 :tag("pubsub", { xmlns = xmlns_pubsub })
208 :tag("publish", { node = node })
209 :tag("item", { id = id });
211 reply = pubsub_error_reply(stanza, ret);
217 function handlers.set_retract(origin, stanza, retract, service)
218 local node, notify = retract.attr.node, retract.attr.notify;
219 notify = (notify == "1") or (notify == "true");
220 local item = retract:get_child("item");
221 local id = item and item.attr.id
222 if not (node and id) then
223 origin.send(pubsub_error_reply(stanza, node and "item-not-found" or "nodeid-required"));
226 local reply, notifier;
228 notifier = st.stanza("retract", { id = id });
230 local ok, ret = service:retract(node, stanza.attr.from, id, notifier);
232 reply = st.reply(stanza);
234 reply = pubsub_error_reply(stanza, ret);
240 function handlers.set_purge(origin, stanza, purge, service)
241 local node, notify = purge.attr.node, purge.attr.notify;
242 notify = (notify == "1") or (notify == "true");
245 origin.send(pubsub_error_reply(stanza, "nodeid-required"));
248 local ok, ret = service:purge(node, stanza.attr.from, notify);
250 reply = st.reply(stanza);
252 reply = pubsub_error_reply(stanza, ret);
258 function handlers.get_configure(origin, stanza, config, service)
259 local node = config.attr.node;
261 origin.send(pubsub_error_reply(stanza, "nodeid-required"));
265 if not service:may(node, stanza.attr.from, "configure") then
266 origin.send(pubsub_error_reply(stanza, "forbidden"));
270 local node_obj = service.nodes[node];
272 origin.send(pubsub_error_reply(stanza, "item-not-found"));
276 local reply = st.reply(stanza)
277 :tag("pubsub", { xmlns = xmlns_pubsub_owner })
278 :tag("configure", { node = node })
279 :add_child(node_config_form:form(node_obj.config));
284 function handlers.set_configure(origin, stanza, config, service)
285 local node = config.attr.node;
287 origin.send(pubsub_error_reply(stanza, "nodeid-required"));
290 if not service:may(node, stanza.attr.from, "configure") then
291 origin.send(pubsub_error_reply(stanza, "forbidden"));
294 local new_config, err = node_config_form:data(config.tags[1]);
295 if not new_config then
296 origin.send(st.error_reply(stanza, "modify", "bad-request", err));
299 local ok, err = service:set_node_config(node, stanza.attr.from, new_config);
301 origin.send(pubsub_error_reply(stanza, err));
304 origin.send(st.reply(stanza));
308 function handlers.get_default(origin, stanza, default, service)
309 local reply = st.reply(stanza)
310 :tag("pubsub", { xmlns = xmlns_pubsub_owner })
312 :add_child(node_config_form:form(service.node_defaults));