several pubsub fixes and improvements. also fixes EJAB-913 and EJAB-871

SVN Revision: 2059

14 files changed, 149 insertions, 115 deletions

diff --git a/src/mod_caps.erl b/src/mod_caps.erl
index 897af4bd7..4a17515be 100644
--- a/src/mod_caps.erl
+++ b/src/mod_caps.erl
@@ -337,7 +337,7 @@ handle_cast({disco_response, From, _To,
 		    mnesia:dirty_write(#caps_features{node_pair = BinaryNode, features = features_to_binary(Features)}),
 		    gen_server:cast(self(), visit_feature_queries);
 		error ->
-		    ?ERROR_MSG("ID '~s' matches no query", [ID])
+		    ?DEBUG("ID '~s' matches no query", [ID])
 	    end;
 	{error, _} ->
 	    %% XXX: if we get error, we cache empty feature not to probe the client continuously
@@ -346,7 +346,7 @@ handle_cast({disco_response, From, _To,
 		    mnesia:dirty_write(#caps_features{node_pair = BinaryNode}),
 		    gen_server:cast(self(), visit_feature_queries);
 		error ->
-		    ?ERROR_MSG("ID '~s' matches no query", [ID])
+		    ?DEBUG("ID '~s' matches no query", [ID])
 	    end;
 	    %gen_server:cast(self(), visit_feature_queries),
 	    %?DEBUG("Error IQ reponse from ~s:~n~p", [jlib:jid_to_string(From), SubEls]);
diff --git a/src/mod_pubsub/gen_pubsub_node.erl b/src/mod_pubsub/gen_pubsub_node.erl
index b4264f809..78256cd56 100644
--- a/src/mod_pubsub/gen_pubsub_node.erl
+++ b/src/mod_pubsub/gen_pubsub_node.erl
@@ -49,7 +49,7 @@ behaviour_info(callbacks) ->
      {subscribe_node, 7},
      {unsubscribe_node, 4},
      {publish_item, 6},
-     {delete_item, 3},
+     {delete_item, 4},
      {remove_extra_items, 3},
      {get_node_affiliations, 1},
      {get_entity_affiliations, 2},
diff --git a/src/mod_pubsub/mod_pubsub.erl b/src/mod_pubsub/mod_pubsub.erl
index b51d7dfeb..c90190859 100644
--- a/src/mod_pubsub/mod_pubsub.erl
+++ b/src/mod_pubsub/mod_pubsub.erl
@@ -179,6 +179,7 @@ init([ServerHost, Opts]) ->
     ejabberd_hooks:add(presence_probe_hook, ServerHost, ?MODULE, presence_probe, 50),
     ejabberd_hooks:add(roster_out_subscription, ServerHost, ?MODULE, out_subscription, 50),
     ejabberd_hooks:add(remove_user, ServerHost, ?MODULE, remove_user, 50),
+    ejabberd_hooks:add(anonymous_purge_hook, ServerHost, ?MODULE, remove_user, 50),
     gen_iq_handler:add_iq_handler(ejabberd_sm, ServerHost, ?NS_PUBSUB, ?MODULE, iq_sm, IQDisc),
     gen_iq_handler:add_iq_handler(ejabberd_sm, ServerHost, ?NS_PUBSUB_OWNER, ?MODULE, iq_sm, IQDisc),
     case lists:member(?PEPNODE, Plugins) of
@@ -409,69 +410,89 @@ send_loop(State) ->
 	%% and is not able to "store" events of remote users (via s2s)
 	%% this makes that hack only work for local domain by now
 	if State#state.pep_sendlast_offline ->
-	    case catch ejabberd_c2s:get_subscribed(Pid) of
-	    Contacts when is_list(Contacts) ->
-		{User, Server, Resource} = jlib:jid_tolower(JID),
-		lists:foreach(
-		    fun({U, S, R}) ->  %% local contacts
-			case ejabberd_sm:get_user_resources(U, S) of
-			[] -> %% offline
-			    case S of
-			    ServerHost -> %% local contact, so we may have pep items
-				PeerJID = jlib:make_jid(U, S, R),
-				self() ! {presence, User, Server, [Resource], PeerJID};
-			    _ -> %% remote contact, no items available
-				ok
-			    end;
-			_ -> %% online
-			    % this is already handled by presence probe
-			    ok
-			end;
-		    (_) ->  %% remote contacts
-			% we can not do anything in any cases
-			ok
-		end, Contacts);
+	    {User, Server, Resource} = jlib:jid_tolower(JID),
+	    case mod_caps:get_caps({User, Server, Resource}) of
+	    nothing ->
+		%% we don't have caps, no need to handle PEP items
+		ok;
 	    _ ->
-		ok
+		case catch ejabberd_c2s:get_subscribed(Pid) of
+		Contacts when is_list(Contacts) ->
+		    lists:foreach(
+			fun({U, S, R}) ->
+			    case S of
+				ServerHost ->  %% local contacts
+				    case ejabberd_sm:get_user_resources(U, S) of
+				    [] -> %% offline
+					PeerJID = jlib:make_jid(U, S, R),
+					self() ! {presence, User, Server, [Resource], PeerJID};
+				    _ -> %% online
+					% this is already handled by presence probe
+					ok
+				    end;
+				_ ->  %% remote contacts
+				    % we can not do anything in any cases
+				    ok
+			    end
+			end, Contacts);
+		_ ->
+		    ok
+		end
 	    end;
 	true ->
 	    ok
 	end,
 	send_loop(State);
     {presence, User, Server, Resources, JID} ->
-	Owner = jlib:jid_remove_resource(jlib:jid_tolower(JID)),
-	Host = State#state.host,
-	ServerHost = State#state.server_host,
-	lists:foreach(fun(#pubsub_node{nodeid = {_, Node}, type = Type, id = NodeId, options = Options}) ->
-	    case get_option(Options, send_last_published_item) of
-		on_sub_and_presence ->
-		    lists:foreach(fun(Resource) ->
-			LJID = {User, Server, Resource},
-			case is_caps_notify(ServerHost, Node, LJID) of
-			    true ->
-				Subscribed = case get_option(Options, access_model) of
-					open -> true;
-					presence -> true;
-					whitelist -> false; % subscribers are added manually
-					authorize -> false; % likewise
-					roster ->
-					    Grps = get_option(Options, roster_groups_allowed, []),
-					    {OU, OS, _} = Owner,
-					    element(2, get_roster_info(OU, OS, LJID, Grps))
-				end,
-				if Subscribed ->
-				    send_items(Owner, Node, NodeId, Type, LJID, last);
-				true ->
-				    ok
-				end;
-			    false ->
-				ok
-			end
-		    end, Resources);
-		_ ->
-		    ok
-	    end
-	end, tree_action(Host, get_nodes, [Owner, JID])),
+	%% get resources caps and check if processing is needed
+	{HasCaps, ResourcesCaps} = lists:foldl(fun(Resource, {R, L}) ->
+		    case mod_caps:get_caps({User, Server, Resource}) of
+		    nothing -> {R, L};
+		    Caps -> {true, [{Resource, Caps} | L]}
+		    end
+		end, {false, []}, Resources),
+	case HasCaps of
+	    true ->
+		Host = State#state.host,
+		ServerHost = State#state.server_host,
+		Owner = jlib:jid_remove_resource(jlib:jid_tolower(JID)),
+		lists:foreach(fun(#pubsub_node{nodeid = {_, Node}, type = Type, id = NodeId, options = Options}) ->
+		    case get_option(Options, send_last_published_item) of
+			on_sub_and_presence ->
+			    lists:foreach(fun({Resource, Caps}) ->
+				CapsNotify = case catch mod_caps:get_features(ServerHost, Caps) of
+					Features when is_list(Features) -> lists:member(Node ++ "+notify", Features);
+					_ -> false
+				    end,
+				case CapsNotify of
+				    true ->
+					LJID = {User, Server, Resource},
+					Subscribed = case get_option(Options, access_model) of
+						open -> true;
+						presence -> true;
+						whitelist -> false; % subscribers are added manually
+						authorize -> false; % likewise
+						roster ->
+						    Grps = get_option(Options, roster_groups_allowed, []),
+						    {OU, OS, _} = Owner,
+						    element(2, get_roster_info(OU, OS, LJID, Grps))
+					end,
+					if Subscribed ->
+					    send_items(Owner, Node, NodeId, Type, LJID, last);
+					true ->
+					    ok
+					end;
+				    false ->
+					ok
+				end
+			    end, ResourcesCaps);
+			_ ->
+			    ok
+		    end
+		end, tree_action(Host, get_nodes, [Owner, JID]));
+	    false ->
+		ok
+	end,
 	send_loop(State);
     stop ->
 	ok
@@ -535,7 +556,7 @@ disco_sm_features(Acc, From, To, Node, _Lang) ->
 
 disco_sm_items(Acc, From, To, [], _Lang) ->
     Host = To#jid.lserver,
-    case tree_action(Host, get_nodes, [Host, From]) of
+    case tree_action(Host, get_subnodes, [Host, [], From]) of
 	[] ->
 	    Acc;
 	Nodes ->
@@ -677,7 +698,7 @@ handle_cast({remove_user, LUser, LServer}, State) ->
     %% remove user's PEP nodes 
     lists:foreach(fun(#pubsub_node{nodeid={NodeKey, NodeName}}) ->
 	delete_node(NodeKey, NodeName, Owner)
-    end, tree_action(Host, get_nodes, [jlib:jid_tolower(Owner)])),
+    end, tree_action(Host, get_nodes, [jlib:jid_tolower(Owner), Owner])),
     %% remove user's nodes
     delete_node(Host, ["home", LServer, LUser], Owner),
     {noreply, State}; 
@@ -717,7 +738,6 @@ terminate(_Reason, #state{host = Host,
 			  nodetree = TreePlugin,
 			  plugins = Plugins,
 			  send_loop = SendLoop}) ->
-    terminate_plugins(Host, ServerHost, Plugins, TreePlugin),
     ejabberd_router:unregister_route(Host),
     case lists:member(?PEPNODE, Plugins) of
 	true ->
@@ -735,11 +755,12 @@ terminate(_Reason, #state{host = Host,
     ejabberd_hooks:delete(presence_probe_hook, ServerHost, ?MODULE, presence_probe, 50),
     ejabberd_hooks:delete(roster_out_subscription, ServerHost, ?MODULE, out_subscription, 50),
     ejabberd_hooks:delete(remove_user, ServerHost, ?MODULE, remove_user, 50),
+    ejabberd_hooks:delete(anonymous_purge_hook, ServerHost, ?MODULE, remove_user, 50),
     gen_iq_handler:remove_iq_handler(ejabberd_sm, ServerHost, ?NS_PUBSUB),
     gen_iq_handler:remove_iq_handler(ejabberd_sm, ServerHost, ?NS_PUBSUB_OWNER),
     mod_disco:unregister_feature(ServerHost, ?NS_PUBSUB),
     SendLoop ! stop,
-    ok.
+    terminate_plugins(Host, ServerHost, Plugins, TreePlugin).
 
 %%--------------------------------------------------------------------
 %% Func: code_change(OldVsn, State, Extra) -> {ok, NewState}
@@ -1748,23 +1769,24 @@ delete_item(_, "", _, _, _) ->
     %% Request does not specify a node
     {error, extended_error(?ERR_BAD_REQUEST, "node-required")};
 delete_item(Host, Node, Publisher, ItemId, ForceNotify) ->
-    Action = fun(#pubsub_node{type = Type, id = NodeId}) ->
-		     Features = features(Type),
-		     PersistentFeature = lists:member("persistent-items", Features),
-		     DeleteFeature = lists:member("delete-items", Features),
-		     if
-			 %%->   iq_pubsub just does that matchs
-			 %%	%% Request does not specify an item
-			 %%	{error, extended_error(?ERR_BAD_REQUEST, "item-required")};
-			 not PersistentFeature ->
-			     %% Node does not support persistent items
-			     {error, extended_error(?ERR_FEATURE_NOT_IMPLEMENTED, unsupported, "persistent-items")};
-			 not DeleteFeature ->
-			     %% Service does not support item deletion
-			     {error, extended_error(?ERR_FEATURE_NOT_IMPLEMENTED, unsupported, "delete-items")};
-			 true ->
-			     node_call(Type, delete_item, [NodeId, Publisher, ItemId])
-		     end
+    Action = fun(#pubsub_node{options = Options, type = Type, id = NodeId}) ->
+		    Features = features(Type),
+		    PersistentFeature = lists:member("persistent-items", Features),
+		    DeleteFeature = lists:member("delete-items", Features),
+		    PublishModel = get_option(Options, publish_model),
+		    if
+			%%->   iq_pubsub just does that matchs
+			%%	%% Request does not specify an item
+			%%	{error, extended_error(?ERR_BAD_REQUEST, "item-required")};
+			not PersistentFeature ->
+			    %% Node does not support persistent items
+			    {error, extended_error(?ERR_FEATURE_NOT_IMPLEMENTED, unsupported, "persistent-items")};
+			not DeleteFeature ->
+			    %% Service does not support item deletion
+			    {error, extended_error(?ERR_FEATURE_NOT_IMPLEMENTED, unsupported, "delete-items")};
+			true ->
+			    node_call(Type, delete_item, [NodeId, Publisher, PublishModel, ItemId])
+		    end
 	     end,
     Reply = [],
     case transaction(Host, Node, Action, sync_dirty) of
@@ -1905,8 +1927,9 @@ get_items(Host, Node, From, SubId, SMaxItems, ItemIDs) ->
 	    end
     end.
 
-%% @spec (Host, NodeId, Type LJID, Number) -> any()
+%% @spec (Host, Node, NodeId, Type LJID, Number) -> any()
 %%	 Host = pubsubHost()
+%%	 Node = pubsubNode()
 %%	 NodeId = pubsubNodeId()
 %%	 Type = pubsubNodeType()
 %%	 LJID = {U, S, []}
diff --git a/src/mod_pubsub/node.template b/src/mod_pubsub/node.template
index 3879266a9..02cd26fa9 100644
--- a/src/mod_pubsub/node.template
+++ b/src/mod_pubsub/node.template
@@ -48,7 +48,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -130,8 +130,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_buddy.erl b/src/mod_pubsub/node_buddy.erl
index 4caa922f3..7bb93ba04 100644
--- a/src/mod_pubsub/node_buddy.erl
+++ b/src/mod_pubsub/node_buddy.erl
@@ -49,7 +49,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -133,8 +133,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_club.erl b/src/mod_pubsub/node_club.erl
index a7de3e855..9c978f48b 100644
--- a/src/mod_pubsub/node_club.erl
+++ b/src/mod_pubsub/node_club.erl
@@ -49,7 +49,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -132,8 +132,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_default.erl b/src/mod_pubsub/node_default.erl
index ac23cf20f..e7dd56900 100644
--- a/src/mod_pubsub/node_default.erl
+++ b/src/mod_pubsub/node_default.erl
@@ -56,7 +56,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -482,23 +482,25 @@ remove_extra_items(NodeId, MaxItems, ItemIds) ->
     %% Return the new items list:
     {result, {NewItems, OldItems}}.
 
-%% @spec (NodeId, JID, ItemId) ->
+%% @spec (NodeId, Publisher, PublishModel, ItemId) ->
 %%		  {error, Reason::stanzaError()} |
 %%		  {result, []}
 %%	 NodeId = mod_pubsub:pubsubNodeId()
-%%	 JID = mod_pubsub:jid()
+%%	 Publisher = mod_pubsub:jid()
+%%	 PublishModel = atom()
 %%	 ItemId = string()
 %% @doc <p>Triggers item deletion.</p>
 %% <p>Default plugin: The user performing the deletion must be the node owner
-%% or a publisher.</p>
-delete_item(NodeId, Publisher, ItemId) ->
+%% or a publisher, or PublishModel being open.</p>
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
     SubKey = jlib:jid_tolower(Publisher),
     GenKey = jlib:jid_remove_resource(SubKey),
     GenState = get_state(NodeId, GenKey),
     #pubsub_state{affiliation = Affiliation, items = Items} = GenState,
     Allowed = (Affiliation == publisher) orelse (Affiliation == owner)
+	orelse (PublishModel == open)
 	orelse case get_item(NodeId, ItemId) of
-		   {result, #pubsub_item{creation = {GenKey, _}}} -> true;
+		   {result, #pubsub_item{creation = {_, GenKey}}} -> true;
 		   _ -> false
 	       end,
     if
@@ -554,7 +556,7 @@ get_entity_affiliations(_Host, Owner) ->
 		%% TODO check if Host needed
 	       #pubsub_state{stateid = {GenKey, '_'}, _ = '_'}),
     Tr = fun(#pubsub_state{stateid = {_, N}, affiliation = A}) ->
-		 {N, A}
+		 {get_nodename(N), A}
 	 end,
     {result, lists:map(Tr, States)}.
 
@@ -604,7 +606,7 @@ get_entity_subscriptions(_Host, Owner) ->
 	       #pubsub_state{stateid = {SubKey, '_'}, _ = '_'})
     end,
     Tr = fun(#pubsub_state{stateid = {J, N}, subscription = S}) ->
-		 {N, S, J}
+		 {get_nodename(N), S, J}
 	 end,
     {result, lists:map(Tr, States)}.
 
@@ -810,3 +812,11 @@ can_fetch_item(outcast,      _)             -> false;
 can_fetch_item(none,         subscribed)    -> true;
 can_fetch_item(none,         none)          -> false;
 can_fetch_item(_Affiliation, _Subscription) -> false.
+
+%% @spec (NodeId) -> Node
+%% @doc retreive pubsubNode() representation giving a NodeId
+get_nodename(NodeId) ->
+    case mnesia:index_read(pubsub_node, NodeId, #pubsub_node.id) of
+	[#pubsub_node{nodeid = {_, Node}}] -> Node;
+	_ -> []
+    end.
diff --git a/src/mod_pubsub/node_dispatch.erl b/src/mod_pubsub/node_dispatch.erl
index 3ef07877d..a279d30ae 100644
--- a/src/mod_pubsub/node_dispatch.erl
+++ b/src/mod_pubsub/node_dispatch.erl
@@ -47,7 +47,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -134,7 +134,7 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(_NodeId, _MaxItems, ItemIds) ->
     {result, {ItemIds, []}}.
 
-delete_item(_NodeId, _JID, _ItemId) ->
+delete_item(_NodeId, _Publisher, _PublishModel, _ItemId) ->
     {error, ?ERR_ITEM_NOT_FOUND}.
 
 purge_node(_NodeId, _Owner) ->
diff --git a/src/mod_pubsub/node_flat.erl b/src/mod_pubsub/node_flat.erl
index db8fed519..2d484e97c 100644
--- a/src/mod_pubsub/node_flat.erl
+++ b/src/mod_pubsub/node_flat.erl
@@ -40,7 +40,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -119,8 +119,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_mb.erl b/src/mod_pubsub/node_mb.erl
index 9116f0f12..64142163a 100644
--- a/src/mod_pubsub/node_mb.erl
+++ b/src/mod_pubsub/node_mb.erl
@@ -52,7 +52,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -140,8 +140,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_pep:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_pep:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_pep:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_pep:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_pep.erl b/src/mod_pubsub/node_pep.erl
index 6a89aa1ec..d1d1731ef 100644
--- a/src/mod_pubsub/node_pep.erl
+++ b/src/mod_pubsub/node_pep.erl
@@ -45,7 +45,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -161,8 +161,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_private.erl b/src/mod_pubsub/node_private.erl
index 0a0e1e5f8..c0fb667ea 100644
--- a/src/mod_pubsub/node_private.erl
+++ b/src/mod_pubsub/node_private.erl
@@ -49,7 +49,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -135,8 +135,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/node_public.erl b/src/mod_pubsub/node_public.erl
index 6efe41d33..893609046 100644
--- a/src/mod_pubsub/node_public.erl
+++ b/src/mod_pubsub/node_public.erl
@@ -49,7 +49,7 @@
 	 subscribe_node/7,
 	 unsubscribe_node/4,
 	 publish_item/6,
-	 delete_item/3,
+	 delete_item/4,
 	 remove_extra_items/3,
 	 get_entity_affiliations/2,
 	 get_node_affiliations/1,
@@ -132,8 +132,8 @@ publish_item(NodeId, Publisher, Model, MaxItems, ItemId, Payload) ->
 remove_extra_items(NodeId, MaxItems, ItemIds) ->
     node_default:remove_extra_items(NodeId, MaxItems, ItemIds).
 
-delete_item(NodeId, JID, ItemId) ->
-    node_default:delete_item(NodeId, JID, ItemId).
+delete_item(NodeId, Publisher, PublishModel, ItemId) ->
+    node_default:delete_item(NodeId, Publisher, PublishModel, ItemId).
 
 purge_node(NodeId, Owner) ->
     node_default:purge_node(NodeId, Owner).
diff --git a/src/mod_pubsub/nodetree_default.erl b/src/mod_pubsub/nodetree_default.erl
index fa3516950..284fe7f8e 100644
--- a/src/mod_pubsub/nodetree_default.erl
+++ b/src/mod_pubsub/nodetree_default.erl
@@ -73,6 +73,7 @@ init(_Host, _ServerHost, _Opts) ->
     mnesia:create_table(pubsub_node,
 			[{disc_copies, [node()]},
 			 {attributes, record_info(fields, pubsub_node)}]),
+    mnesia:add_table_index(pubsub_node, id),
     NodesFields = record_info(fields, pubsub_node),
     case mnesia:table_info(pubsub_node, attributes) of
 	NodesFields -> ok;