view mod_adhoc/adhoc/adhoc.lib.lua @ 122:c3a874eec712

mod_adhoc: Add more features described in XEP-0050
author Florian Zeitz <florob@babelmonkeys.de>
date Fri, 22 Jan 2010 14:45:36 +0100
parents a9898f13c89e
children c04443ea114c
line wrap: on
line source

local st = require "util.stanza";

local xmlns_cmd = "http://jabber.org/protocol/commands";

local _M = {};

function _cmdtag(desc, status, sessionid, action)
	local cmd = st.stanza("command", { xmlns = xmlns_cmd, node = desc.node, status = status });
	if sessionid then cmd.attr.sessionid = sessionid; end
	if action then cmd.attr.action = action; end

	return cmd;
end

function _M.new(name, node, handler, permission)
	return { name = name, node = node, handler = handler, cmdtag = _cmdtag, permission = (permission or "user") };
end

function _M.handle_cmd(command, origin, stanza)
	local sessionid = stanza.tags[1].attr.sessionid or nil;
	local dataIn = {};
	dataIn.to = stanza.attr.to;
	dataIn.from = stanza.attr.from;
	dataIn.action = stanza.tags[1].attr.action or nil;
	dataIn.form = stanza.tags[1]:child_with_ns("jabber:x:data");

	local data, sessid = command:handler(dataIn, sessionid);
	local stanza = st.reply(stanza);
	if data.status == "completed" then
		cmdtag = command:cmdtag("completed", sessid);
	elseif data.status == "canceled" then
		cmdtag = command:cmdtag("canceled", sessid);
	elseif data.status == "error" then
		stanza = st.error_reply(stanza, data.error.type, data.error.condition, data.error.message);
		cmdtag = command:cmdtag("canceled", sessid);
	else 
		cmdtag = command:cmdtag("executing", sessid);
	end

	for name, content in pairs(data) do
		if name == "info" then
			cmdtag:tag("note", {type="info"}):text(content):up();
		elseif name == "warn" then
			cmdtag:tag("note", {type="warn"}):text(content):up();
		elseif name == "error" then
			cmdtag:tag("note", {type="error"}):text(content.message):up();
		elseif name =="actions" then
			local actions = st.stanza("actions");
			for _, action in ipairs(content) do
				if (action == "prev") or (action == "next") or (action == "complete") then
					actions:tag(action):up();
				else
					module:log("error", 'Command "'..command.name..
						'" at node "'..command.node..'" provided an invalid action "'..action..'"');
				end
			end
			cmdtag:add_child(actions):up();
		elseif name == "form" then
			cmdtag:add_child(data.form:form()):up();
		elseif name == "other" then
			cmdtag:add_child(content):up();
		end
	end
	stanza:add_child(cmdtag);
	origin.send(stanza);

	return true;
end

return _M;