module:depends("http");
local st = require "util.stanza";
local json = require "util.json";
local formdecode = require "net.http".formdecode;
local uuid_generate = require "util.uuid".generate;
local timestamp_generate = require "util.datetime".datetime;
local pubsub_service = module:depends("pubsub").service;
function handle_POST(event, path)
local data = event.request.body;
local item_id = "default";
local post_item = st.stanza("item", { id = item_id, xmlns = "http://jabber.org/protocol/pubsub" })
:tag("entry", { xmlns = "http://www.w3.org/2005/Atom" })
:tag("id"):text(uuid_generate()):up()
:tag("title"):text(data):up()
:tag("author")
:tag("name"):text(event.request.conn:ip()):up()
:up()
:tag("published"):text(timestamp_generate()):up();
local ok, err = pubsub_service:publish(path, true, item_id, post_item);
module:log("debug", "Handled POST: \n%s\n", tostring(event.request.body));
return ok and "Posted" or ("Error: "..err);
end
module:provides("http", {
route = {
["POST /*"] = handle_POST;
};
});
function module.load()
module:log("debug", "Loaded at %s", module:http_url());
end