local t_unpack = table.unpack or unpack; -- luacheck: ignore 113

local time_now = os.time;

local jid_prep = require "util.jid".prep;

local set = require "util.set";

local st = require "util.stanza";

local it = require "util.iterators";

local uuid_generate = require "util.uuid".generate;

local dataform = require"util.dataforms".new;

local errors = require "util.error";

local xmlns_pubsub = "http://jabber.org/protocol/pubsub";

local xmlns_pubsub_errors = "http://jabber.org/protocol/pubsub#errors";

local xmlns_pubsub_owner = "http://jabber.org/protocol/pubsub#owner";

local _M = {};

local handlers = {};

_M.handlers = handlers;

local pubsub_errors = {

	["conflict"] = { "cancel", "conflict" };

	["invalid-jid"] = { "modify", "bad-request", nil, "invalid-jid" };

	["jid-required"] = { "modify", "bad-request", nil, "jid-required" };

	["nodeid-required"] = { "modify", "bad-request", nil, "nodeid-required" };

	["item-not-found"] = { "cancel", "item-not-found" };

	["not-subscribed"] = { "modify", "unexpected-request", nil, "not-subscribed" };

	["invalid-options"] = { "modify", "bad-request", nil, "invalid-options" };

	["forbidden"] = { "auth", "forbidden" };

	["not-allowed"] = { "cancel", "not-allowed" };

	["not-acceptable"] = { "modify", "not-acceptable" };

	["internal-server-error"] = { "wait", "internal-server-error" };

	["precondition-not-met"] = { "cancel", "conflict", nil, "precondition-not-met" };

	["invalid-item"] = { "modify", "bad-request", "invalid item" };

	["persistent-items-unsupported"] = { "cancel", "feature-not-implemented", nil, "persistent-items" };

};

local function pubsub_error_reply(stanza, error)

	local e = pubsub_errors[error];

	if not e and errors.is_err(error) then

		e = { error.type, error.condition, error.text, error.pubsub_condition };

	end

	local reply = st.error_reply(stanza, t_unpack(e, 1, 3));

	if e[4] then

		reply:tag(e[4], { xmlns = xmlns_pubsub_errors }):up();

	end

	return reply;

end

_M.pubsub_error_reply = pubsub_error_reply;

local function dataform_error_message(err) -- ({ string : string }) -> string?

	local out = {};

	for field, errmsg in pairs(err) do

		table.insert(out, ("%s: %s"):format(field, errmsg))

	end

	return table.concat(out, "; ");

end

-- Note: If any config options are added that are of complex types,

-- (not simply strings/numbers) then the publish-options code will

-- need to be revisited

local node_config_form = dataform {

	{

		type = "hidden";

		var = "FORM_TYPE";

		value = "http://jabber.org/protocol/pubsub#node_config";

	};

	{

		type = "text-single";

		name = "title";

		var = "pubsub#title";

		label = "Title";

	};

	{

		type = "text-single";

		name = "description";

		var = "pubsub#description";

		label = "Description";

	};

	{

		type = "text-single";

		name = "payload_type";

		var = "pubsub#type";

		label = "The type of node data, usually specified by the namespace of the payload (if any)";

	};

	{

		type = "text-single";

		datatype = "pubsub:integer-or-max";

		name = "max_items";

		range_min = 1;

		var = "pubsub#max_items";

		label = "Max # of items to persist";

	};

	{

		type = "boolean";

		name = "persist_items";

		var = "pubsub#persist_items";

		label = "Persist items to storage";

	};

	{

		type = "list-single";

		name = "access_model";

		var = "pubsub#access_model";

		label = "Specify the subscriber model";

		options = {

			"authorize",

			"open",

			"presence",

			"roster",

			"whitelist",

		};

	};

	{

		type = "list-single";

		name = "publish_model";

		var = "pubsub#publish_model";

		label = "Specify the publisher model";

		options = {

			"publishers";

			"subscribers";

			"open";

		};

	};

	{

		type = "list-single";

		var = "pubsub#send_last_published_item";

		name = "send_last_published_item";

		options = { "never"; "on_sub"; "on_sub_and_presence" };

	};

	{

		type = "boolean";

		value = true;

		label = "Whether to deliver event notifications";

		name = "notify_items";

		var = "pubsub#deliver_notifications";

	};

	{

		type = "boolean";

		value = true;

		label = "Whether to deliver payloads with event notifications";

		name = "include_payload";

		var = "pubsub#deliver_payloads";

	};

	{

		type = "list-single";

		name = "notification_type";

		var = "pubsub#notification_type";

		label = "Specify the delivery style for notifications";

		options = {

			{ label = "Messages of type normal", value = "normal" },

			{ label = "Messages of type headline", value = "headline", default = true },

		};

	};

	{

		type = "boolean";

		label = "Whether to notify subscribers when the node is deleted";

		name = "notify_delete";

		var = "pubsub#notify_delete";

		value = true;

	};

	{

		type = "boolean";

		label = "Whether to notify subscribers when items are removed from the node";

		name = "notify_retract";

		var = "pubsub#notify_retract";

		value = true;

	};

};

_M.node_config_form = node_config_form;

local subscribe_options_form = dataform {

	{

		type = "hidden";

		var = "FORM_TYPE";

		value = "http://jabber.org/protocol/pubsub#subscribe_options";

	};

	{

		type = "boolean";

		name = "pubsub#include_body";

		label = "Receive message body in addition to payload?";

	};

};

_M.subscribe_options_form = subscribe_options_form;

local node_metadata_form = dataform {

	{

		type = "hidden";

		var = "FORM_TYPE";

		value = "http://jabber.org/protocol/pubsub#meta-data";

	};

	{

		type = "text-single";

		name = "pubsub#title";

	};

	{

		type = "text-single";

		name = "pubsub#description";

	};

	{

		type = "text-single";

		name = "pubsub#type";

	};

	{

		type = "text-single";

		name = "pubsub#access_model";

	};

	{

		type = "text-single";

		name = "pubsub#publish_model";

	};

};

_M.node_metadata_form = node_metadata_form;

local service_method_feature_map = {

	add_subscription = { "subscribe", "subscription-options" };

	create = { "create-nodes", "instant-nodes", "item-ids", "create-and-configure" };

	delete = { "delete-nodes" };

	get_items = { "retrieve-items" };

	get_subscriptions = { "retrieve-subscriptions" };

	node_defaults = { "retrieve-default" };

	publish = { "publish", "multi-items", "publish-options" };

	purge = { "purge-nodes" };

	retract = { "delete-items", "retract-items" };

	set_node_config = { "config-node", "meta-data" };

	set_affiliation = { "modify-affiliations" };

};

local service_config_feature_map = {

	autocreate_on_publish = { "auto-create" };

};

function _M.get_feature_set(service)

	local supported_features = set.new();

	for method, features in pairs(service_method_feature_map) do

		if service[method] then

			for _, feature in ipairs(features) do

				if feature then

					supported_features:add(feature);

				end

			end

		end

	end

	for option, features in pairs(service_config_feature_map) do

		if service.config[option] then

			for _, feature in ipairs(features) do

				if feature then

					supported_features:add(feature);

				end

			end

		end

	end

	for affiliation in pairs(service.config.capabilities) do

		if affiliation ~= "none" and affiliation ~= "owner" then

			supported_features:add(affiliation.."-affiliation");

		end

	end

	if service.node_defaults.access_model then

		supported_features:add("access-"..service.node_defaults.access_model);

	end

	if service.node_defaults.send_last_published_item ~= "never" then

		supported_features:add("last-published");

	end

	if rawget(service.config, "itemstore") and rawget(service.config, "nodestore") then

		supported_features:add("persistent-items");

	end

	if true --[[ node_metadata_form[max_items].datatype == "pubsub:integer-or-max" ]] then

		supported_features:add("config-node-max");

	end

	return supported_features;

end

function _M.handle_disco_info_node(event, service)

	local stanza, reply, node = event.stanza, event.reply, event.node;

	local ok, ret = service:get_nodes(stanza.attr.from);

	if not ok then

		event.origin.send(pubsub_error_reply(stanza, ret));

		return true;

	end

	local node_obj = ret[node];

	if not node_obj then

		event.origin.send(pubsub_error_reply(stanza, "item-not-found"));

		return true;

	end

	event.exists = true;

	reply:tag("identity", { category = "pubsub", type = "leaf" }):up();

	if node_obj.config then

		reply:add_child(node_metadata_form:form({

			["pubsub#title"] = node_obj.config.title;

			["pubsub#description"] = node_obj.config.description;

			["pubsub#type"] = node_obj.config.payload_type;

			["pubsub#access_model"] = node_obj.config.access_model;

			["pubsub#publish_model"] = node_obj.config.publish_model;

		}, "result"));

	end

end

function _M.handle_disco_items_node(event, service)

	local stanza, reply, node = event.stanza, event.reply, event.node;

	local ok, ret = service:get_items(node, stanza.attr.from);

	if not ok then

		event.origin.send(pubsub_error_reply(stanza, ret));

		return true;

	end

	for _, id in ipairs(ret) do

		reply:tag("item", { jid = service.jid or module.host, name = id }):up();

	end

	event.exists = true;

end

function _M.handle_pubsub_iq(event, service)

	local origin, stanza = event.origin, event.stanza;

	local pubsub_tag = stanza.tags[1];

	local action = pubsub_tag.tags[1];

	if not action then

		return origin.send(st.error_reply(stanza, "cancel", "bad-request"));

	end

	local prefix = "";

	if pubsub_tag.attr.xmlns == xmlns_pubsub_owner then

		prefix = "owner_";

	end

	local handler = handlers[prefix..stanza.attr.type.."_"..action.name];

	if handler then

		handler(origin, stanza, action, service);

		return true;

	end

end

function handlers.get_items(origin, stanza, items, service)

	local node = items.attr.node;

	local requested_items = {};

	for item in items:childtags("item") do

		table.insert(requested_items, item.attr.id);

	end

	if requested_items[1] == nil then

		requested_items = nil;

	end

	if not node then

		origin.send(pubsub_error_reply(stanza, "nodeid-required"));

		return true;

	end

	local resultspec; -- TODO rsm.get()

	if items.attr.max_items then

		resultspec = { max = tonumber(items.attr.max_items) };

	end

	local ok, results = service:get_items(node, stanza.attr.from, requested_items, resultspec);

	if not ok then

		origin.send(pubsub_error_reply(stanza, results));

		return true;

	end

	local expose_publisher = service.config.expose_publisher;

	local data = st.stanza("items", { node = node });

	local iter, v, i = ipairs(results);

	if not requested_items then

		-- XXX Hack to preserve order of explicitly requested items.

		iter, v, i = it.reverse(iter, v, i);

	end

	for _, id in iter, v, i do

		local item = results[id];

		if not expose_publisher then

			item = st.clone(item);

			item.attr.publisher = nil;

		end

		data:add_child(item);

	end

	local reply = st.reply(stanza)