clix/publish_atom.lua

local verse = require "verse";

local new_uuid = require "prosody.util.uuid".generate;

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

local xmlns_atom = "http://www.w3.org/2005/Atom";

local xmlns_activitystreams = "http://activitystrea.ms/spec/1.0/";

return function (opts, arg)

	if opts.short_help then

		print("Publish an Atom entry to a pubsub node");

		return;

	end

	if opts.help or not (opts.node or opts.title or opts.content) then

		print("clix publish_atom \\");

		print("","--service=pubsub.shakespeare.lit \\");

		print("","--node=princely_musings \\");

		print("","--id=123 \\");

		print("","--author=Hamlet \\");

		print("","--title=Soliloquy \\");

		print("","--summary=\"To be, or not to be: that is the question\"");

		return 0;

	end

	local function on_connect(conn)

		-- Required: id, title, updated, author (which must have a name)

		local entry_id = opts.id or new_uuid();

		local atom_entry = verse.stanza("entry", { xmlns = xmlns_atom})

			:tag("id"):text(entry_id):up()

			:tag("title", { type = opts["title-type"] }):text(opts.title or ""):up()

			:tag("updated"):text(opts.updated or datetime()):up();

		atom_entry:tag("author"):tag("name"):text(opts.author or os.getenv("USER") or "Unknown author"):up();

		atom_entry:up();

		if opts.summary then

			atom_entry:tag("summary", { type = opts["summary-type"] }):text(opts.summary):up();

		end

		if opts.content then

			atom_entry:tag("content", { type = opts["content-type"] }):text(opts.content):up();

		end

		for opt, optval in pairs(opts) do

			if opt:sub(1,3) == "as_" then

				atom_entry:tag(opt:sub(4), { xmlns = xmlns_activitystreams } )

					:text(optval):up();

			end

		end

		conn.pubsub(opts.service, opts.node or "urn:xmpp:microblog:0"):publish(entry_id, nil, atom_entry

		, function(ok)

			-- TODO Report success?

			conn:close();

		end);

		--conn:send(verse.message({ to = opts.to, type = "chat" }) :body(text));

	end

	clix_connect(opts, on_connect, {"pubsub"});

end