Chapril/xmpp.chapril.org-ejabberd
25
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-12-26 17:38:45 +01:00
Code Releases Activity

port commit from r2527 to odbc plugin

Browse Source 
SVN Revision: 2543
This commit is contained in:
Christophe Romain 2009-08-27 08:17:44 +00:00
parent 2c735c91d6
commit 670d7c7ebd
2 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/mod_pubsub/node_hometree.erl
View File

@ -702,7 +702,7 @@ set_subscriptions(NodeId, Owner, Subscription, SubId) ->
case {SubId, SubState#pubsub_state.subscriptions} of case {SubId, SubState#pubsub_state.subscriptions} of
{_, []} -> {_, []} ->
case Subscription of case Subscription of
none -> ok; none -> {error, ?ERR_EXTENDED(?ERR_BAD_REQUEST, "not-subscribed")};
_ -> new_subscription(NodeId, Owner, Subscription, SubState) _ -> new_subscription(NodeId, Owner, Subscription, SubState)
end; end;
{"", [{_, SID}]} -> {"", [{_, SID}]} ->

15
src/mod_pubsub/node_hometree_odbc.erl
View File

@ -740,7 +740,10 @@ set_subscriptions(NodeId, Owner, Subscription, SubId) ->
SubState = get_state_without_itemids(NodeId, SubKey), SubState = get_state_without_itemids(NodeId, SubKey),
case {SubId, SubState#pubsub_state.subscriptions} of case {SubId, SubState#pubsub_state.subscriptions} of
{_, []} -> {_, []} ->
{error, ?ERR_ITEM_NOT_FOUND}; case Subscription of
none -> {error, ?ERR_EXTENDED(?ERR_BAD_REQUEST, "not-subscribed")};
_ -> new_subscription(NodeId, Owner, Subscription, SubState)
end;
{"", [{_, SID}]} -> {"", [{_, SID}]} ->
case Subscription of case Subscription of
none -> unsub_with_subid(NodeId, SID, SubState); none -> unsub_with_subid(NodeId, SID, SubState);
@ -765,6 +768,16 @@ replace_subscription(_, [], Acc) ->
replace_subscription({Sub, SubId}, [{_, SubID} | T], Acc) -> replace_subscription({Sub, SubId}, [{_, SubID} | T], Acc) ->
replace_subscription({Sub, SubId}, T, [{Sub, SubID} | Acc]). replace_subscription({Sub, SubId}, T, [{Sub, SubID} | Acc]).
new_subscription(NodeId, Owner, Subscription, SubState) ->
case pubsub_subscription_odbc:subscribe_node(Owner, NodeId, []) of
{result, SubId} ->
Subscriptions = SubState#pubsub_state.subscriptions,
set_state(SubState#pubsub_state{subscriptions = [{Subscription, SubId} | Subscriptions]}),
{Subscription, SubId};
_ ->
{error, ?ERR_INTERNAL_SERVER_ERROR}
end.
unsub_with_subid(NodeId, SubId, SubState) -> unsub_with_subid(NodeId, SubId, SubState) ->
pubsub_subscription_odbc:unsubscribe_node(SubState#pubsub_state.stateid, pubsub_subscription_odbc:unsubscribe_node(SubState#pubsub_state.stateid,
NodeId, SubId), NodeId, SubId),