plugins/msg2pubsub.lua

local verse = require "verse";

local jid = require "prosody.util.jid";

local sha256 = require "prosody.util.hashes".sha256;

function riddim.plugins.msg2pubsub(bot)

	bot.stream:add_plugin("pubsub");

	local config = bot.config.msg2pubsub;

	if not config then return; end

	bot:hook("message", function (message)

		print("MSG", message.body);

		if not message.body or message.body == "" then

			return;

		end

		local payload = verse.stanza("data", { xmlns = "https://prosody.im/protocol/data" })

			:text(message.body);

		bot.stream.pubsub(config.host, config.node):publish(

			"current", -- item id

			nil, -- options (not implemented anyway)

			payload,

			function (response) -- callback

				if response.attr.type == "error" then

					local e = verse.error_reply(message.stanza, "wait", "recipient-unavailable", "Failed to relay message ("..select(2, response:get_error())..")");

					bot:send(e);

					return true;

				else

					if message.stanza:get_child("request", "urn:xmpp:receipts") then

						local rcpt = verse.reply(message.stanza)

							:tag("received", { xmlns = "urn:xmpp:receipts", id = message.stanza.attr.id });

						bot:send(rcpt);

					end

				end

			end

		);

		return true;

	end);

end