Software /
code /
prosody-modules
Diff
mod_pubsub_post/mod_pubsub_post.lua @ 1619:43c54a27bab2
mod_pubsub_post: Module to publish to pubsub nodes from a simple HTTP POST
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Fri, 27 Feb 2015 16:25:48 +0000 |
child | 3013:8bfba31a1f8b |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mod_pubsub_post/mod_pubsub_post.lua Fri Feb 27 16:25:48 2015 +0000 @@ -0,0 +1,37 @@ +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