diff --git a/src/mod_pubsub/mod_pubsub.erl b/src/mod_pubsub/mod_pubsub.erl index e5aaeaa9b..578441bca 100644 --- a/src/mod_pubsub/mod_pubsub.erl +++ b/src/mod_pubsub/mod_pubsub.erl @@ -1552,7 +1552,7 @@ send_authorization_request(#pubsub_node{owners = Owners, nodeid = {Host, Node}}, [#xmlel{ns = ?NS_DATA_FORMS, name = 'value', children = [#xmlcdata{cdata = <<"false">>}]}]}]}]}, lists:foreach(fun(Owner) -> {U, S, R} = Owner, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza} + ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza) end, Owners). find_authorization_response(Packet) -> @@ -1597,7 +1597,7 @@ send_authorization_approval(Host, JID, SNode, Subscription) -> [#xmlel{ns = ?NS_PUBSUB_EVENT, name = 'subscription', attrs = [ ?XMLATTR('jid', exmpp_jid:to_binary(JID)) | nodeAttr(SNode)] ++ SubAttrs }]), - ejabberd_router ! {route, service_jid(Host), JID, Stanza}. + ejabberd_router:route(service_jid(Host), JID, Stanza). handle_authorization_response(Host, From, To, Packet, XFields) -> case {lists:keysearch("pubsub#node", 1, XFields), @@ -2379,7 +2379,7 @@ send_items(Host, Node, NodeId, Type, LJID, last) -> [#xmlel{ns = ?NS_PUBSUB_EVENT, name = 'items', attrs = nodeAttr(Node), children = itemsEls(LastItem)}], ModifNow, ModifLjid), {U, S, R} = LJID, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza} + ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza) end; send_items(Host, Node, NodeId, Type, {LU, LS, LR} = LJID, Number) -> ToSend = case node_action(Host, Type, get_items, [NodeId, LJID]) of @@ -2404,7 +2404,7 @@ send_items(Host, Node, NodeId, Type, {LU, LS, LR} = LJID, Number) -> [#xmlel{ns = ?NS_PUBSUB_EVENT, name = 'items', attrs = nodeAttr(Node), children = itemsEls(ToSend)}]) end, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(LU, LS, LR), Stanza}. + ejabberd_router:route(service_jid(Host), exmpp_jid:make(LU, LS, LR), Stanza). %% @spec (Host, JID, Plugins) -> {error, Reason} | {result, Response} %% Host = host() @@ -2818,7 +2818,7 @@ set_subscriptions(Host, Node, From, EntitiesEls) -> name = 'subscription', attrs = [?XMLATTR('jid', exmpp_jid:to_binary(JID)), ?XMLATTR('subsription', subscription_to_string(Sub)) | nodeAttr(Node)]}]}]}, - ejabberd_router ! {route, service_jid(Host), JID, Stanza} + ejabberd_router:route(service_jid(Host), JID, Stanza) end, Action = fun(#pubsub_node{owners = Owners, type = Type, id = NodeId}) -> case lists:member(Owner, Owners) of @@ -3173,7 +3173,7 @@ broadcast_stanza(Host, Node, _NodeId, _Type, NodeOptions, SubsByDepth, NotifyTyp SHIMStanza = add_headers(Stanza, collection_shim(Node, Nodes)), lists:foreach(fun(To) -> {TU, TS, TR} = To, - ejabberd_router ! {route, From, exmpp_jid:make(TU, TS, TR), SHIMStanza} + ejabberd_router:route(From, exmpp_jid:make(TU, TS, TR), SHIMStanza) end, LJIDs) end, NodesByJID), %% Handles implicit presence subscriptions @@ -3206,7 +3206,7 @@ broadcast_stanza(Host, Node, _NodeId, _Type, NodeOptions, SubsByDepth, NotifyTyp end end, [], user_resources(U, S)), lists:foreach(fun(R) -> - ejabberd_router ! {route, Sender, exmpp_jid:make(U, S, R), Stanza} + ejabberd_router:route(Sender, exmpp_jid:make(U, S, R), Stanza) end, Rs) end) end, Contacts); diff --git a/src/mod_pubsub/mod_pubsub_odbc.erl b/src/mod_pubsub/mod_pubsub_odbc.erl index 3bcafd3c8..d0668080a 100644 --- a/src/mod_pubsub/mod_pubsub_odbc.erl +++ b/src/mod_pubsub/mod_pubsub_odbc.erl @@ -1363,7 +1363,7 @@ send_authorization_request(#pubsub_node{nodeid = {Host, Node}, type = Type, id = [#xmlel{ns = ?NS_DATA_FORMS, name = 'value', children = [#xmlcdata{cdata = <<"false">>}]}]}]}]}, lists:foreach(fun(Owner) -> {U, S, R} = Owner, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza} + ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza) end, node_owners(Host, Type, NodeId)). find_authorization_response(Packet) -> @@ -1408,7 +1408,7 @@ send_authorization_approval(Host, JID, SNode, Subscription) -> [#xmlel{ns = ?NS_PUBSUB_EVENT, name = 'subscription', attrs = [?XMLATTR('jid', exmpp_jid:to_binary(JID)) | nodeAttr(SNode)] ++ SubAttrs }]), - ejabberd_router ! {route, service_jid(Host), JID, Stanza}. + ejabberd_router:route(service_jid(Host), JID, Stanza). handle_authorization_response(Host, From, To, Packet, XFields) -> case {lists:keysearch("pubsub#node", 1, XFields), @@ -2207,7 +2207,7 @@ send_items(Host, Node, NodeId, Type, LJID, last) -> children = itemsEls(LastItem)}], ModifNow, ModifLjid) end, {U, S, R} = LJID, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza}; + ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza); send_items(Host, Node, NodeId, Type, {LU, LS, LR} = LJID, Number) -> ToSend = case node_action(Host, Type, get_items, [NodeId, LJID]) of {result, []} -> @@ -2231,7 +2231,7 @@ send_items(Host, Node, NodeId, Type, {LU, LS, LR} = LJID, Number) -> [#xmlel{ns = ?NS_PUBSUB_EVENT, name = 'items', attrs = nodeAttr(Node), children = itemsEls(ToSend)}]) end, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(LU, LS, LR), Stanza}. + ejabberd_router:route(service_jid(Host), exmpp_jid:make(LU, LS, LR), Stanza). %% @spec (Host, JID, Plugins) -> {error, Reason} | {result, Response} %% Host = host() @@ -2628,7 +2628,7 @@ set_subscriptions(Host, Node, From, EntitiesEls) -> name = 'subscription', attrs = [?XMLATTR('jid', exmpp_jid:to_binary(JID)), ?XMLATTR('subsription', subscription_to_string(Sub)) | nodeAttr(Node)]}]}]}, - ejabberd_router ! {route, service_jid(Host), JID, Stanza} + ejabberd_router:route(service_jid(Host), JID, Stanza) end, Action = fun(#pubsub_node{type = Type, id = NodeId}) -> case lists:member(Owner, node_owners_call(Type, NodeId)) of @@ -2983,7 +2983,7 @@ broadcast_stanza(Host, Node, _NodeId, _Type, NodeOptions, SubsByDepth, NotifyTyp SHIMStanza = add_headers(Stanza, collection_shim(Node, Nodes)), lists:foreach(fun(To) -> {TU, TS, TR} = To, - ejabberd_router ! {route, From, exmpp_jid:make(TU, TS, TR), SHIMStanza} + ejabberd_router:route(From, exmpp_jid:make(TU, TS, TR), SHIMStanza) end, LJIDs) end, NodesByJID), %% Handles implicit presence subscriptions @@ -3016,7 +3016,7 @@ broadcast_stanza(Host, Node, _NodeId, _Type, NodeOptions, SubsByDepth, NotifyTyp end end, [], user_resources(U, S)), lists:foreach(fun(R) -> - ejabberd_router ! {route, Sender, exmpp_jid:make(U, S, R), Stanza} + ejabberd_router:route(Sender, exmpp_jid:make(U, S, R), Stanza) end, Rs) end) end, Contacts); diff --git a/src/mod_pubsub/pubsub_odbc.patch b/src/mod_pubsub/pubsub_odbc.patch index 368866d30..57a3abf2c 100644 --- a/src/mod_pubsub/pubsub_odbc.patch +++ b/src/mod_pubsub/pubsub_odbc.patch @@ -457,7 +457,7 @@ @@ -1553,7 +1364,7 @@ lists:foreach(fun(Owner) -> {U, S, R} = Owner, - ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza} + ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza) - end, Owners). + end, node_owners(Host, Type, NodeId)). @@ -470,7 +470,7 @@ - [ ?XMLATTR('jid', exmpp_jid:to_binary(JID)) | nodeAttr(SNode)] ++ SubAttrs + [?XMLATTR('jid', exmpp_jid:to_binary(JID)) | nodeAttr(SNode)] ++ SubAttrs }]), - ejabberd_router ! {route, service_jid(Host), JID, Stanza}. + ejabberd_router:route(service_jid(Host), JID, Stanza). @@ -1606,14 +1417,14 @@ {{value, {_, [SNode]}}, {value, {_, [SSubscriber]}}, @@ -594,12 +594,12 @@ [#xmlel{ns = ?NS_PUBSUB_EVENT, name = 'items', attrs = nodeAttr(Node), - children = itemsEls(LastItem)}], ModifNow, ModifLjid), - {U, S, R} = LJID, -- ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza} +- ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza) - end; + children = itemsEls(LastItem)}], ModifNow, ModifLjid) + end, + {U, S, R} = LJID, -+ ejabberd_router ! {route, service_jid(Host), exmpp_jid:make(U, S, R), Stanza}; ++ ejabberd_router:route(service_jid(Host), exmpp_jid:make(U, S, R), Stanza); send_items(Host, Node, NodeId, Type, {LU, LS, LR} = LJID, Number) -> ToSend = case node_action(Host, Type, get_items, [NodeId, LJID]) of {result, []} -> @@ -670,7 +670,7 @@ {result, _} -> @@ -2820,8 +2630,8 @@ ?XMLATTR('subsription', subscription_to_string(Sub)) | nodeAttr(Node)]}]}]}, - ejabberd_router ! {route, service_jid(Host), JID, Stanza} + ejabberd_router:route(service_jid(Host), JID, Stanza) end, - Action = fun(#pubsub_node{owners = Owners, type = Type, id = NodeId}) -> - case lists:member(Owner, Owners) of diff --git a/src/mod_vcard.erl b/src/mod_vcard.erl index 4aedf18d2..486d761a3 100644 --- a/src/mod_vcard.erl +++ b/src/mod_vcard.erl @@ -316,7 +316,7 @@ do_route(ServerHost, From, To, Packet) -> if (User /= undefined) or (Resource /= undefined) -> Err = exmpp_stanza:reply_with_error(Packet, 'service-unavailable'), - ejabberd_router ! {route, To, From, Err}; + ejabberd_router:route(To, From, Err); true -> try Request = exmpp_iq:get_request(Packet),