1 -- Copyright (C) 2009-2010 Florian Zeitz
3 -- This file is MIT/X11 licensed. Please see the
4 -- COPYING file in the source package for more information.
7 local st, uuid = require "util.stanza", require "util.uuid";
9 local xmlns_cmd = "http://jabber.org/protocol/commands";
15 local function _cmdtag(desc, status, sessionid, action)
16 local cmd = st.stanza("command", { xmlns = xmlns_cmd, node = desc.node, status = status });
17 if sessionid then cmd.attr.sessionid = sessionid; end
18 if action then cmd.attr.action = action; end
23 function _M.new(name, node, handler, permission)
24 return { name = name, node = node, handler = handler, cmdtag = _cmdtag, permission = (permission or "user") };
27 function _M.handle_cmd(command, origin, stanza)
28 local cmdtag = stanza.tags[1]
29 local sessionid = cmdtag.attr.sessionid or uuid.generate();
31 dataIn.to = stanza.attr.to;
32 dataIn.from = stanza.attr.from;
33 dataIn.action = cmdtag.attr.action or "execute";
34 dataIn.form = cmdtag:get_child("x", "jabber:x:data");
36 local data, state = command:handler(dataIn, states[sessionid]);
37 states[sessionid] = state;
39 if data.status == "completed" then
40 states[sessionid] = nil;
41 cmdtag = command:cmdtag("completed", sessionid);
42 elseif data.status == "canceled" then
43 states[sessionid] = nil;
44 cmdtag = command:cmdtag("canceled", sessionid);
45 elseif data.status == "error" then
46 states[sessionid] = nil;
47 local reply = st.error_reply(stanza, data.error.type, data.error.condition, data.error.message);
51 cmdtag = command:cmdtag("executing", sessionid);
52 data.actions = data.actions or { "complete" };
55 for name, content in pairs(data) do
56 if name == "info" then
57 cmdtag:tag("note", {type="info"}):text(content):up();
58 elseif name == "warn" then
59 cmdtag:tag("note", {type="warn"}):text(content):up();
60 elseif name == "error" then
61 cmdtag:tag("note", {type="error"}):text(content.message):up();
62 elseif name == "actions" then
63 local actions = st.stanza("actions", { execute = content.default });
64 for _, action in ipairs(content) do
65 if (action == "prev") or (action == "next") or (action == "complete") then
66 actions:tag(action):up();
68 module:log("error", "Command %q at node %q provided an invalid action %q",
69 command.name, command.node, action);
72 cmdtag:add_child(actions);
73 elseif name == "form" then
74 cmdtag:add_child((content.layout or content):form(content.values));
75 elseif name == "result" then
76 cmdtag:add_child((content.layout or content):form(content.values, "result"));
77 elseif name == "other" then
78 cmdtag:add_child(content);
81 local reply = st.reply(stanza);
82 reply:add_child(cmdtag);