local jid_bare = require "util.jid".bare;
local jid_split = require "util.jid".split;
local st = require "util.stanza";
local hosts = hosts;
local user_exists = require "core.usermanager".user_exists;
local is_contact_subscribed = require "core.rostermanager".is_contact_subscribed;
local pairs, ipairs = pairs, ipairs;

local function publish(session, node, item)
	local stanza = st.message({from=session.full_jid, type='headline'})
		:tag('event', {xmlns='http://jabber.org/protocol/pubsub#event'})
			:tag('items', {node=node})
				:add_child(item)
			:up()
		:up();

	-- broadcast to resources
	stanza.attr.to = session.username..'@'..session.host;
	core_route_stanza(session, stanza);

	-- broadcast to contacts
	for jid, item in pairs(session.roster) do
		if jid and jid ~= "pending" and (item.subscription == 'from' or item.subscription == 'both') then
			stanza.attr.to = jid;
			core_route_stanza(session, stanza);
		end
	end
end

module:add_iq_handler("c2s", "http://jabber.org/protocol/pubsub", function (session, stanza)
	if stanza.attr.type == 'set' and (not stanza.attr.to or jid_bare(stanza.attr.from) == stanza.attr.to) then
		local payload = stanza.tags[1];
		if payload.name == 'pubsub' then
			payload = payload.tags[1];
			if payload and payload.name == 'publish' and payload.attr.node then
				local node = payload.attr.node;
				payload = payload.tags[1];
				if payload then
					publish(session, node, payload);
					return true;
				end -- TODO else error
			end -- TODO else error
		end
	end
	origin.send(st.error_reply(stanza, "cancel", "service-unavailable"));
end);