# HG changeset patch
# User Florian Zeitz <florob@babelmonkeys.de>
# Date 1291243127 -3600
# Node ID 405231b1cb88dcc76282b4a3bce1da5c69f7413f
# Parent  6bd4305044a8c072381924fc90de4599366ffa1a
mod_pubsub, util.pubsub: Support node creation

diff -r 6bd4305044a8 -r 405231b1cb88 plugins/mod_pubsub.lua
--- a/plugins/mod_pubsub.lua	Sun Nov 28 15:02:56 2010 +0500
+++ b/plugins/mod_pubsub.lua	Wed Dec 01 23:38:47 2010 +0100
@@ -55,6 +55,28 @@
 	return origin.send(reply);
 end
 
+function handlers.set_create(origin, stanza, create)
+	local node = create.attr.node;
+	local ok, ret, reply;
+	if node then
+		ok, ret = service:create(node, stanza.attr.from);
+		if ok then
+			reply = st.reply(stanza);
+		else
+			reply = st.error_reply(stanza, "cancel", ret);
+		end
+	else
+		repeat
+			node = uuid_generate();
+			ok, ret = service:create(node, stanza.attr.from);
+		until ok;
+		reply = st.reply(stanza)
+			:tag("pubsub", { xmlns = xmlns_pubsub })
+				:tag("create", { node = node });
+	end
+	origin.send(reply);
+end
+
 function handlers.set_subscribe(origin, stanza, subscribe)
 	local node, jid = subscribe.attr.node, subscribe.attr.jid;
 	if jid_bare(jid) ~= jid_bare(stanza.attr.from) then
diff -r 6bd4305044a8 -r 405231b1cb88 util/pubsub.lua
--- a/util/pubsub.lua	Sun Nov 28 15:02:56 2010 +0500
+++ b/util/pubsub.lua	Wed Dec 01 23:38:47 2010 +0100
@@ -28,6 +28,14 @@
 	end
 end
 
+function service:create(node, actor)
+	if not self.nodes[node] then
+		self.nodes[node] = { name = node, subscribers = {}, config = {}, data = {} };
+		return true;
+	end
+	return false, "conflict";
+end
+
 function service:publish(node, actor, id, item)
 	local node_obj = self.nodes[node];
 	if not node_obj then