pubsub identity and database update bugfix

SVN Revision: 1285

ChangeLog

@@ -1,6 +1,12 @@
+2008-04-10  Christophe Romain <christophe.romain@process-one.net>
+
+	* src/mod_pubsub/mod_pubsub.erl: fix identity and database update
+	bugfix
+	* src/mod_pubsub/nodetree_default.erl: Likewise
+
 2008-04-10  Mickael Remond  <mremond@process-one.net>
 
-	*src/ejabberd_c2s.erl: Uniform default value for empty privacy
+	* src/ejabberd_c2s.erl: Uniform default value for empty privacy
 	list. Fixes (EJAB-603).
 
 2008-04-08  Badlop  <badlop@process-one.net>

src/mod_pubsub/mod_pubsub.erl

@@ -232,7 +232,7 @@ init_nodes(Host, ServerHost, ServedHosts) ->
     lists:foreach(
       fun(H) ->
 	      create_node(Host, ServerHost, ["home", H], service_jid(Host), ?STDNODE)
-      end, [ServerHost | ServedHosts]),
+      end, lists:usort([ServerHost | ServedHosts])),
     ok.
 
 update_database(Host) ->
@@ -306,7 +306,7 @@ update_database(Host) ->
 identity(Host) ->
     Identity = case lists:member(?PEPNODE, plugins(Host)) of
     true -> [{"category", "pubsub"}, {"type", "pep"}];
-    false -> [{"category", "pubsub"}]
+    false -> [{"category", "pubsub"}, {"type", "service"}]
     end,
     {xmlelement, "identity", Identity, []}.
 
@@ -2280,38 +2280,44 @@ broadcast_by_caps({LUser, LServer, LResource}, Node, _Type, Stanza) ->
 				 [R|_] ->
 				     R;
 				 [] ->
-				     ?ERROR_MSG("~p@~p is offline; can't deliver ~p to contacts", [LUser, LServer, Stanza]),
 				     ""
 			     end;
 			 _ ->
 			     LResource
 		     end,
-    case ejabberd_sm:get_session_pid(LUser, LServer, SenderResource) of
+    case SenderResource of
-	C2SPid when is_pid(C2SPid) ->
+    "" ->
-	    %% set the from address on the notification to the bare JID of the account owner
+	?DEBUG("~p@~p is offline; can't deliver ~p to contacts", [LUser, LServer, Stanza]),
-	    %% Also, add "replyto" if entity has presence subscription to the account owner
+	ok;
-	    %% See XEP-0163 1.1 section 4.3.1
+    _ ->
-	    Sender = jlib:make_jid(LUser, LServer, ""),
+	case ejabberd_sm:get_session_pid(LUser, LServer, SenderResource) of
-	    %%ReplyTo = jlib:make_jid(LUser, LServer, SenderResource),  % This has to be used
+	    C2SPid when is_pid(C2SPid) ->
-	    case catch ejabberd_c2s:get_subscribed_and_online(C2SPid) of
+		%% set the from address on the notification to the bare JID of the account owner
-		ContactsWithCaps when is_list(ContactsWithCaps) ->
+		%% Also, add "replyto" if entity has presence subscription to the account owner
-		    ?DEBUG("found contacts with caps: ~p", [ContactsWithCaps]),
+		%% See XEP-0163 1.1 section 4.3.1
-		    lists:foreach(
+		Sender = jlib:make_jid(LUser, LServer, ""),
-		      fun({JID, Caps}) ->
+		%%ReplyTo = jlib:make_jid(LUser, LServer, SenderResource),  % This has to be used
-			    case is_caps_notify(LServer, Node, Caps) of
+		case catch ejabberd_c2s:get_subscribed_and_online(C2SPid) of
-				true ->
+		    ContactsWithCaps when is_list(ContactsWithCaps) ->
-				    To = jlib:make_jid(JID),
+			?DEBUG("found contacts with caps: ~p", [ContactsWithCaps]),
-				    ejabberd_router ! {route, Sender, To, Stanza};
+			lists:foreach(
-				false ->
+			fun({JID, Caps}) ->
-				    ok
+				case is_caps_notify(LServer, Node, Caps) of
-			    end
+				    true ->
-		      end, ContactsWithCaps);
+					To = jlib:make_jid(JID),
-		_ ->
+					ejabberd_router ! {route, Sender, To, Stanza};
-		    ok
+				    false ->
-	    end,
+					ok
-	    ok;
+				end
-	_ ->
+			end, ContactsWithCaps);
-	    ok
+		    _ ->
+			ok
+		end,
+		ok;
+	    _ ->
+		?DEBUG("~p@~p has no session; can't deliver ~p to contacts", [LUser, LServer, Stanza]),
+		ok
+	end
     end;
 broadcast_by_caps(_, _, _, _) ->
     ok.

src/mod_pubsub/nodetree_default.erl

@@ -74,6 +74,7 @@ init(_Host, _ServerHost, _Opts) ->
 			 {index, [type,parentid]}]),
     NodesFields = record_info(fields, pubsub_node),
     case mnesia:table_info(pubsub_node, attributes) of
+	[host_node, host_parent, info] -> ok;  % old schema, updated later by pubsub
 	NodesFields -> ok;
 	_ -> mnesia:transform_table(pubsub_node, ignore, NodesFields)
     end,