tests/integration/pubsub.lua

local harness = require "harness";

local verse = harness.verse;

local service = "pubsub."..harness.domain;

return {

	{ "creates a node, subscribes, publishes and receives the event", function (t)

		local node_name = "verse-test-"..os.time();

		-- alice is a server admin in the test config, so may create nodes

		t.client("alice", function (c)

			local node = c.pubsub(service, node_name);

			node:hook(t.cb(function (event)

				assert(event.from == service, "unexpected event source: "..tostring(event.from));

				assert(event.item.tags[1].name == "payload", "unexpected payload");

				assert(event.item.tags[1]:get_text() == "hello", "unexpected payload text");

				node:delete(nil, t.cb(function (reply)

					assert(reply.attr.type == "result", "node delete failed");

					t.done();

				end));

			end));

			node:create(nil, t.cb(function (reply)

				assert(reply.attr.type == "result", "node create failed: "..tostring(select(2, reply:get_error())));

				node:subscribe(nil, nil, t.cb(function (reply)

					assert(reply.attr.type == "result", "subscribe failed: "..tostring(select(2, reply:get_error())));

					node:publish(nil, nil, verse.stanza("payload", { xmlns = "urn:example:payload" }):text("hello"), t.cb(function (reply)

						assert(reply.attr.type == "result", "publish failed: "..tostring(select(2, reply:get_error())));

					end));

				end));

			end));

		end, { plugins = { "pubsub" } });

	end };

};