mirror of
https://github.com/processone/ejabberd.git
synced 2024-12-26 17:38:45 +01:00
fix pep not fetching subscriptions
SVN Revision: 2551
This commit is contained in:
parent
054ad379ce
commit
51e2896914
@ -196,24 +196,24 @@ get_entity_subscriptions(_Host, Owner) ->
|
||||
GJ = node_hometree_odbc:encode_jid(GenKey),
|
||||
Query = case SubKey of
|
||||
GenKey ->
|
||||
["select host, node, type, i.nodeid, jid, subscription "
|
||||
["select host, node, type, i.nodeid, jid, subscriptions "
|
||||
"from pubsub_state i, pubsub_node n "
|
||||
"where i.nodeid = n.nodeid "
|
||||
"and jid like '", GJ, "%' "
|
||||
"and host like '%@", Host, "';"];
|
||||
_ ->
|
||||
["select host, node, type, i.nodeid, jid, subscription "
|
||||
["select host, node, type, i.nodeid, jid, subscriptions "
|
||||
"from pubsub_state i, pubsub_node n "
|
||||
"where i.nodeid = n.nodeid "
|
||||
"and jid in ('", SJ, "', '", GJ, "') "
|
||||
"and host like '%@", Host, "';"]
|
||||
end,
|
||||
Reply = case catch ejabberd_odbc:sql_query_t(Query) of
|
||||
{selected, ["host", "node", "type", "nodeid", "jid", "subscription"], RItems} ->
|
||||
{selected, ["host", "node", "type", "nodeid", "jid", "subscriptions"], RItems} ->
|
||||
lists:map(fun({H, N, T, I, J, S}) ->
|
||||
O = node_hometree_odbc:decode_jid(H),
|
||||
Node = nodetree_odbc:raw_to_node(O, {N, "", T, I}),
|
||||
{Node, node_hometree_odbc:decode_subscription(S), node_hometree_odbc:decode_jid(J)}
|
||||
{Node, node_hometree_odbc:decode_subscriptions(S), node_hometree_odbc:decode_jid(J)}
|
||||
end, RItems);
|
||||
_ ->
|
||||
[]
|
||||
@ -228,14 +228,14 @@ get_entity_subscriptions_for_send_last(_Host, Owner) ->
|
||||
GJ = node_hometree_odbc:encode_jid(GenKey),
|
||||
Query = case SubKey of
|
||||
GenKey ->
|
||||
["select host, node, type, i.nodeid, jid, subscription "
|
||||
["select host, node, type, i.nodeid, jid, subscriptions "
|
||||
"from pubsub_state i, pubsub_node n, pubsub_node_option o "
|
||||
"where i.nodeid = n.nodeid and n.nodeid = o.nodeid "
|
||||
"and name='send_last_published_item' and val='on_sub_and_presence' "
|
||||
"and jid like '", GJ, "%' "
|
||||
"and host like '%@", Host, "';"];
|
||||
_ ->
|
||||
["select host, node, type, i.nodeid, jid, subscription "
|
||||
["select host, node, type, i.nodeid, jid, subscriptions "
|
||||
"from pubsub_state i, pubsub_node n, pubsub_node_option o "
|
||||
"where i.nodeid = n.nodeid and n.nodeid = o.nodeid "
|
||||
"and name='send_last_published_item' and val='on_sub_and_presence' "
|
||||
@ -243,11 +243,11 @@ get_entity_subscriptions_for_send_last(_Host, Owner) ->
|
||||
"and host like '%@", Host, "';"]
|
||||
end,
|
||||
Reply = case catch ejabberd_odbc:sql_query_t(Query) of
|
||||
{selected, ["host", "node", "type", "nodeid", "jid", "subscription"], RItems} ->
|
||||
{selected, ["host", "node", "type", "nodeid", "jid", "subscriptions"], RItems} ->
|
||||
lists:map(fun({H, N, T, I, J, S}) ->
|
||||
O = node_hometree_odbc:decode_jid(H),
|
||||
Node = nodetree_odbc:raw_to_node(O, {N, "", T, I}),
|
||||
{Node, node_hometree_odbc:decode_subscription(S), node_hometree_odbc:decode_jid(J)}
|
||||
{Node, node_hometree_odbc:decode_subscriptions(S), node_hometree_odbc:decode_jid(J)}
|
||||
end, RItems);
|
||||
_ ->
|
||||
[]
|
||||
|
Loading…
Reference in New Issue
Block a user