25
1
mirror of https://github.com/processone/ejabberd.git synced 2024-11-22 16:20:52 +01:00

minor bug fixes related to the use/conversion of/to exmpp (thanks to Karim Gemayel)

SVN Revision: 2732
This commit is contained in:
Christophe Romain 2009-11-06 14:34:23 +00:00
parent 1c4cc57e3f
commit a1e9b55ead
4 changed files with 34 additions and 33 deletions

View File

@ -1228,7 +1228,7 @@ iq_sm(From, To, #iq{type = Type, payload = SubEl, ns = XMLNS, lang = Lang} = IQ_
end, end,
case Res of case Res of
{result, []} -> exmpp_iq:result(IQ_Rec); {result, []} -> exmpp_iq:result(IQ_Rec);
{result, [IQRes]} -> exmpp_iq:result(IQ_Rec, IQRes); {result, IQRes} -> exmpp_iq:result(IQ_Rec, IQRes);
{error, Error} -> exmpp_iq:error(IQ_Rec, Error) {error, Error} -> exmpp_iq:error(IQ_Rec, Error)
end. end.
@ -2848,12 +2848,11 @@ set_subscriptions(Host, Node, From, EntitiesEls) ->
%% @spec (OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, SubscriberResource}, AllowedGroups) %% @spec (OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, SubscriberResource}, AllowedGroups)
%% -> {PresenceSubscription, RosterGroup} %% -> {PresenceSubscription, RosterGroup}
get_roster_info(OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, _}, AllowedGroups) -> get_roster_info(OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, _}, AllowedGroups) ->
OwnerServerB = list_to_binary(OwnerServer),
{Subscription, Groups} = {Subscription, Groups} =
ejabberd_hooks:run_fold( ejabberd_hooks:run_fold(
roster_get_jid_info, OwnerServerB, roster_get_jid_info, OwnerServer,
{none, []}, {none, []},
[OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, undefined}]), [OwnerUser, OwnerServer, exmpp_jid:make({SubscriberUser, SubscriberServer, undefined})]),
PresenceSubscription = (Subscription == both) orelse (Subscription == from) PresenceSubscription = (Subscription == both) orelse (Subscription == from)
orelse ({OwnerUser, OwnerServer} == {SubscriberUser, SubscriberServer}), orelse ({OwnerUser, OwnerServer} == {SubscriberUser, SubscriberServer}),
RosterGroup = lists:any(fun(Group) -> RosterGroup = lists:any(fun(Group) ->

View File

@ -1036,7 +1036,7 @@ iq_sm(From, To, #iq{type = Type, payload = SubEl, ns = XMLNS, lang = Lang} = IQ_
end, end,
case Res of case Res of
{result, []} -> exmpp_iq:result(IQ_Rec); {result, []} -> exmpp_iq:result(IQ_Rec);
{result, [IQRes]} -> exmpp_iq:result(IQ_Rec, IQRes); {result, IQRes} -> exmpp_iq:result(IQ_Rec, IQRes);
{error, Error} -> exmpp_iq:error(IQ_Rec, Error) {error, Error} -> exmpp_iq:error(IQ_Rec, Error)
end. end.
@ -2658,12 +2658,11 @@ set_subscriptions(Host, Node, From, EntitiesEls) ->
%% @spec (OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, SubscriberResource}, AllowedGroups) %% @spec (OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, SubscriberResource}, AllowedGroups)
%% -> {PresenceSubscription, RosterGroup} %% -> {PresenceSubscription, RosterGroup}
get_roster_info(OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, _}, AllowedGroups) -> get_roster_info(OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, _}, AllowedGroups) ->
OwnerServerB = list_to_binary(OwnerServer),
{Subscription, Groups} = {Subscription, Groups} =
ejabberd_hooks:run_fold( ejabberd_hooks:run_fold(
roster_get_jid_info, OwnerServerB, roster_get_jid_info, OwnerServer,
{none, []}, {none, []},
[OwnerUser, OwnerServer, {SubscriberUser, SubscriberServer, undefined}]), [OwnerUser, OwnerServer, exmpp_jid:make({SubscriberUser, SubscriberServer, undefined})]),
PresenceSubscription = (Subscription == both) orelse (Subscription == from) PresenceSubscription = (Subscription == both) orelse (Subscription == from)
orelse ({OwnerUser, OwnerServer} == {SubscriberUser, SubscriberServer}), orelse ({OwnerUser, OwnerServer} == {SubscriberUser, SubscriberServer}),
RosterGroup = lists:any(fun(Group) -> RosterGroup = lists:any(fun(Group) ->

View File

@ -1,5 +1,5 @@
--- mod_pubsub.erl 2009-11-05 18:37:16.000000000 +0100 --- mod_pubsub.erl 2009-11-06 15:30:53.000000000 +0100
+++ mod_pubsub_odbc.erl 2009-11-05 18:37:21.000000000 +0100 +++ mod_pubsub_odbc.erl 2009-11-06 15:31:06.000000000 +0100
@@ -42,7 +42,7 @@ @@ -42,7 +42,7 @@
%%% 6.2.3.1, 6.2.3.5, and 6.3. For information on subscription leases see %%% 6.2.3.1, 6.2.3.5, and 6.3. For information on subscription leases see
%%% XEP-0060 section 12.18. %%% XEP-0060 section 12.18.
@ -679,7 +679,7 @@
true -> true ->
Result = lists:foldl(fun({JID, Subscription, SubId}, Acc) -> Result = lists:foldl(fun({JID, Subscription, SubId}, Acc) ->
@@ -3111,7 +2921,7 @@ @@ -3110,7 +2920,7 @@
{Depth, [{N, get_node_subs(N)} || N <- Nodes]} {Depth, [{N, get_node_subs(N)} || N <- Nodes]}
end, tree_call(Host, get_parentnodes_tree, [Host, Node, service_jid(Host)]))} end, tree_call(Host, get_parentnodes_tree, [Host, Node, service_jid(Host)]))}
end, end,
@ -688,7 +688,7 @@
{result, CollSubs} -> CollSubs; {result, CollSubs} -> CollSubs;
_ -> [] _ -> []
end. end.
@@ -3125,9 +2935,9 @@ @@ -3124,9 +2934,9 @@
get_options_for_subs(NodeID, Subs) -> get_options_for_subs(NodeID, Subs) ->
lists:foldl(fun({JID, subscribed, SubID}, Acc) -> lists:foldl(fun({JID, subscribed, SubID}, Acc) ->
@ -700,7 +700,7 @@
_ -> Acc _ -> Acc
end; end;
(_, Acc) -> (_, Acc) ->
@@ -3135,7 +2945,7 @@ @@ -3134,7 +2944,7 @@
end, [], Subs). end, [], Subs).
% TODO: merge broadcast code that way % TODO: merge broadcast code that way
@ -709,7 +709,7 @@
%broadcast(Host, Node, NodeId, Type, NodeOptions, Feature, Force, ElName, SubEls) -> %broadcast(Host, Node, NodeId, Type, NodeOptions, Feature, Force, ElName, SubEls) ->
% case (get_option(NodeOptions, Feature) or Force) of % case (get_option(NodeOptions, Feature) or Force) of
% true -> % true ->
@@ -3327,6 +3137,30 @@ @@ -3326,6 +3136,30 @@
Result Result
end. end.
@ -740,7 +740,7 @@
%% @spec (Host, Options) -> MaxItems %% @spec (Host, Options) -> MaxItems
%% Host = host() %% Host = host()
%% Options = [Option] %% Options = [Option]
@@ -3716,7 +3550,13 @@ @@ -3715,7 +3549,13 @@
tree_action(Host, Function, Args) -> tree_action(Host, Function, Args) ->
?DEBUG("tree_action ~p ~p ~p",[Host,Function,Args]), ?DEBUG("tree_action ~p ~p ~p",[Host,Function,Args]),
Fun = fun() -> tree_call(Host, Function, Args) end, Fun = fun() -> tree_call(Host, Function, Args) end,
@ -755,7 +755,7 @@
%% @doc <p>node plugin call.</p> %% @doc <p>node plugin call.</p>
node_call(Type, Function, Args) -> node_call(Type, Function, Args) ->
@@ -3736,13 +3576,13 @@ @@ -3735,13 +3575,13 @@
node_action(Host, Type, Function, Args) -> node_action(Host, Type, Function, Args) ->
?DEBUG("node_action ~p ~p ~p ~p",[Host,Type,Function,Args]), ?DEBUG("node_action ~p ~p ~p ~p",[Host,Type,Function,Args]),
@ -771,7 +771,7 @@
case tree_call(Host, get_node, [Host, Node]) of case tree_call(Host, get_node, [Host, Node]) of
N when is_record(N, pubsub_node) -> N when is_record(N, pubsub_node) ->
case Action(N) of case Action(N) of
@@ -3755,8 +3595,15 @@ @@ -3754,8 +3594,15 @@
end end
end, Trans). end, Trans).
@ -789,7 +789,7 @@
{result, Result} -> {result, Result}; {result, Result} -> {result, Result};
{error, Error} -> {error, Error}; {error, Error} -> {error, Error};
{atomic, {result, Result}} -> {result, Result}; {atomic, {result, Result}} -> {result, Result};
@@ -3764,6 +3611,15 @@ @@ -3763,6 +3610,15 @@
{aborted, Reason} -> {aborted, Reason} ->
?ERROR_MSG("transaction return internal error: ~p~n", [{aborted, Reason}]), ?ERROR_MSG("transaction return internal error: ~p~n", [{aborted, Reason}]),
{error, 'internal-server-error'}; {error, 'internal-server-error'};
@ -805,7 +805,7 @@
{'EXIT', Reason} -> {'EXIT', Reason} ->
?ERROR_MSG("transaction return internal error: ~p~n", [{'EXIT', Reason}]), ?ERROR_MSG("transaction return internal error: ~p~n", [{'EXIT', Reason}]),
{error, 'internal-server-error'}; {error, 'internal-server-error'};
@@ -3772,6 +3628,16 @@ @@ -3771,6 +3627,16 @@
{error, 'internal-server-error'} {error, 'internal-server-error'}
end. end.

View File

@ -138,20 +138,23 @@ get_options_xform(Lang, Options) ->
children = [?XMLCDATA(?NS_PUBSUB_SUBSCRIBE_OPTIONS_s)]}]}] ++ XFields}}. children = [?XMLCDATA(?NS_PUBSUB_SUBSCRIBE_OPTIONS_s)]}]}] ++ XFields}}.
parse_options_xform(XFields) -> parse_options_xform(XFields) ->
case exmpp_xml:get_child_elements(XFields) of case XFields of
[] -> {result, []}; [] -> {result, []};
[#xmlel{name = 'x'} = XEl] -> _ -> case exmpp_xml:get_child_elements(XFields) of
case jlib:parse_xdata_submit(XEl) of [] -> {result, []};
XData when is_list(XData) -> [#xmlel{name = 'x'} = XEl] ->
case set_xoption(XData, []) of case jlib:parse_xdata_submit(XEl) of
Opts when is_list(Opts) -> {result, Opts}; XData when is_list(XData) ->
Other -> Other case set_xoption(XData, []) of
end; Opts when is_list(Opts) -> {result, Opts};
Other -> Other -> Other
Other end;
end; Other ->
Other -> Other
Other end;
Other ->
Other
end
end. end.
%%==================================================================== %%====================================================================