mirror of
https://github.com/processone/ejabberd.git
synced 2024-11-24 16:23:40 +01:00
Add tests for MUC MAM
This commit is contained in:
Evgeniy Khramtsov
parent
82082f1799
commit
8700a3401e
@ -303,6 +303,8 @@ db_tests(DB) when DB == mnesia; DB == redis ->
|
||||
[client_state_master, client_state_slave]},
|
||||
{test_muc, [parallel],
|
||||
[muc_master, muc_slave]},
|
||||
{test_muc_mam, [parallel],
|
||||
[muc_mam_master, muc_mam_slave]},
|
||||
{test_announce, [sequence],
|
||||
[announce_master, announce_slave]},
|
||||
{test_vcard_xupdate, [parallel],
|
||||
@ -343,6 +345,8 @@ db_tests(_) ->
|
||||
[mam_new_master, mam_new_slave]},
|
||||
{test_muc, [parallel],
|
||||
[muc_master, muc_slave]},
|
||||
{test_muc_mam, [parallel],
|
||||
[muc_mam_master, muc_mam_slave]},
|
||||
{test_announce, [sequence],
|
||||
[announce_master, announce_slave]},
|
||||
{test_vcard_xupdate, [parallel],
|
||||
@ -1189,6 +1193,92 @@ proxy65_slave(Config) ->
|
||||
socks5_recv(Socks5, Data),
|
||||
disconnect(Config).
|
||||
|
||||
send_messages_to_room(Config, Range) ->
|
||||
MyNick = ?config(master_nick, Config),
|
||||
Room = muc_room_jid(Config),
|
||||
MyNickJID = jid:replace_resource(Room, MyNick),
|
||||
lists:foreach(
|
||||
fun(N) ->
|
||||
Text = #text{data = integer_to_binary(N)},
|
||||
I = send(Config, #message{to = Room, body = [Text],
|
||||
type = groupchat}),
|
||||
?recv1(#message{from = MyNickJID, id = I,
|
||||
type = groupchat,
|
||||
body = [Text]})
|
||||
end, Range).
|
||||
|
||||
retrieve_messages_from_room_via_mam(Config, Range) ->
|
||||
MyNick = ?config(master_nick, Config),
|
||||
Room = muc_room_jid(Config),
|
||||
MyNickJID = jid:replace_resource(Room, MyNick),
|
||||
QID = randoms:get_string(),
|
||||
I = send(Config, #iq{type = set, to = Room,
|
||||
sub_els = [#mam_query{xmlns = ?NS_MAM_1, id = QID}]}),
|
||||
lists:foreach(
|
||||
fun(N) ->
|
||||
Text = #text{data = integer_to_binary(N)},
|
||||
?recv1(#message{
|
||||
to = MyJID, from = Room,
|
||||
sub_els =
|
||||
[#mam_result{
|
||||
xmlns = ?NS_MAM_1,
|
||||
queryid = QID,
|
||||
sub_els =
|
||||
[#forwarded{
|
||||
delay = #delay{},
|
||||
sub_els = [#message{
|
||||
from = MyNickJID,
|
||||
type = groupchat,
|
||||
body = [Text]}]}]}]})
|
||||
end, Range),
|
||||
?recv1(#iq{from = Room, id = I, type = result, sub_els = []}).
|
||||
|
||||
muc_mam_master(Config) ->
|
||||
MyJID = my_jid(Config),
|
||||
MyNick = ?config(master_nick, Config),
|
||||
Room = muc_room_jid(Config),
|
||||
MyNickJID = jid:replace_resource(Room, MyNick),
|
||||
%% Joining
|
||||
send(Config, #presence{to = MyNickJID, sub_els = [#muc{}]}),
|
||||
%% Receive self-presence
|
||||
?recv1(#presence{from = MyNickJID}),
|
||||
%% MAM feature should not be advertised at this point,
|
||||
%% because MAM is not enabled so far
|
||||
false = is_feature_advertised(Config, ?NS_MAM_1, Room),
|
||||
%% Fill in some history
|
||||
send_messages_to_room(Config, lists:seq(1, 21)),
|
||||
%% We now should be able to retrieve those via MAM, even though
|
||||
%% MAM is disabled. However, only last 20 messages should be received.
|
||||
retrieve_messages_from_room_via_mam(Config, lists:seq(2, 21)),
|
||||
%% Now enable MAM for the conference
|
||||
%% Retrieve config first
|
||||
#iq{type = result, sub_els = [#muc_owner{config = #xdata{} = RoomCfg}]} =
|
||||
send_recv(Config, #iq{type = get, sub_els = [#muc_owner{}],
|
||||
to = Room}),
|
||||
%% Find the MAM field in the config and enable it
|
||||
NewFields = lists:flatmap(
|
||||
fun(#xdata_field{var = <<"muc#roomconfig_mam">> = Var}) ->
|
||||
[#xdata_field{var = Var, values = [<<"1">>]}];
|
||||
(_) ->
|
||||
[]
|
||||
end, RoomCfg#xdata.fields),
|
||||
NewRoomCfg = #xdata{type = submit, fields = NewFields},
|
||||
I1 = send(Config, #iq{type = set, to = Room,
|
||||
sub_els = [#muc_owner{config = NewRoomCfg}]}),
|
||||
?recv2(#iq{type = result, id = I1},
|
||||
#message{from = Room, type = groupchat,
|
||||
sub_els = [#muc_user{status_codes = [104]}]}),
|
||||
%% Check if MAM has been enabled
|
||||
true = is_feature_advertised(Config, ?NS_MAM_1, Room),
|
||||
%% We now sending some messages again
|
||||
send_messages_to_room(Config, lists:seq(1, 5)),
|
||||
%% And retrieve them via MAM again.
|
||||
retrieve_messages_from_room_via_mam(Config, lists:seq(1, 5)),
|
||||
disconnect(Config).
|
||||
|
||||
muc_mam_slave(Config) ->
|
||||
disconnect(Config).
|
||||
|
||||
muc_master(Config) ->
|
||||
MyJID = my_jid(Config),
|
||||
PeerJID = ?config(slave, Config),
|
||||
|
||||
@ -103,6 +103,8 @@ decode({xmlel, _name, _attrs, _} = _el, Opts) ->
|
||||
decode_mam_fin(<<"urn:xmpp:mam:0">>, IgnoreEls, _el);
|
||||
{<<"prefs">>, <<"urn:xmpp:mam:0">>} ->
|
||||
decode_mam_prefs(<<"urn:xmpp:mam:0">>, IgnoreEls, _el);
|
||||
{<<"prefs">>, <<"urn:xmpp:mam:1">>} ->
|
||||
decode_mam_prefs(<<"urn:xmpp:mam:1">>, IgnoreEls, _el);
|
||||
{<<"prefs">>, <<"urn:xmpp:mam:tmp">>} ->
|
||||
decode_mam_prefs(<<"urn:xmpp:mam:tmp">>, IgnoreEls,
|
||||
_el);
|
||||
@ -116,6 +118,8 @@ decode({xmlel, _name, _attrs, _} = _el, Opts) ->
|
||||
decode_mam_jid(<<"urn:xmpp:mam:tmp">>, IgnoreEls, _el);
|
||||
{<<"result">>, <<"urn:xmpp:mam:0">>} ->
|
||||
decode_mam_result(<<"urn:xmpp:mam:0">>, IgnoreEls, _el);
|
||||
{<<"result">>, <<"urn:xmpp:mam:1">>} ->
|
||||
decode_mam_result(<<"urn:xmpp:mam:1">>, IgnoreEls, _el);
|
||||
{<<"result">>, <<"urn:xmpp:mam:tmp">>} ->
|
||||
decode_mam_result(<<"urn:xmpp:mam:tmp">>, IgnoreEls,
|
||||
_el);
|
||||
@ -124,6 +128,8 @@ decode({xmlel, _name, _attrs, _} = _el, Opts) ->
|
||||
_el);
|
||||
{<<"query">>, <<"urn:xmpp:mam:0">>} ->
|
||||
decode_mam_query(<<"urn:xmpp:mam:0">>, IgnoreEls, _el);
|
||||
{<<"query">>, <<"urn:xmpp:mam:1">>} ->
|
||||
decode_mam_query(<<"urn:xmpp:mam:1">>, IgnoreEls, _el);
|
||||
{<<"query">>, <<"urn:xmpp:mam:tmp">>} ->
|
||||
decode_mam_query(<<"urn:xmpp:mam:tmp">>, IgnoreEls,
|
||||
_el);
|
||||
@ -1141,14 +1147,17 @@ is_known_tag({xmlel, _name, _attrs, _} = _el) ->
|
||||
{<<"forwarded">>, <<"urn:xmpp:forward:0">>} -> true;
|
||||
{<<"fin">>, <<"urn:xmpp:mam:0">>} -> true;
|
||||
{<<"prefs">>, <<"urn:xmpp:mam:0">>} -> true;
|
||||
{<<"prefs">>, <<"urn:xmpp:mam:1">>} -> true;
|
||||
{<<"prefs">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"always">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"never">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"jid">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"result">>, <<"urn:xmpp:mam:0">>} -> true;
|
||||
{<<"result">>, <<"urn:xmpp:mam:1">>} -> true;
|
||||
{<<"result">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"archived">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"query">>, <<"urn:xmpp:mam:0">>} -> true;
|
||||
{<<"query">>, <<"urn:xmpp:mam:1">>} -> true;
|
||||
{<<"query">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"with">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
{<<"end">>, <<"urn:xmpp:mam:tmp">>} -> true;
|
||||
|
||||
@ -2145,7 +2145,7 @@
|
||||
|
||||
-xml(mam_query,
|
||||
#elem{name = <<"query">>,
|
||||
xmlns = [<<"urn:xmpp:mam:0">>, <<"urn:xmpp:mam:tmp">>],
|
||||
xmlns = [<<"urn:xmpp:mam:0">>, <<"urn:xmpp:mam:1">>, <<"urn:xmpp:mam:tmp">>],
|
||||
result = {mam_query, '$xmlns', '$id', '$start', '$end', '$with',
|
||||
'$rsm', '$xdata'},
|
||||
attrs = [#attr{name = <<"queryid">>, label = '$id'},
|
||||
@ -2168,7 +2168,7 @@
|
||||
|
||||
-xml(mam_result,
|
||||
#elem{name = <<"result">>,
|
||||
xmlns = [<<"urn:xmpp:mam:0">>, <<"urn:xmpp:mam:tmp">>],
|
||||
xmlns = [<<"urn:xmpp:mam:0">>, <<"urn:xmpp:mam:1">>, <<"urn:xmpp:mam:tmp">>],
|
||||
result = {mam_result, '$xmlns', '$queryid', '$id', '$_els'},
|
||||
attrs = [#attr{name = <<"queryid">>},
|
||||
#attr{name = <<"xmlns">>},
|
||||
@ -2196,7 +2196,7 @@
|
||||
|
||||
-xml(mam_prefs,
|
||||
#elem{name = <<"prefs">>,
|
||||
xmlns = [<<"urn:xmpp:mam:0">>, <<"urn:xmpp:mam:tmp">>],
|
||||
xmlns = [<<"urn:xmpp:mam:0">>, <<"urn:xmpp:mam:1">>, <<"urn:xmpp:mam:tmp">>],
|
||||
result = {mam_prefs, '$xmlns', '$default', '$always', '$never'},
|
||||
attrs = [#attr{name = <<"default">>,
|
||||
dec = {dec_enum, [[always, never, roster]]},
|
||||
|
||||
Loading…
Reference in New Issue
Block a user