plugins/adhoc/adhoc.lib.lua

   1 -- Copyright (C) 2009-2010 Florian Zeitz
   2 --
   3 -- This file is MIT/X11 licensed. Please see the
   4 -- COPYING file in the source package for more information.
   5 --
   6
   7 local st, uuid = require "util.stanza", require "util.uuid";
   8
   9 local xmlns_cmd = "http://jabber.org/protocol/commands";
  10
  11 local states = {}
  12
  13 local _M = {};
  14
  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
  19
  20         return cmd;
  21 end
  22
  23 function _M.new(name, node, handler, permission)
  24         return { name = name, node = node, handler = handler, cmdtag = _cmdtag, permission = (permission or "user") };
  25 end
  26
  27 function _M.handle_cmd(command, origin, stanza)
  28         local cmdtag = stanza.tags[1]
  29         local sessionid = cmdtag.attr.sessionid or uuid.generate();
  30         local dataIn = {};
  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");
  35
  36         local data, state = command:handler(dataIn, states[sessionid]);
  37         states[sessionid] = state;
  38         local cmdtag;
  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);
  48                 origin.send(reply);
  49                 return true;
  50         else
  51                 cmdtag = command:cmdtag("executing", sessionid);
  52                 data.actions = data.actions or { "complete" };
  53         end
  54
  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();
  67                                 else
  68                                         module:log("error", "Command %q at node %q provided an invalid action %q",
  69                                                 command.name, command.node, action);
  70                                 end
  71                         end
  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);
  79                 end
  80         end
  81         local reply = st.reply(stanza);
  82         reply:add_child(cmdtag);
  83         origin.send(reply);
  84
  85         return true;
  86 end
  87
  88 return _M;