diff options
Diffstat (limited to 'lib/megaco/test/megaco_codec_v2_test.erl')
| -rw-r--r-- | lib/megaco/test/megaco_codec_v2_test.erl | 6992 |
1 files changed, 6992 insertions, 0 deletions
diff --git a/lib/megaco/test/megaco_codec_v2_test.erl b/lib/megaco/test/megaco_codec_v2_test.erl new file mode 100644 index 0000000000..1df1c6c93b --- /dev/null +++ b/lib/megaco/test/megaco_codec_v2_test.erl @@ -0,0 +1,6992 @@ +%% +%% %CopyrightBegin% +%% +%% Copyright Ericsson AB 2003-2009. All Rights Reserved. +%% +%% The contents of this file are subject to the Erlang Public License, +%% Version 1.1, (the "License"); you may not use this file except in +%% compliance with the License. You should have received a copy of the +%% Erlang Public License along with this software. If not, it can be +%% retrieved online at http://www.erlang.org/. +%% +%% Software distributed under the License is distributed on an "AS IS" +%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +%% the License for the specific language governing rights and limitations +%% under the License. +%% +%% %CopyrightEnd% +%% + +%% +%%---------------------------------------------------------------------- +%% Purpose: Test encoding/decoding (codec) module of Megaco/H.248 +%%---------------------------------------------------------------------- + +-module(megaco_codec_v2_test). + +%% ---- + +-include_lib("megaco/include/megaco.hrl"). +-include_lib("megaco/include/megaco_message_v2.hrl"). +-include("megaco_test_lib.hrl"). + +%% ---- + +-export([msgs/0]). +-export([rfc3525_msgs_display/0, rfc3525_msgs_test/0]). + +-export([t/0, t/1]). + +-export([all/1, + + text/1, + + pretty/1, + pretty_test_msgs/1, + + compact/1, + compact_test_msgs/1, + + flex_pretty/1, + flex_pretty_init/1, + flex_pretty_finish/1, + flex_pretty_test_msgs/1, + + flex_compact/1, + flex_compact_init/1, + flex_compact_finish/1, + flex_compact_test_msgs/1, + + flex_compact_dm_timers1/1, + flex_compact_dm_timers2/1, + flex_compact_dm_timers3/1, + flex_compact_dm_timers4/1, + flex_compact_dm_timers5/1, + flex_compact_dm_timers6/1, + flex_compact_dm_timers7/1, + flex_compact_dm_timers8/1, + + binary/1, + + bin/1, + bin_test_msgs/1, + + ber/1, + ber_test_msgs/1, + + ber_bin/1, + ber_bin_test_msgs/1, + + per/1, + per_test_msgs/1, + + per_bin/1, + per_bin_test_msgs/1, + + erl_dist/1, + erl_dist_m/1, + erl_dist_m_test_msgs/1, + + tickets/0, + tickets/1, + + compact_tickets/1, + compact_otp4011_msg1/1, + compact_otp4011_msg2/1, + compact_otp4011_msg3/1, + compact_otp4013_msg1/1, + compact_otp4085_msg1/1, + compact_otp4085_msg2/1, + compact_otp4280_msg1/1, + compact_otp4299_msg1/1, + compact_otp4299_msg2/1, + compact_otp4359_msg1/1, + compact_otp4920_msg0/1, + compact_otp4920_msg1/1, + compact_otp4920_msg2/1, + compact_otp4920_msg3/1, + compact_otp4920_msg4/1, + compact_otp4920_msg5/1, + compact_otp4920_msg6/1, + compact_otp4920_msg7/1, + compact_otp4920_msg8/1, + compact_otp4920_msg9/1, + compact_otp4920_msg10/1, + compact_otp4920_msg11/1, + compact_otp4920_msg12/1, + compact_otp4920_msg20/1, + compact_otp4920_msg21/1, + compact_otp4920_msg22/1, + compact_otp4920_msg23/1, + compact_otp4920_msg24/1, + compact_otp4920_msg25/1, + compact_otp5186_msg01/1, + compact_otp5186_msg02/1, + compact_otp5186_msg03/1, + compact_otp5186_msg04/1, + compact_otp5186_msg05/1, + compact_otp5186_msg06/1, + compact_otp5290_msg01/1, + compact_otp5290_msg02/1, + compact_otp5793_msg01/1, + compact_otp5993_msg01/1, + compact_otp5993_msg02/1, + compact_otp5993_msg03/1, + compact_otp6017_msg01/1, + compact_otp6017_msg02/1, + compact_otp6017_msg03/1, + compact_otp7138_msg01/1, + compact_otp7138_msg02/1, + compact_otp7457_msg01/1, + compact_otp7457_msg02/1, + compact_otp7457_msg03/1, + compact_otp7534_msg01/1, + compact_otp7576_msg01/1, + compact_otp7671_msg01/1, + + flex_compact_tickets/1, + flex_compact_otp7138_msg01/1, + flex_compact_otp7138_msg02/1, + flex_compact_otp7431_msg01/1, + flex_compact_otp7431_msg02/1, + flex_compact_otp7431_msg03/1, + flex_compact_otp7431_msg04/1, + flex_compact_otp7431_msg05/1, + flex_compact_otp7431_msg06/1, + flex_compact_otp7431_msg07/1, + flex_compact_otp7457_msg01/1, + flex_compact_otp7457_msg02/1, + flex_compact_otp7457_msg03/1, + flex_compact_otp7534_msg01/1, + flex_compact_otp7573_msg01/1, + flex_compact_otp7576_msg01/1, + + pretty_tickets/1, + pretty_otp4632_msg1/1, + pretty_otp4632_msg2/1, + pretty_otp4632_msg3/1, + pretty_otp4632_msg4/1, + pretty_otp4710_msg1/1, + pretty_otp4710_msg2/1, + pretty_otp4945_msg1/1, + pretty_otp4945_msg2/1, + pretty_otp4945_msg3/1, + pretty_otp4945_msg4/1, + pretty_otp4945_msg5/1, + pretty_otp4945_msg6/1, + pretty_otp4949_msg1/1, + pretty_otp4949_msg2/1, + pretty_otp4949_msg3/1, + pretty_otp5042_msg1/1, + pretty_otp5068_msg1/1, + pretty_otp5085_msg1/1, + pretty_otp5085_msg2/1, + pretty_otp5085_msg3/1, + pretty_otp5085_msg4/1, + pretty_otp5085_msg5/1, + pretty_otp5085_msg6/1, + pretty_otp5085_msg7/1, + pretty_otp5600_msg1/1, + pretty_otp5600_msg2/1, + pretty_otp5601_msg1/1, + pretty_otp5793_msg01/1, + pretty_otp5882_msg01/1, + pretty_otp6490_msg01/1, + pretty_otp6490_msg02/1, + pretty_otp6490_msg03/1, + pretty_otp6490_msg04/1, + pretty_otp6490_msg05/1, + pretty_otp6490_msg06/1, + pretty_otp7249_msg01/1, + pretty_otp7671_msg01/1, + pretty_otp7671_msg02/1, + pretty_otp7671_msg03/1, + pretty_otp7671_msg04/1, + pretty_otp7671_msg05/1, + + flex_pretty_tickets/1, + flex_pretty_otp5042_msg1/1, + flex_pretty_otp5085_msg1/1, + flex_pretty_otp5085_msg2/1, + flex_pretty_otp5085_msg3/1, + flex_pretty_otp5085_msg4/1, + flex_pretty_otp5085_msg5/1, + flex_pretty_otp5085_msg6/1, + flex_pretty_otp5085_msg7/1, + flex_pretty_otp5600_msg1/1, + flex_pretty_otp5600_msg2/1, + flex_pretty_otp5601_msg1/1, + flex_pretty_otp5793_msg01/1, + flex_pretty_otp7431_msg01/1, + flex_pretty_otp7431_msg02/1, + flex_pretty_otp7431_msg03/1, + flex_pretty_otp7431_msg04/1, + flex_pretty_otp7431_msg05/1, + flex_pretty_otp7431_msg06/1, + flex_pretty_otp7431_msg07/1, + + init_per_testcase/2, fin_per_testcase/2]). + +-export([display_text_messages/0, generate_text_messages/0]). + +-export([ + %% Decode + profile_decode_compact_text_message/1, + profile_decode_compact_text_messages/0, + profile_decode_compact_flex_text_messages/0, + profile_decode_pretty_text_message/1, + profile_decode_pretty_text_messages/0, + profile_decode_pretty_flex_text_messages/0, + + %% Encode + profile_encode_compact_text_messages/0, + profile_encode_pretty_text_messages/0 + ]). + + +%% ---- + +-define(V2, v2). +-define(EC, []). +-define(VERSION, 2). +-define(VERSION_STR, "2"). +-define(MSG_LIB, megaco_test_msg_v2_lib). +-define(DEFAULT_PORT, 55555). +-define(MG1_MID_NO_PORT, {ip4Address, + #'IP4Address'{address = [124, 124, 124, 222]}}). +-define(MG1_MID, {ip4Address, #'IP4Address'{address = [124, 124, 124, 222], + portNumber = ?DEFAULT_PORT}}). +-define(MG2_MID, {ip4Address, #'IP4Address'{address = [125, 125, 125, 111], + portNumber = ?DEFAULT_PORT}}). +-define(MGC_MID, {ip4Address, #'IP4Address'{address = [123, 123, 123, 4], + portNumber = ?DEFAULT_PORT}}). + +-define(A4444, ["11111111", "00000000", "00000000"]). +-define(A4445, ["11111111", "00000000", "11111111"]). +-define(A5555, ["11111111", "11111111", "00000000"]). +-define(A5556, ["11111111", "11111111", "11111111"]). + + +%% ---- + +display_text_messages() -> + Msgs = + msgs4() ++ + msgs5(), + megaco_codec_test_lib:display_text_messages(?VERSION, Msgs). + + +generate_text_messages() -> + Msgs = + msgs4() ++ + msgs5(), + megaco_codec_test_lib:generate_text_messages(?V2, ?VERSION, ?EC, Msgs). + + +%% ---- + +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg51a)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg51b)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg52)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg53)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg54a)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg58a)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg58b)). +%% (catch megaco_codec_v2_test:profile_decode_compact_text_message(msg61a)). +profile_decode_compact_text_message(MsgTag) -> + Codec = megaco_compact_text_encoder, + Config = [], + profile_decode_text_message(Codec, Config, MsgTag). + +%% (catch megaco_codec_v2_test:profile_decode_pretty_text_message(msg51a)). +%% (catch megaco_codec_v2_test:profile_decode_pretty_text_message(msg51b)). +%% (catch megaco_codec_v2_test:profile_decode_pretty_text_message(msg52)). +profile_decode_pretty_text_message(MsgTag) -> + Codec = megaco_pretty_text_encoder, + Config = [], + profile_decode_text_message(Codec, Config, MsgTag). + +profile_decode_text_message(Codec, Config, MsgTag) -> + Msgs = msgs4() ++ msgs5(), + case lists:keysearch(MsgTag, 1, Msgs) of + {value, Msg} -> + profile_decode_text_messages(Codec, Config, [Msg]); + false -> + {error, {no_such_message, MsgTag}} + end. + + +%% (catch megaco_codec_v2_test:profile_decode_compact_text_messages()). +profile_decode_compact_text_messages() -> + Config = [], + Slogan = decode_compact_v2, + profile_decode_compact_text_messages(Slogan, Config). + +%% (catch megaco_codec_v2_test:profile_decode_compact_flex_text_messages()). +profile_decode_compact_flex_text_messages() -> + Conf = flex_init([]), + Config = flex_scanner_conf(Conf), + Slogan = decode_compact_flex_v2, + Res = profile_decode_compact_text_messages(Slogan, [Config]), + flex_finish(Conf), + Res. + +profile_decode_compact_text_messages(Slogan, Config) -> + Codec = megaco_compact_text_encoder, + profile_decode_text_messages(Slogan, Codec, Config). + +%% (catch megaco_codec_v2_test:profile_decode_pretty_text_messages()). +profile_decode_pretty_text_messages() -> + Config = [], + Slogan = decode_pretty_v2, + profile_decode_pretty_text_messages(Slogan, Config). + +%% (catch megaco_codec_v2_test:profile_decode_pretty_flex_text_messages()). +profile_decode_pretty_flex_text_messages() -> + Conf = flex_init([]), + Config = flex_scanner_conf(Conf), + Slogan = decode_pretty_flex_v2, + Res = profile_decode_pretty_text_messages(Slogan, [Config]), + flex_finish(Conf), + Res. + +profile_decode_pretty_text_messages(Slogan, Config) -> + Codec = megaco_pretty_text_encoder, + profile_decode_text_messages(Slogan, Codec, Config). + +profile_decode_text_messages(Slogan, Codec, Config) -> + Msgs = msgs4() ++ msgs5(), + profile_decode_text_messages(Slogan, Codec, Config, Msgs). + +profile_decode_text_messages(Slogan, Codec, Config, Msgs0) -> + Msgs = [Msg || {_, Msg, _, _} <- Msgs0], + EncodeRes = encode_text_messages(Codec, Config, Msgs, []), + Bins = [Bin || {ok, Bin} <- EncodeRes], + Fun = fun() -> + decode_text_messages(Codec, Config, Bins, []) + end, + %% Make a dry run, just to make sure all modules are loaded: + io:format("make a dry run..~n", []), + (catch Fun()), + io:format("make the run..~n", []), + megaco_profile:profile(Slogan, Fun). + +%% (catch megaco_codec_v2_test:profile_encode_compact_text_messages()). +profile_encode_compact_text_messages() -> + Codec = megaco_compact_text_encoder, + Config = [], + Slogan = encode_compact_v2, + profile_encode_text_messages(Slogan, Codec, Config). + +%% (catch megaco_codec_v2_test:profile_encode_pretty_text_messages()). +profile_encode_pretty_text_messages() -> + Codec = megaco_pretty_text_encoder, + Config = [], + Slogan = encode_pretty_v2, + profile_encode_text_messages(Slogan, Codec, Config). + +profile_encode_text_messages(Slogan, Codec, Config) -> + Msgs = msgs4() ++ msgs5(), + profile_encode_text_messages(Slogan, Codec, Config, Msgs). + +profile_encode_text_messages(Slogan, Codec, Config, Msgs0) -> + Msgs = [Msg || {_, Msg, _, _} <- Msgs0], + Fun = fun() -> + encode_text_messages(Codec, Config, Msgs, []) + end, + %% Make a dry run, just to make sure all modules are loaded: + io:format("make a dry run...~n", []), + (catch Fun()), + io:format("make the run...~n", []), + megaco_profile:profile(Slogan, Fun). + +encode_text_messages(_Codec, _Config, [], Acc) -> + Acc; +encode_text_messages(Codec, Config, [Msg|Msgs], Acc) -> + Res = Codec:encode_message(Config, ?VERSION, Msg), + encode_text_messages(Codec, Config, Msgs, [Res | Acc]). + +decode_text_messages(_Codec, _Config, [], Acc) -> + Acc; +decode_text_messages(Codec, Config, [Msg|Msgs], Acc) -> + Res = Codec:decode_message(Config, dynamic, Msg), + decode_text_messages(Codec, Config, Msgs, [Res | Acc]). + + +%% ---- + + +expand(RootCase) -> + expand([RootCase], []). + +expand([], Acc) -> + lists:flatten(lists:reverse(Acc)); +expand([Case|Cases], Acc) -> + case (catch apply(?MODULE,Case,[suite])) of + [] -> + expand(Cases, [Case|Acc]); + C when is_list(C) -> + expand(Cases, [expand(C, [])|Acc]); + _ -> + expand(Cases, [Case|Acc]) + end. + + +%% ---- + +tickets() -> + Flag = process_flag(trap_exit, true), + Cases = expand(tickets), + Fun = fun(Case) -> + C = init_per_testcase(Case, [{tc_timeout, + timer:minutes(10)}]), + io:format("Eval ~w~n", [Case]), + Result = + case (catch apply(?MODULE, Case, [C])) of + {'EXIT', Reason} -> + io:format("~n~p exited:~n ~p~n", + [Case, Reason]), + {error, {Case, Reason}}; + Res -> + Res + end, + fin_per_testcase(Case, C), + Result + end, + process_flag(trap_exit, Flag), + lists:map(Fun, Cases). + + +%% ---- + +t() -> megaco_test_lib:t(?MODULE). +t(Case) -> megaco_test_lib:t({?MODULE, Case}). + +init_per_testcase(Case, Config) -> + %% CaseString = io_lib:format("~p", [Case]), + C = + case lists:suffix("time_test", atom_to_list(Case)) of + true -> + [{tc_timeout, timer:minutes(10)}|Config]; + false -> + put(verbosity,trc), + Config + end, + megaco_test_lib:init_per_testcase(Case, C). + +fin_per_testcase(Case, Config) -> + erase(verbosity), + megaco_test_lib:fin_per_testcase(Case, Config). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% +%% Top test case + +all(suite) -> + [ + text, + binary, + erl_dist, + tickets + ]. + +text(suite) -> + [ + pretty, + flex_pretty, + compact, + flex_compact + ]. + +binary(suite) -> + [ + bin, + ber, + ber_bin, + per, + per_bin + ]. + +erl_dist(suite) -> + [ + erl_dist_m + ]. + +pretty(suite) -> + [ + pretty_test_msgs + ]. + + +compact(suite) -> + [ + compact_test_msgs + ]. + + +flex_pretty(suite) -> + {req, [], + {conf, flex_pretty_init, flex_pretty_cases(), flex_pretty_finish}}. + +flex_pretty_cases() -> + [ + flex_pretty_test_msgs + ]. + +flex_compact(suite) -> + {req, [], + {conf, flex_compact_init, flex_compact_cases(), flex_compact_finish}}. + +flex_compact_cases() -> + [ + flex_compact_test_msgs, + flex_compact_dm_timers1, + flex_compact_dm_timers2, + flex_compact_dm_timers3, + flex_compact_dm_timers4, + flex_compact_dm_timers5, + flex_compact_dm_timers6, + flex_compact_dm_timers7, + flex_compact_dm_timers8 + ]. + + +bin(suite) -> + [ + bin_test_msgs + ]. + + +ber(suite) -> + [ + ber_test_msgs + ]. + + +ber_bin(suite) -> + [ + ber_bin_test_msgs + ]. + + +per(suite) -> + [ + per_test_msgs + ]. + + +%% Support for per_bin was added to ASN.1 as of version +%% 1.3.2 (R8). And later merged into 1.3.1.3 (R7). These +%% releases are identical (as far as I know). +%% +per_bin(suite) -> + [ + per_bin_test_msgs + ]. + + +erl_dist_m(suite) -> + [ + erl_dist_m_test_msgs + ]. + +tickets(suite) -> + [ + compact_tickets, + pretty_tickets, + flex_compact_tickets, + flex_pretty_tickets + ]. + + +compact_tickets(suite) -> + [ + compact_otp4011_msg1, + compact_otp4011_msg2, + compact_otp4011_msg3, + compact_otp4013_msg1, + compact_otp4085_msg1, + compact_otp4085_msg2, + compact_otp4280_msg1, + compact_otp4299_msg1, + compact_otp4299_msg2, + compact_otp4359_msg1, + compact_otp4920_msg0, + compact_otp4920_msg1, + compact_otp4920_msg2, + compact_otp4920_msg3, + compact_otp4920_msg4, + compact_otp4920_msg5, + compact_otp4920_msg6, + compact_otp4920_msg7, + compact_otp4920_msg8, + compact_otp4920_msg9, + compact_otp4920_msg10, + compact_otp4920_msg11, + compact_otp4920_msg12, + compact_otp4920_msg20, + compact_otp4920_msg21, + compact_otp4920_msg22, + compact_otp4920_msg23, + compact_otp4920_msg24, + compact_otp4920_msg25, + compact_otp5186_msg01, + compact_otp5186_msg02, + compact_otp5186_msg03, + compact_otp5186_msg04, + compact_otp5186_msg05, + compact_otp5186_msg06, + compact_otp5290_msg01, + compact_otp5290_msg02, + compact_otp5793_msg01, + compact_otp5993_msg01, + compact_otp5993_msg02, + compact_otp5993_msg03, + compact_otp6017_msg01, + compact_otp6017_msg02, + compact_otp6017_msg03, + compact_otp7138_msg01, + compact_otp7138_msg02, + compact_otp7457_msg01, + compact_otp7457_msg02, + compact_otp7457_msg03, + compact_otp7534_msg01, + compact_otp7576_msg01, + compact_otp7671_msg01 + ]. + +flex_compact_tickets(suite) -> + {req, [], + {conf, flex_compact_init, flex_compact_tickets_cases(), + flex_compact_finish}}. + +flex_compact_tickets_cases() -> + [ + flex_compact_otp7138_msg01, + flex_compact_otp7138_msg02, + flex_compact_otp7431_msg01, + flex_compact_otp7431_msg02, + flex_compact_otp7431_msg03, + flex_compact_otp7431_msg04, + flex_compact_otp7431_msg05, + flex_compact_otp7431_msg06, + flex_compact_otp7431_msg07, + flex_compact_otp7138_msg02, + flex_compact_otp7457_msg01, + flex_compact_otp7457_msg02, + flex_compact_otp7457_msg03, + flex_compact_otp7534_msg01, + flex_compact_otp7573_msg01, + flex_compact_otp7576_msg01 + ]. + +pretty_tickets(suite) -> + [ + pretty_otp4632_msg1, + pretty_otp4632_msg2, + pretty_otp4632_msg3, + pretty_otp4632_msg4, + pretty_otp4710_msg1, + pretty_otp4710_msg2, + pretty_otp4945_msg1, + pretty_otp4945_msg2, + pretty_otp4945_msg3, + pretty_otp4945_msg4, + pretty_otp4945_msg5, + pretty_otp4945_msg6, + pretty_otp4949_msg1, + pretty_otp4949_msg2, + pretty_otp4949_msg3, + pretty_otp5042_msg1, + pretty_otp5068_msg1, + pretty_otp5085_msg1, + pretty_otp5085_msg2, + pretty_otp5085_msg3, + pretty_otp5085_msg4, + pretty_otp5085_msg5, + pretty_otp5085_msg6, + pretty_otp5085_msg7, + pretty_otp5600_msg1, + pretty_otp5600_msg2, + pretty_otp5601_msg1, + pretty_otp5793_msg01, + pretty_otp5882_msg01, + pretty_otp6490_msg01, + pretty_otp6490_msg02, + pretty_otp6490_msg03, + pretty_otp6490_msg04, + pretty_otp6490_msg05, + pretty_otp6490_msg06, + pretty_otp7249_msg01, + pretty_otp7671_msg01, + pretty_otp7671_msg02, + pretty_otp7671_msg03, + pretty_otp7671_msg04, + pretty_otp7671_msg05 + ]. + +flex_pretty_tickets(suite) -> + {req, [], + {conf, flex_pretty_init, flex_pretty_tickets_cases(), + flex_pretty_finish}}. + +flex_pretty_tickets_cases() -> + [ + flex_pretty_otp5042_msg1, + flex_pretty_otp5085_msg1, + flex_pretty_otp5085_msg2, + flex_pretty_otp5085_msg3, + flex_pretty_otp5085_msg4, + flex_pretty_otp5085_msg5, + flex_pretty_otp5085_msg6, + flex_pretty_otp5085_msg7, + flex_pretty_otp5600_msg1, + flex_pretty_otp5600_msg2, + flex_pretty_otp5601_msg1, + flex_pretty_otp5793_msg01, + flex_pretty_otp7431_msg01, + flex_pretty_otp7431_msg02, + flex_pretty_otp7431_msg03, + flex_pretty_otp7431_msg04, + flex_pretty_otp7431_msg05, + flex_pretty_otp7431_msg06, + flex_pretty_otp7431_msg07 + ]. + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +pretty_test_msgs(suite) -> + []; +pretty_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs2() ++ msgs3() ++ msgs4() ++ msgs5(), + %% Msgs = msgs5(), + DynamicDecode = false, + test_msgs(megaco_pretty_text_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +flex_pretty_init(Config) -> + flex_init(Config). + +flex_pretty_finish(Config) -> + flex_finish(Config). + + +flex_pretty_test_msgs(suite) -> + []; +flex_pretty_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs2() ++ msgs3() ++ msgs4(), + Conf = flex_scanner_conf(Config), + DynamicDecode = false, + test_msgs(megaco_pretty_text_encoder, DynamicDecode, [Conf], Msgs). + + +flex_pretty_otp5042_msg1(suite) -> + []; +flex_pretty_otp5042_msg1(Config) when is_list(Config) -> + d("flex_pretty_otp5042_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp5042_msg1(), + Bin0 = list_to_binary(Msg0), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_pretty_text_encoder, false, [Conf], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {_, _Mod, {bad_timeStamp, TimeStamp}} -> + exit({bad_timeStamp, TimeStamp}); + _ -> + io:format("flex_pretty_otp5042_msg1 -> " + "~n Reason: ~w" + "~n", [Reason]), + exit({unexpected_decode_result, Reason}) + end; + {ok, M} -> + t("flex_pretty_otp5042_msg1 -> successfull decode:" + "~n~p", [M]), + ok + end. + + +flex_pretty_otp5085_msg1(suite) -> + []; +flex_pretty_otp5085_msg1(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(ok, pretty_otp5085_msg1(), [Conf]). + +flex_pretty_otp5085_msg2(suite) -> + []; +flex_pretty_otp5085_msg2(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(error, pretty_otp5085_msg2(), [Conf]). + +flex_pretty_otp5085_msg3(suite) -> + []; +flex_pretty_otp5085_msg3(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(ok, pretty_otp5085_msg3(), [Conf]). + +flex_pretty_otp5085_msg4(suite) -> + []; +flex_pretty_otp5085_msg4(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg4 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(ok, pretty_otp5085_msg4(), [Conf]). + +flex_pretty_otp5085_msg5(suite) -> + []; +flex_pretty_otp5085_msg5(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg5 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(ok, pretty_otp5085_msg5(), [Conf]). + +flex_pretty_otp5085_msg6(suite) -> + []; +flex_pretty_otp5085_msg6(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg6 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(ok, pretty_otp5085_msg6(), [Conf]). + +flex_pretty_otp5085_msg7(suite) -> + []; +flex_pretty_otp5085_msg7(Config) when is_list(Config) -> + d("flex_pretty_otp5085_msg7 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5085(ok, pretty_otp5085_msg7(), [Conf]). + +flex_pretty_otp5600_msg1(suite) -> + []; +flex_pretty_otp5600_msg1(Config) when is_list(Config) -> + d("flex_pretty_otp5600_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5600(ok, pretty_otp5600_msg1(), [Conf]). + +flex_pretty_otp5600_msg2(suite) -> + []; +flex_pretty_otp5600_msg2(Config) when is_list(Config) -> + d("flex_pretty_otp5600_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5600(ok, pretty_otp5600_msg2(), [Conf]). + +flex_pretty_otp5601_msg1(suite) -> + []; +flex_pretty_otp5601_msg1(Config) when is_list(Config) -> + d("flex_pretty_otp5601_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5601(ok, pretty_otp5601_msg1(), [Conf]). + +flex_pretty_otp5793_msg01(suite) -> + []; +flex_pretty_otp5793_msg01(Config) when is_list(Config) -> + d("flex_pretty_otp5793_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + pretty_otp5793(ok, pretty_otp5793_msg1(), [Conf]). + + +flex_pretty_otp7431_msg01(suite) -> + []; +flex_pretty_otp7431_msg01(Config) when is_list(Config) -> + d("flex_pretty_otp7431_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(ok, flex_pretty_otp7431_msg1(), [Conf]). + +flex_pretty_otp7431_msg02(suite) -> + []; +flex_pretty_otp7431_msg02(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_pretty_otp7431_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(error, flex_pretty_otp7431_msg2(), [Conf]). + +flex_pretty_otp7431_msg03(suite) -> + []; +flex_pretty_otp7431_msg03(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_pretty_otp7431_msg03 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(error, flex_pretty_otp7431_msg3(), [Conf]). + +flex_pretty_otp7431_msg04(suite) -> + []; +flex_pretty_otp7431_msg04(Config) when is_list(Config) -> + d("flex_pretty_otp7431_msg04 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(error, flex_pretty_otp7431_msg4(), [Conf]). + +flex_pretty_otp7431_msg05(suite) -> + []; +flex_pretty_otp7431_msg05(Config) when is_list(Config) -> + d("flex_pretty_otp7431_msg05 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(error, flex_pretty_otp7431_msg5(), [Conf]). + +flex_pretty_otp7431_msg06(suite) -> + []; +flex_pretty_otp7431_msg06(Config) when is_list(Config) -> + d("flex_pretty_otp7431_msg06 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(error, flex_pretty_otp7431_msg6(), [Conf]). + +flex_pretty_otp7431_msg07(suite) -> + []; +flex_pretty_otp7431_msg07(Config) when is_list(Config) -> + d("flex_pretty_otp7431_msg07 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Conf = flex_scanner_conf(Config), + flex_pretty_otp7431(error, flex_pretty_otp7431_msg7(), [Conf]). + +flex_pretty_otp7431(Expected, Msg, Conf) -> + otp7431(Expected, megaco_pretty_text_encoder, Msg, Conf). + +otp7431(Expected, Codec, Msg0, Conf) -> + Bin0 = list_to_binary(Msg0), + case decode_message(Codec, false, Conf, Bin0) of + {ok, _Msg1} when Expected =:= ok -> + io:format(" decoded", []); + {error, {bad_property_parm, Reason}} when (Expected =:= error) andalso + is_list(Reason) -> + io:format("expected result: ~s", [Reason]), + ok; + Else -> + io:format("unexpected result", []), + exit({unexpected_decode_result, Else}) + end. + + +flex_pretty_otp7431_msg1() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v=0 + o=- 2890844526 2890842807 IN IP4 124.124.124.222 + s=- + t= 0 0 + c=IN IP4 124.124.124.222 + m=audio 2222 RTP/AVP 4 + a=ptime:30 + a=recvonly + } ; RTP profile for G.723.1 is 4 + } + } + } + } + }". + +flex_pretty_otp7431_msg2() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v=0 + o=- 2890844526 2890842807 IN IP4 124.124.124.222 + s=- + t= 0 0 + c=IN IP4 124.124.124.222 + m=audio 2222 RTP/AVP 4 + a=ptime:30 + a= } + } + } + } + } + }". + +flex_pretty_otp7431_msg3() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v=0 + o=- 2890844526 2890842807 IN IP4 124.124.124.222 + s=- + t= 0 0 + c=IN IP4 124.124.124.222 + m=audio 2222 RTP/AVP 4 + a=ptime:30 + a } + } + } + } + } + }". + +flex_pretty_otp7431_msg4() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v=0 + o=- 2890844526 2890842807 IN IP4 124.124.124.222 + s=- + t= 0 0 + c=IN IP4 124.124.124.222 + m=audio 2222 RTP/AVP 4 + a=ptime:30 + a} + } + } + } + } + }". + +flex_pretty_otp7431_msg5() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v= } + } + } + } + } + }". + +flex_pretty_otp7431_msg6() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v } + } + } + } + } + }". + +flex_pretty_otp7431_msg7() -> + "MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { + v} + } + } + } + } + }". + + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +compact_test_msgs(suite) -> + []; +compact_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs2() ++ msgs3() ++ msgs4(), + DynamicDecode = false, + test_msgs(megaco_compact_text_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +flex_compact_init(Config) -> + flex_init(Config). + +flex_compact_finish(Config) -> + flex_finish(Config). + + +flex_compact_test_msgs(suite) -> + []; +flex_compact_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs2() ++ msgs3() ++ msgs4(), + Conf = flex_scanner_conf(Config), + DynamicDecode = true, + test_msgs(megaco_compact_text_encoder, DynamicDecode, [Conf], Msgs). + + +flex_compact_dm_timers1(suite) -> + []; +flex_compact_dm_timers1(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("1", "2", "3"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers1 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({1,2,3}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers2(suite) -> + []; +flex_compact_dm_timers2(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("02", "03", "04"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers2 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({2,3,4}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers3(suite) -> + []; +flex_compact_dm_timers3(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("1", "02", "31"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers3 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({1,2,31}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers4(suite) -> + []; +flex_compact_dm_timers4(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("10", "21", "99"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers4 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({10,21,99}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers5(suite) -> + []; +flex_compact_dm_timers5(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("99", "23", "11"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers5 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({99,23,11}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers6(suite) -> + []; +flex_compact_dm_timers6(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("77", "09", "1"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers6 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({77,9,1}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers7(suite) -> + []; +flex_compact_dm_timers7(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("77", "09", "1", "99"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers7 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({77,9,1,99}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +flex_compact_dm_timers8(suite) -> + []; +flex_compact_dm_timers8(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + M = build_dm_timers_message("01", "09", "01", "02"), + B = list_to_binary(M), + Conf = flex_scanner_conf(Config), + case decode_message(megaco_compact_text_encoder, false, [Conf], B) of + {ok, M1} when is_record(M1,'MegacoMessage') -> + t("flex_compact_dm_timers8 -> " + "~n M: ~s" + "~n M1: ~p", [M, M1]), + verify_dm_timers({1,9,1,2}, M1); + Else -> + exit({decode_failed, M, Else}) + end. + + +build_dm_timers_message(T, S, L) -> + TMRs = lists:flatten(io_lib:format("T:~s,S:~s,L:~s", [T, S, L])), + build_dm_timers_message(TMRs). + +build_dm_timers_message(T, S, L, Z) -> + TMRs = lists:flatten(io_lib:format("T:~s,S:~s,L:~s,Z:~s", [T, S, L,Z])), + build_dm_timers_message(TMRs). + +build_dm_timers_message(TMRs) -> + M = io_lib:format("!/" ?VERSION_STR " [123.123.123.4]:55555\nT=10001{C=-{MF=11111111/00000000/00000000{E=2223{al/on,dd/ce{DM=dialplan00}},SG{cg/rt},DM=dialplan00{~s,(0s| 00s|[1-7]xlxx|8lxxxxxxx|#xxxxxxx|*xx|9l1xxxxxxxxxx|9l011x.s)}}}}", [TMRs]), + lists:flatten(M). + + +verify_dm_timers(TMRs, #'MegacoMessage'{mess = Mess}) -> + #'Message'{messageBody = Body} = Mess, + case get_dm_timers(Body) of + {error, Reason} -> + exit({invalid_timer, {TMRs, Reason}}); + TMRs -> + ok; + TMRs1 -> + exit({invalid_timer_values, {TMRs, TMRs1}}) + end. + +get_dm_timers({transactions, T}) when is_list(T) -> + get_dm_timers1(T); +get_dm_timers(Other) -> + {error, {invalid_transactions, Other}}. + +get_dm_timers1([{transactionRequest,T}|Ts]) + when is_record(T,'TransactionRequest') -> + case get_dm_timers2(T) of + {ok, Timers} -> + Timers; + _ -> + get_dm_timers1(Ts) + end; +get_dm_timers1([_|Ts]) -> + get_dm_timers1(Ts); +get_dm_timers1([]) -> + {error, {no_timers, 'TransactionRequest'}}. + + +get_dm_timers2(#'TransactionRequest'{actions = Actions}) when is_list(Actions) -> + get_dm_timers3(Actions). + + +get_dm_timers3([#'ActionRequest'{commandRequests = Cmds}|Ars]) when is_list(Cmds) -> + case get_dm_timers4(Cmds) of + {ok, Timers} -> + {ok, Timers}; + _ -> + get_dm_timers3(Ars) + end; +get_dm_timers3([_|Ars]) -> + get_dm_timers3(Ars); +get_dm_timers3([]) -> + {error, {no_timers, 'ActionRequest'}}. + +get_dm_timers4([#'CommandRequest'{command = Cmd}|Cmds]) -> + case get_dm_timers5(Cmd) of + {ok, Timers} -> + {ok, Timers}; + _ -> + get_dm_timers4(Cmds) + end; +get_dm_timers4([_|Cmds]) -> + get_dm_timers4(Cmds); +get_dm_timers4([]) -> + {error, {no_timers, 'CommandRequest'}}. + + +get_dm_timers5({modReq, #'AmmRequest'{descriptors = Descriptors}}) -> + get_dm_timers6(Descriptors); +get_dm_timers5(R) -> + {error, {no_modReq, R}}. + + +get_dm_timers6([{digitMapDescriptor, #'DigitMapDescriptor'{digitMapValue = Val}}|_]) -> + case Val of + #'DigitMapValue'{startTimer = T, + shortTimer = S, + longTimer = L, + durationTimer = asn1_NOVALUE} -> + {ok, {T, S, L}}; + #'DigitMapValue'{startTimer = T, + shortTimer = S, + longTimer = L, + durationTimer = Z} -> + {ok, {T, S, L, Z}}; + _ -> + {error, no_value_in_dm} + end; +get_dm_timers6([_|Descs]) -> + get_dm_timers6(Descs); +get_dm_timers6([]) -> + {error, {no_timers, descriptors}}. + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +bin_test_msgs(suite) -> + []; +bin_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs4(), + DynamicDecode = false, + test_msgs(megaco_binary_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +ber_test_msgs(suite) -> + []; +ber_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs4(), + DynamicDecode = false, + test_msgs(megaco_ber_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +ber_bin_test_msgs(suite) -> + []; +ber_bin_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs4(), + DynamicDecode = true, + test_msgs(megaco_ber_bin_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +per_test_msgs(suite) -> + []; +per_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs4(), + DynamicDecode = false, + test_msgs(megaco_per_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +per_bin_test_msgs(suite) -> + []; +per_bin_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs4(), + DynamicDecode = false, + test_msgs(megaco_per_bin_encoder, DynamicDecode, [], Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +erl_dist_m_test_msgs(suite) -> + []; +erl_dist_m_test_msgs(Config) when is_list(Config) -> + ?ACQUIRE_NODES(1, Config), + Msgs = msgs1() ++ msgs2() ++ msgs3() ++ msgs4(), + DynamicDecode = false, + Conf = [megaco_compressed], + test_msgs(megaco_erl_dist_encoder, DynamicDecode, Conf, Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +%% # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # +%% Ticket test cases: + + +%% -------------------------------------------------------------- +%% Observe that this decode SHALL fail +compact_otp4011_msg1(suite) -> + []; +compact_otp4011_msg1(Config) when is_list(Config) -> +% put(severity,trc), +% put(dbg,true), + d("compact_otp4011_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + M = "!/" ?VERSION_STR " ML T=233350{C=${A=stedevice/01{M{O{MO=SR,RV=OFF,RG=OFF,tdmc/ec=OFF,MO=SR}}}}}", + ok = compact_otp4011(M), +% erase(severity), +% erase(dbg), + ok. + + +%% -------------------------------------------------------------- +%% Observe that this decode SHALL fail +compact_otp4011_msg2(suite) -> + []; +compact_otp4011_msg2(Config) when is_list(Config) -> + d("compact_otp4011_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + M = "!/" ?VERSION_STR " ML T=233350{C=${A=stedevice/01{M{O{MO=SO,RV=OFF,RG=OFF,tdmc/ec=OFF,MO=SR}}}}}", +% put(severity,trc), +% put(dbg,true), + ok = compact_otp4011(M). + + +%% -------------------------------------------------------------- +%% Observe that this decode SHALL fail +compact_otp4011_msg3(suite) -> + []; +compact_otp4011_msg3(Config) when is_list(Config) -> + d("compact_otp4011_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + M = "!/" ?VERSION_STR " ML T=233350{C=${A=stedevice/01{M{O{MO=SR,RV=OFF,RG=OFF,tdmc/ec=OFF,MO=SO}}}}}", +% put(severity,trc), +% put(dbg,true), + ok = compact_otp4011(M). + + +compact_otp4011(M) -> + d("compact_otp4011 -> entry with" + "~n M: '~s'", [M]), + Bin = list_to_binary(M), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, _} -> + exit({decoded_erroneous_message,M}); + {error, Error} when is_list(Error) -> % Expected result + d("compact_otp4011 -> expected error result (so far)", []), + case lists:keysearch(reason,1,Error) of + {value, {reason,Reason}} -> + d("compact_otp4011 -> expected error: " + "~n Reason: ~p", [Reason]), + case Reason of + {0, megaco_text_parser_v2, + {do_merge_control_streamParms, [A,B]}} + when is_list(A) andalso is_record(B, 'LocalControlDescriptor') -> + case lists:keysearch(mode,1,A) of + {value, {mode, Mode}} + when B#'LocalControlDescriptor'.streamMode /= asn1_NOVALUE -> + d("compact_otp4011 -> " + "expected error [~w]",[Mode]), + ok; + Other -> + exit({unexpected_mode_reason, {A,B,Other}}) + end; + Other -> + exit({unexpected_reason, Other}) + end; + + false -> + d("compact_otp4011 -> OUPS, wrong kind of error", []), + exit({unexpected_result, Error}) + end; + Else -> + d("compact_otp4011 -> unexpected decode result: ~p", [Else]), + exit({unexpected_decode_result, Else}) + end. + + +%% -------------------------------------------------------------- +%% Note that this decode SHALL fail, because of the misspelled +%% MEGCAO instead of the correct MEGACO. +compact_otp4013_msg1(suite) -> + []; +compact_otp4013_msg1(Config) when is_list(Config) -> + d("compact_otp4013_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + M = "MEGCAO/2 MG1 T=12345678{C=-{SC=root{SV{MT=RS,RE=901}}}}", + Bin = list_to_binary(M), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, _} -> + exit({decoded_erroneous_message,M}); + {error, Reason} when is_list(Reason) -> + {value, {reason, no_version_found, _}} = + lists:keysearch(reason, 1, Reason), + {value, {token, [{'SafeChars',_,"megcao/2"}|_]}} = + lists:keysearch(token, 1, Reason), + ok; + Else -> + exit({unexpected_decode_result,Else}) + end. + + + +%% -------------------------------------------------------------- +%% +%% +compact_otp4085_msg1(suite) -> + []; +compact_otp4085_msg1(Config) when is_list(Config) -> + d("compact_otp4085_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + M = compact_otp4085_erroneous_msg(), + Bin = list_to_binary(M), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, M} -> + exit({decoded_erroneous_message,M}); + {error, Error} when is_list(Error) -> % Expected result + t("compact_otp4085_msg1 -> decode failed", []), + case lists:keysearch(reason, 1, Error) of + {value, {reason,{999999, Module, Crap}}} -> + t("compact_otp4085_msg1 -> THE ACTUAL ERROR: " + "~n LINE NUMBER: 999999" + "~n Module: ~p" + "~n Crap: ~p", [Module, Crap]), + %% ok; + exit({decode_failed_999999, Module, Crap}); + {value, {reason,{Line, Module, Crap}}} -> + t("compact_otp4085_msg1 -> Expected: " + "~n Line: ~p" + "~n Module: ~p" + "~n Crap: ~p", [Line, Module, Crap]), + ok; + false -> + exit({unexpected_result, Error}) + end; + Else -> + exit({unexpected_decode_result, Else}) + end. + + +%% -------------------------------------------------------------- +%% This test case is just to show that the message used in +%% compact_otp4085_msg1 is actually ok when you add '}' at the end. +compact_otp4085_msg2(suite) -> + []; +compact_otp4085_msg2(Config) when is_list(Config) -> + d("compact_otp4085_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + M1 = compact_otp4085_erroneous_msg() ++ "}", + Bin = list_to_binary(M1), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, M2} -> + l("compact_otp4085_msg1 -> successfull decode" + "~n M2: ~p", [M2]), + ok; + Else -> + e("compact_otp4085_msg1 -> decode error" + "~n Else: ~p", [Else]), + exit({unexpected_decode_result,Else}) + end. + + +%% This message lack the ending parentesis (}). +compact_otp4085_erroneous_msg() -> + M = "!/" + ?VERSION_STR + " ML T=11223342{C=${A=${M{O{MO=SR,RV=OFF,RG=OFF},L{v=0," + "c=ATM NSAP $ ," + "a=eecid:$ ," + "m=audio - AAL1/ATMF -," + "}}},A=stee1181/01{M{O{MO=SR,RV=OFF,RG=OFF,tdmc/ec=off}}}}", + M. + +%% -------------------------------------------------------------- +%% +%% +compact_otp4280_msg1(suite) -> + []; +compact_otp4280_msg1(Config) when is_list(Config) -> + d("compact_otp4280_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Bin = list_to_binary(compact_otp4280_msg()), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, _Msg} -> + ok; + {error, Error} when is_list(Error) -> + t("compact_otp4280_msg1 -> decode failed", []), + case lists:keysearch(reason, 1, Error) of + {value, {reason,{Line, Module, Reason} = R}} -> + t("compact_otp4280_msg1 -> " + "~n Line: ~w" + "~n Module: ~w" + "~n Reason: ~w", [Line, Module, Reason]), + exit({decode_failed, R}); + false -> + exit({unexpected_result, Error}) + end; + Else -> + exit({unexpected_decode_result, Else}) + end. + +compact_otp4280_msg() -> + M = "!/" + ?VERSION_STR + " mgw1 P=71853646{C=-{AV=root{M{TS{root/maxnumberofcontexts=49500," + "root/maxterminationspercontext=2,root/normalmgexecutiontime=200," + "root/normalmgcexecutiontime=150," + "root/provisionalresponsetimervalue=2000,BF=OFF,SI=IV}}}}}", + M. + + +%% -------------------------------------------------------------- +%% This ticket is about comments in a message +compact_otp4299_msg1(suite) -> + []; +compact_otp4299_msg1(Config) when is_list(Config) -> + d("compact_otp4299_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Bin = list_to_binary(compact_otp4299_msg()), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, _Msg} -> + ok; + + {error, Reason} -> + exit({decode_error, Reason}); + + Else -> + exit({unexpected_decode_result, Else}) + end. + + +%% Same message, but this time decoded using the flex scanner +compact_otp4299_msg2(suite) -> + []; +compact_otp4299_msg2(Config) when is_list(Config) -> + d("compact_otp4299_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + + {Pid, Conf} = compact_otp4299_msg2_init(), + + Bin = list_to_binary(compact_otp4299_msg()), + Res = decode_message(megaco_compact_text_encoder, false, [Conf], Bin), + compact_otp4299_msg2_finish(Pid), + + case Res of + {ok, _Msg} -> + ok; + + {error, Reason} -> + exit({decode_error, Reason}); + + Else -> + exit({unexpected_decode_result, Else}) + end. + + +compact_otp4299_msg2_init() -> + Flag = process_flag(trap_exit, true), + Res = (catch start_flex_scanner()), + process_flag(trap_exit, Flag), + case Res of + {error, Reason} -> + skip(Reason); + {ok, FlexConfig} -> + FlexConfig + end. + +compact_otp4299_msg2_finish(Pid) -> + stop_flex_scanner(Pid). + + +compact_otp4299_msg() -> + M = ";KALLE\n" + "!/" + ?VERSION_STR + " mg58_1 P=005197711{; YET ANOTHER COMMENT\n" + "C=035146207{A=mg58_1_1_4_1_23/19; BEFORE COMMA\n" + ",; AFTER COMMA\n" + "A=eph58_1/0xA4023371{M{L{\n" + "v=0\n" + "c=ATM NSAP 39.0102.0304.0506.0708.090a.0b58.0100.0000.0000.00\n" + "m=audio - AAL1/ATMF -\n" + "a=eecid:A4023371\n" + "}}; HOBBE\n}; KALLE \"HOBBE \n}}" + ";KALLE\n\n", + M. + + +%% -------------------------------------------------------------- +%% +%% +compact_otp4359_msg1(suite) -> + []; +compact_otp4359_msg1(Config) when is_list(Config) -> + d("compact_otp4359_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Bin = list_to_binary(compact_otp4359_msg()), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, #'MegacoMessage'{mess = Mess}} -> + {transactions, Trans} = Mess#'Message'.messageBody, + case Trans of + [{transactionRequest,#'TransactionRequest'{transactionId = asn1_NOVALUE}}] -> + ok; + _ -> + exit({unexpected_transactions, Trans}) + end; + Else -> + t("compact_otp4359_msg1 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +compact_otp4359_msg() -> + M = "!/" ?VERSION_STR " ml2 T={C=${A=${M{O {MO=SR,RG=OFF,RV=OFF}}}}}", + M. + + +%% -------------------------------------------------------------- +%% +%% +compact_otp4920_msg0(suite) -> + []; +compact_otp4920_msg0(Config) when is_list(Config) -> + d("compact_otp4920_msg0 -> entry", []), + ?ACQUIRE_NODES(1, Config), + % put(dbg,true), + compact_otp4920_msg_1(compact_otp4920_msg0(), true). + +compact_otp4920_msg1(suite) -> + []; +compact_otp4920_msg1(Config) when is_list(Config) -> + d("compact_otp4920_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + % put(dbg,true), + compact_otp4920_msg_1(compact_otp4920_msg1(), false). + +compact_otp4920_msg2(suite) -> + []; +compact_otp4920_msg2(Config) when is_list(Config) -> + d("compact_otp4920_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg2(), false). + +compact_otp4920_msg3(suite) -> + []; +compact_otp4920_msg3(Config) when is_list(Config) -> + d("compact_otp4920_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg3(), true). + +compact_otp4920_msg4(suite) -> + []; +compact_otp4920_msg4(Config) when is_list(Config) -> + d("compact_otp4920_msg4 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg4(), true). + +compact_otp4920_msg5(suite) -> + []; +compact_otp4920_msg5(Config) when is_list(Config) -> + d("compact_otp4920_msg5 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg5(), true). + +compact_otp4920_msg6(suite) -> + []; +compact_otp4920_msg6(Config) when is_list(Config) -> + d("compact_otp4920_msg6 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg6(), true). + +compact_otp4920_msg7(suite) -> + []; +compact_otp4920_msg7(Config) when is_list(Config) -> + d("compact_otp4920_msg7 -> entry", []), + ?ACQUIRE_NODES(1, Config), + % put(dbg,true), + compact_otp4920_msg_1(compact_otp4920_msg7(), true). + +compact_otp4920_msg8(suite) -> + []; +compact_otp4920_msg8(Config) when is_list(Config) -> + d("compact_otp4920_msg8 -> entry", []), + ?ACQUIRE_NODES(1, Config), + % put(dbg,true), + compact_otp4920_msg_1(compact_otp4920_msg8(), false). + +compact_otp4920_msg9(suite) -> + []; +compact_otp4920_msg9(Config) when is_list(Config) -> + d("compact_otp4920_msg9 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg9(), false). + +compact_otp4920_msg10(suite) -> + []; +compact_otp4920_msg10(Config) when is_list(Config) -> + d("compact_otp4920_msg10 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg10(), false). + +compact_otp4920_msg11(suite) -> + []; +compact_otp4920_msg11(Config) when is_list(Config) -> + d("compact_otp4920_msg11 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg11(), false). + +compact_otp4920_msg12(suite) -> + []; +compact_otp4920_msg12(Config) when is_list(Config) -> + d("compact_otp4920_msg12 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_1(compact_otp4920_msg12(), true). + +%% Duplicate padding +compact_otp4920_msg20(suite) -> + []; +compact_otp4920_msg20(Config) when is_list(Config) -> + d("compact_otp4920_msg20 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_2(compact_otp4920_msg20(), bad_mid_duplicate_padding). + +%% Length +compact_otp4920_msg21(suite) -> + []; +compact_otp4920_msg21(Config) when is_list(Config) -> + d("compact_otp4920_msg21 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_2(compact_otp4920_msg21(), bad_mid_ip6addr_length). + +%% Length +compact_otp4920_msg22(suite) -> + []; +compact_otp4920_msg22(Config) when is_list(Config) -> + d("compact_otp4920_msg22 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_2(compact_otp4920_msg22(), bad_mid_ip6addr_length). + +%% Length +compact_otp4920_msg23(suite) -> + []; +compact_otp4920_msg23(Config) when is_list(Config) -> + d("compact_otp4920_msg23 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_2(compact_otp4920_msg23(), bad_mid_ip6addr_length). + +%% Length +compact_otp4920_msg24(suite) -> + []; +compact_otp4920_msg24(Config) when is_list(Config) -> + d("compact_otp4920_msg24 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_2(compact_otp4920_msg24(), bad_mid_ip6addr_length). + +%% Length +compact_otp4920_msg25(suite) -> + []; +compact_otp4920_msg25(Config) when is_list(Config) -> + d("compact_otp4920_msg25 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp4920_msg_2(compact_otp4920_msg25(), bad_mid_ip6addr_length). + +compact_otp4920_msg_1(M1, CheckEqual) -> + Bin1 = list_to_binary(M1), + case decode_message(megaco_compact_text_encoder, false, [], Bin1) of + {ok, Msg} -> + io:format(" decoded", []), + case encode_message(megaco_compact_text_encoder, [], Msg) of + {ok, Bin1} -> + io:format(", encoded - equal:", []), + ok; + {ok, Bin2} when is_binary(Bin2) andalso (CheckEqual =:= true) -> + M2 = binary_to_list(Bin2), + io:format(", encoded - not equal:", []), + exit({messages_not_equal, M1, M2}); + {ok, _} -> + io:format(", encoded:", []), + ok; + Else -> + io:format(", encode failed:", []), + exit({unexpected_encode_result, Else}) + end; + Else -> + io:format("decode failed:", []), + exit({unexpected_decode_result, Else}) + end. + +compact_otp4920_msg_2(M1, ExpectedReason) -> + Bin = list_to_binary(M1), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, Msg} -> + io:format("unexpected successfull decode", []), + exit({unexpected_encode_ok, Msg}); + {error, [{reason, {__Line, _Mod, Reason}}|_]} -> + case element(1, Reason) of + ExpectedReason -> + ok; + _ -> + exit({unexpected_decode_error_reason, + ExpectedReason, Reason}) + end; + {error, [{reason, {_Mod, Reason}}|_]} -> + case element(1, Reason) of + ExpectedReason -> + ok; + _ -> + exit({unexpected_decode_error_reason, + ExpectedReason, Reason}) + end; + Else -> + io:format("unexpected decode result", []), + exit({unexpected_decode_result, Else}) + + end. + +compact_otp4920_msg0() -> + M = "!/" ?VERSION_STR " [192.168.30.1]\nT=100{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg1() -> + M = "!/" ?VERSION_STR " [2031:0000:130F:0000:0000:09C0:876A:130B]\nT=101{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg2() -> + M = "!/" ?VERSION_STR " [2031:0:130F:0:0:9C0:876A:130B]\nT=102{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg3() -> + M = "!/" ?VERSION_STR " [2031:0:130F::9C0:876A:130B]\nT=103{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg4() -> + M = "!/" ?VERSION_STR " [::1]\nT=104{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg5() -> + M = "!/" ?VERSION_STR " [::]\nT=105{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg6() -> + M = "!/" ?VERSION_STR " [1::]\nT=106{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg7() -> + M = "!/" ?VERSION_STR " [FEDC:1::]\nT=107{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg8() -> + M = "!/" ?VERSION_STR " [2031:0:130F:0:0:9C0:135.106.19.11]\nT=108{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg9() -> + M = "!/" ?VERSION_STR " [2031:0:130F::9C0:135.106.19.11]\nT=109{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg10() -> + M = "!/" ?VERSION_STR " [::FFFF:192.168.30.1]\nT=110{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg11() -> + M = "!/" ?VERSION_STR " [::192.168.30.1]\nT=111{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +compact_otp4920_msg12() -> + M = "!/" ?VERSION_STR " [::C0A8:1E01]\nT=112{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +%% Illegal: only one :: allowed +compact_otp4920_msg20() -> + M = "!/" ?VERSION_STR " [2031::130F::9C0]\nT=120{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +%% Illegal: length +compact_otp4920_msg21() -> + M = "!/" ?VERSION_STR " [2031:FFEE:0000:130F:0000:0000:09C0:876A:130B]\nT=121{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +%% Illegal: length +compact_otp4920_msg22() -> + M = "!/" ?VERSION_STR " [2031:FFEE:0:130F:0:0:9C0:135.106.19.11]\nT=122{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +%% Illegal: length +compact_otp4920_msg23() -> + M = "!/" ?VERSION_STR " [2031:FFEE:0000:130F:2132:4354::09C0:876A:130B]\nT=123{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +%% Illegal: length +compact_otp4920_msg24() -> + M = "!/" ?VERSION_STR " [::2031:FFEE:0000:130F:2132:4354:09C0:876A:130B]\nT=124{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + +%% Illegal: length +compact_otp4920_msg25() -> + M = "!/" ?VERSION_STR " [2031:FFEE:0000:130F:2132:4354:09C0:876A:130B::]\nT=125{C=${A=${M{O{MO=SR,RG=OFF,RV=OFF}}}}}", + M. + + +compact_otp5186_msg01(suite) -> + []; +compact_otp5186_msg01(Config) when is_list(Config) -> + d("compact_otp5186_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5186_msg_1(compact_otp5186_msg01(), error, ignore). + +compact_otp5186_msg02(suite) -> + []; +compact_otp5186_msg02(Config) when is_list(Config) -> + d("compact_otp5186_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5186_msg_1(compact_otp5186_msg02(), ok, ok). + +compact_otp5186_msg03(suite) -> + []; +compact_otp5186_msg03(Config) when is_list(Config) -> + d("compact_otp5186_msg03 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5186_msg_2(compact_otp5186_msg03(), ok, ok). + +compact_otp5186_msg04(suite) -> + []; +compact_otp5186_msg04(Config) when is_list(Config) -> + d("compact_otp5186_msg04 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5186_msg_2(compact_otp5186_msg04(), ok, ok). + +compact_otp5186_msg05(suite) -> + []; +compact_otp5186_msg05(Config) when is_list(Config) -> + d("compact_otp5186_msg05 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5186_msg_2(compact_otp5186_msg05(), ok, ok). + +compact_otp5186_msg06(suite) -> + []; +compact_otp5186_msg06(Config) when is_list(Config) -> + d("compact_otp5186_msg06 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5186_msg_2(compact_otp5186_msg06(), ok, ok). + +compact_otp5186_msg_1(M1, DecodeExpect, EncodeExpect) -> + Bin1 = list_to_binary(M1), + case decode_message(megaco_compact_text_encoder, false, [], Bin1) of + {ok, Msg} when DecodeExpect == ok -> + io:format(" decoded", []), + case encode_message(megaco_compact_text_encoder, [], Msg) of + {ok, Bin1} when EncodeExpect == ok -> + io:format(", encoded - equal:", []), + ok; + {ok, Bin2} when EncodeExpect == ok -> + M2 = binary_to_list(Bin2), + io:format(", encoded - not equal:", []), + exit({messages_not_equal, Msg, M1, M2}); + {ok, Bin3} when EncodeExpect == error -> + M3 = binary_to_list(Bin3), + io:format(", unexpected encode:", []), + exit({unexpected_encode_success, Msg, M1, M3}); + _Else when EncodeExpect == error -> + io:format(", encode failed ", []), + ok + end; + {ok, Msg} when DecodeExpect == error -> + io:format(" decoded", []), + exit({unexpected_decode_success, Msg}); + _Else when DecodeExpect == error -> + io:format(" decode failed ", []), + ok; + Else when DecodeExpect == ok -> + io:format(" decode failed ", []), + exit({unexpected_decode_result, Else}) + end. + +compact_otp5186_msg_2(Msg1, EncodeExpect, DecodeExpect) -> + case encode_message(megaco_compact_text_encoder, [], Msg1) of + {ok, Bin} when EncodeExpect == ok -> + io:format(" encoded", []), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, Msg1} when DecodeExpect == ok -> + io:format(", decoded - equal:", []), + ok; + {ok, Msg2} when DecodeExpect == ok -> + M = binary_to_list(Bin), + case (catch compact_otp5186_check_megamsg(Msg1, Msg2)) of + ok -> + io:format(", decoded - not equal - ok:", []), + ok; + {'EXIT', Reason} -> + io:format(", decoded - not equal:", []), + exit({messages_not_equal, M, Reason, Msg1, Msg2}) + end; + {ok, Msg3} when DecodeExpect == error -> + M = binary_to_list(Bin), + io:format(", decoded:", []), + exit({unexpected_decode_success, M, Msg1, Msg3}); + Else when DecodeExpect == ok -> + M = binary_to_list(Bin), + io:format(", decode failed ", []), + exit({unexpected_decode_success, Msg1, M, Else}); + _Else when DecodeExpect == error -> + io:format(", decode failed ", []), + ok + end; + {ok, Bin} when EncodeExpect == error -> + M = binary_to_list(Bin), + io:format(" encoded", []), + exit({unexpected_encode_success, Msg1, M}); + _Else when EncodeExpect == error -> + io:format(" encode failed ", []), + ok; + Else when EncodeExpect == ok -> + io:format(" encode failed ", []), + exit({unexpected_encode_result, Else}) + end. + + +%% -- + +compact_otp5186_msg01() -> + "!/2 <mg5>\nP=67111298{C=2699{AV=mg5_ipeph/0x0f0001{}}}". + +compact_otp5186_msg02() -> + "!/2 <mg5>\nP=67111298{C=2699{AV=mg5_ipeph/0x0f0001}}". + +compact_otp5186_msg03() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + 2, + {domainName,{'DomainName',"mg5",asn1_NOVALUE}}, + {transactions, + [{transactionReply, + {'TransactionReply',67111298,asn1_NOVALUE, + {actionReplies,[ + {'ActionReply',2699,asn1_NOVALUE,asn1_NOVALUE, + [ + {auditValueReply, + {auditResult, + {'AuditResult', + {megaco_term_id,false,["mg5_ipeph","0x0f0001"]}, + [ + ] + } + } + } + ] + } + ] + } + } + } + ] + } + } + }. + +compact_otp5186_msg04() -> + {'MegacoMessage',asn1_NOVALUE, + {'Message',2,{domainName,{'DomainName',"mg5",asn1_NOVALUE}}, + {transactions, + [{transactionReply, + {'TransactionReply',67111298,asn1_NOVALUE, + {actionReplies,[ + {'ActionReply',2699,asn1_NOVALUE,asn1_NOVALUE, + [ + {auditValueReply, + {auditResult, + {'AuditResult', + {megaco_term_id,false,["mg5_ipeph","0x0f0001"]}, + [ + {emptyDescriptors, + {'AuditDescriptor',asn1_NOVALUE,asn1_NOVALUE} + } + ] + } + } + } + ] + } + ] + } + } + } + ] + } + } + }. + +compact_otp5186_msg05() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + 2, + {domainName,{'DomainName',"mg5",asn1_NOVALUE}}, + {transactions, + [{transactionReply, + {'TransactionReply',67111298,asn1_NOVALUE, + {actionReplies,[ + {'ActionReply',2699,asn1_NOVALUE,asn1_NOVALUE, + [ + {addReply, + {'AmmsReply', + [ + {megaco_term_id,false,["mg5_ipeph","0x0f0001"]} + ], + [ + ] + } + } + ] + } + ] + } + } + } + ] + } + } + }. + +compact_otp5186_msg06() -> + {'MegacoMessage',asn1_NOVALUE, + {'Message',2,{domainName,{'DomainName',"mg5",asn1_NOVALUE}}, + {transactions, + [{transactionReply, + {'TransactionReply',67111298,asn1_NOVALUE, + {actionReplies,[ + {'ActionReply',2699,asn1_NOVALUE,asn1_NOVALUE, + [ + {addReply, + {'AmmsReply', + [ + {megaco_term_id,false,["mg5_ipeph","0x0f0001"]} + ], + [ + {emptyDescriptors, + {'AuditDescriptor',asn1_NOVALUE,asn1_NOVALUE} + } + ] + } + } + ] + } + ] + } + } + } + ] + } + } + }. + +%% -- + +compact_otp5186_check_megamsg(M1, M1) -> + ok; +compact_otp5186_check_megamsg(#'MegacoMessage'{authHeader = AH, + mess = M1}, + #'MegacoMessage'{authHeader = AH, + mess = M2}) -> + compact_otp5186_check_mess(M1, M2); +compact_otp5186_check_megamsg(#'MegacoMessage'{authHeader = AH1}, + #'MegacoMessage'{authHeader = AH2}) -> + exit({not_equal, authHeader, AH1, AH2}). + +compact_otp5186_check_mess(M, M) -> + ok; +compact_otp5186_check_mess(#'Message'{version = V, + mId = MId, + messageBody = B1}, + #'Message'{version = V, + mId = MId, + messageBody = B2}) -> + compact_otp5186_check_body(B1, B2); +compact_otp5186_check_mess(#'Message'{version = V, + mId = MId1}, + #'Message'{version = V, + mId = MId2}) -> + exit({not_equal, mId, MId1, MId2}); +compact_otp5186_check_mess(#'Message'{version = V1, + mId = MId}, + #'Message'{version = V2, + mId = MId}) -> + exit({not_equal, version, V1, V2}). + +compact_otp5186_check_body(B, B) -> + ok; +compact_otp5186_check_body({transactions, T1}, {transactions, T2}) -> + compact_otp5186_check_trans(T1, T2); +compact_otp5186_check_body({messageError, E1}, {messageError, E2}) -> + compact_otp5186_check_merr(E1, E2); +compact_otp5186_check_body(B1, B2) -> + exit({not_equal, messageBody, B1, B2}). + +compact_otp5186_check_trans([], []) -> + ok; +compact_otp5186_check_trans([], T2) -> + exit({not_equal, transactions, [], T2}); +compact_otp5186_check_trans(T1, []) -> + exit({not_equal, transactions, T1, []}); +compact_otp5186_check_trans([Tran1|Trans1], [Tran2|Trans2]) -> + compact_otp5186_check_trans(Trans1, Trans2), + compact_otp5186_check_transaction(Tran1, Tran2). + +compact_otp5186_check_merr(ME, ME) -> + ok; +compact_otp5186_check_merr(#'ErrorDescriptor'{errorCode = EC, + errorText = ET1}, + #'ErrorDescriptor'{errorCode = EC, + errorText = ET2}) -> + exit({not_equal, errorText, ET1, ET2}); +compact_otp5186_check_merr(#'ErrorDescriptor'{errorCode = EC1, + errorText = ET}, + #'ErrorDescriptor'{errorCode = EC2, + errorText = ET}) -> + exit({not_equal, errorCode, EC1, EC2}). + +compact_otp5186_check_transaction(T, T) -> + ok; +compact_otp5186_check_transaction({transactionReply, TR1}, + {transactionReply, TR2}) -> + compact_otp5186_check_transRep(TR1, TR2); +compact_otp5186_check_transaction(T1, T2) -> + exit({unexpected_transactions, T1, T2}). + +compact_otp5186_check_transRep(T, T) -> + ok; +compact_otp5186_check_transRep(#'TransactionReply'{transactionId = TId, + immAckRequired = IAR, + transactionResult = TR1}, + #'TransactionReply'{transactionId = TId, + immAckRequired = IAR, + transactionResult = TR2}) -> + compact_otp5186_check_transRes(TR1, TR2); +compact_otp5186_check_transRep(T1, T2) -> + exit({unexpected_transaction_reply, T1, T2}). + +compact_otp5186_check_transRes(TR, TR) -> + ok; +compact_otp5186_check_transRes({actionReplies, AR1}, + {actionReplies, AR2}) -> + compact_otp5186_check_actReps(AR1, AR2); +compact_otp5186_check_transRes(TR1, TR2) -> + exit({unexpected_transaction_result, TR1, TR2}). + +compact_otp5186_check_actReps([], []) -> + ok; +compact_otp5186_check_actReps(AR1, []) -> + exit({not_equal, actionReplies, AR1, []}); +compact_otp5186_check_actReps([], AR2) -> + exit({not_equal, actionReplies, [], AR2}); +compact_otp5186_check_actReps([AR1|ARs1], [AR2|ARs2]) -> + compact_otp5186_check_actRep(AR1, AR2), + compact_otp5186_check_actReps(ARs1, ARs2). + +compact_otp5186_check_actRep(AR, AR) -> + ok; +compact_otp5186_check_actRep(#'ActionReply'{contextId = ID, + errorDescriptor = ED, + contextReply = CtxRep, + commandReply = CmdRep1}, + #'ActionReply'{contextId = ID, + errorDescriptor = ED, + contextReply = CtxRep, + commandReply = CmdRep2}) -> + compact_otp5186_check_cmdReps(CmdRep1, CmdRep2); +compact_otp5186_check_actRep(AR1, AR2) -> + exit({unexpected_actionReply, AR1, AR2}). + +compact_otp5186_check_cmdReps([], []) -> + ok; +compact_otp5186_check_cmdReps(CR1, []) -> + exit({not_equal, commandReplies, CR1, []}); +compact_otp5186_check_cmdReps([], CR2) -> + exit({not_equal, commandReplies, [], CR2}); +compact_otp5186_check_cmdReps([CR1|CRs1], [CR2|CRs2]) -> + compact_otp5186_check_cmdRep(CR1, CR2), + compact_otp5186_check_cmdReps(CRs1, CRs2). + +compact_otp5186_check_cmdRep(CR, CR) -> + ok; +compact_otp5186_check_cmdRep({auditValueReply, AVR1}, + {auditValueReply, AVR2}) -> + compact_otp5186_check_auditReply(AVR1, AVR2); +compact_otp5186_check_cmdRep({addReply, AVR1}, + {addReply, AVR2}) -> + compact_otp5186_check_ammsReply(AVR1, AVR2); +compact_otp5186_check_cmdRep(CR1, CR2) -> + exit({unexpected_commandReply, CR1, CR2}). + +compact_otp5186_check_auditReply(AR, AR) -> + ok; +compact_otp5186_check_auditReply({auditResult, AR1}, + {auditResult, AR2}) -> + compact_otp5186_check_auditRes(AR1, AR2); +compact_otp5186_check_auditReply(AR1, AR2) -> + exit({unexpected_auditReply, AR1, AR2}). + +compact_otp5186_check_ammsReply(AR, AR) -> + ok; +compact_otp5186_check_ammsReply(#'AmmsReply'{terminationID = ID, + terminationAudit = TA1}, + #'AmmsReply'{terminationID = ID, + terminationAudit = TA2}) -> + %% This is just to simplify the test + F = fun(asn1_NOVALUE) -> []; + (E) -> E + end, + compact_otp5186_check_termAudit(F(TA1), F(TA2)); +compact_otp5186_check_ammsReply(AR1, AR2) -> + exit({unexpected_ammsReply, AR1, AR2}). + +compact_otp5186_check_auditRes(AR, AR) -> + ok; +compact_otp5186_check_auditRes(#'AuditResult'{terminationID = ID, + terminationAuditResult = TAR1}, + #'AuditResult'{terminationID = ID, + terminationAuditResult = TAR2}) -> + compact_otp5186_check_termAuditRes(TAR1, TAR2); +compact_otp5186_check_auditRes(AR1, AR2) -> + exit({unexpected_auditResult, AR1, AR2}). + +compact_otp5186_check_termAuditRes([], []) -> + ok; +%% An empty empty descriptor is removed +compact_otp5186_check_termAuditRes([{emptyDescriptors, + #'AuditDescriptor'{auditToken = asn1_NOVALUE, + auditPropertyToken = asn1_NOVALUE}}|TAR1], []) -> + compact_otp5186_check_termAuditRes(TAR1, []); +compact_otp5186_check_termAuditRes(TAR1, []) -> + exit({not_equal, termAuditRes, TAR1, []}); +%% An empty empty descriptor is removed +compact_otp5186_check_termAuditRes([], [{emptyDescriptors, + #'AuditDescriptor'{auditToken = asn1_NOVALUE, + auditPropertyToken = asn1_NOVALUE}}|TAR2]) -> + compact_otp5186_check_termAuditRes([], TAR2); +compact_otp5186_check_termAuditRes([], TAR2) -> + exit({not_equal, termAuditRes, [], TAR2}); +compact_otp5186_check_termAuditRes([ARP1|TAR1], [ARP2|TAR2]) -> + compact_otp5186_check_auditRetParm(ARP1, ARP2), + compact_otp5186_check_termAuditRes(TAR1, TAR2). + +compact_otp5186_check_termAudit([], []) -> + ok; +%% An empty empty descriptor is removed +compact_otp5186_check_termAudit([{emptyDescriptors, + #'AuditDescriptor'{auditToken = asn1_NOVALUE, + auditPropertyToken = asn1_NOVALUE}}|TAR1], []) -> + compact_otp5186_check_termAudit(TAR1, []); +compact_otp5186_check_termAudit(TAR1, []) -> + exit({not_equal, termAudit, TAR1, []}); +%% An empty empty descriptor is removed +compact_otp5186_check_termAudit([], + [{emptyDescriptors, + #'AuditDescriptor'{auditToken = asn1_NOVALUE, + auditPropertyToken = asn1_NOVALUE}}|TAR2]) -> + compact_otp5186_check_termAudit([], TAR2); +compact_otp5186_check_termAudit([], TAR2) -> + exit({not_equal, termAudit, [], TAR2}); +compact_otp5186_check_termAudit([ARP1|TAR1], [ARP2|TAR2]) -> + compact_otp5186_check_auditRetParm(ARP1, ARP2), + compact_otp5186_check_termAudit(TAR1, TAR2). + +compact_otp5186_check_auditRetParm(ARP, ARP) -> + ok; +compact_otp5186_check_auditRetParm({emptyDescriptors, AD1}, + {emptyDescriptors, AD2}) -> + compact_otp5186_check_auditDesc(AD1, AD2); +compact_otp5186_check_auditRetParm(ARP1, ARP2) -> + exit({unexpected_auditRetParm, ARP1, ARP2}). + +compact_otp5186_check_auditDesc(AD, AD) -> + ok; +compact_otp5186_check_auditDesc(#'AuditDescriptor'{auditToken = L1, + auditPropertyToken = asn1_NOVALUE}, + #'AuditDescriptor'{auditToken = L2, + auditPropertyToken = asn1_NOVALUE}) -> + compact_otp5186_check_auditDesc_auditItems(L1, L2); +compact_otp5186_check_auditDesc(#'AuditDescriptor'{auditToken = asn1_NOVALUE, + auditPropertyToken = APT1}, + #'AuditDescriptor'{auditToken = asn1_NOVALUE, + auditPropertyToken = APT2}) -> + compact_otp5186_check_auditDesc_apt(APT1, APT2); +compact_otp5186_check_auditDesc(AD1, AD2) -> + exit({unexpected_auditDesc, AD1, AD2}). + +compact_otp5186_check_auditDesc_auditItems([], []) -> + ok; +compact_otp5186_check_auditDesc_auditItems(AI1, []) -> + exit({not_equal, auditItems, AI1, []}); +compact_otp5186_check_auditDesc_auditItems([], AI2) -> + exit({not_equal, auditItems, [], AI2}); +compact_otp5186_check_auditDesc_auditItems([AI1|AIs1], [AI2|AIs2]) -> + compact_otp5186_check_auditDesc_auditItem(AI1, AI2), + compact_otp5186_check_auditDesc_auditItems(AIs1, AIs2). + +compact_otp5186_check_auditDesc_auditItem(AI, AI) -> + ok; +compact_otp5186_check_auditDesc_auditItem(AI1, AI2) -> + exit({not_equal, auditItem, AI1, AI2}). + +compact_otp5186_check_auditDesc_apt(APT, APT) -> + ok; +compact_otp5186_check_auditDesc_apt(APT1, APT2) -> + exit({not_equal, auditPropertyToken, APT1, APT2}). + + + +%% -------------------------------------------------------------- + +compact_otp5290_msg01(suite) -> + []; +compact_otp5290_msg01(Config) when is_list(Config) -> + d("compact_otp5290_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5290_msg_1(compact_otp5290_msg01(), ok, ok). + +compact_otp5290_msg02(suite) -> + []; +compact_otp5290_msg02(Config) when is_list(Config) -> + d("compact_otp5290_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5290_msg_1(compact_otp5290_msg02(), error, ignore). + +compact_otp5290_msg_1(M1, DecodeExpect, EncodeExpect) -> + Bin1 = list_to_binary(M1), + case decode_message(megaco_compact_text_encoder, false, [], Bin1) of + {ok, Msg} when DecodeExpect == ok -> + io:format(" decoded", []), + case encode_message(megaco_compact_text_encoder, [], Msg) of + {ok, Bin1} when EncodeExpect == ok -> + io:format(", encoded - equal:", []), + ok; + {ok, Bin2} when EncodeExpect == ok -> + M2 = binary_to_list(Bin2), + io:format(", encoded - not equal:", []), + exit({messages_not_equal, Msg, M1, M2}); + {ok, Bin3} when EncodeExpect == error -> + M3 = binary_to_list(Bin3), + io:format(", unexpected encode:", []), + exit({unexpected_encode_success, Msg, M3}); + _ when EncodeExpect == error -> + io:format(", encode failed ", []), + ok + end; + {ok, Msg} when DecodeExpect == error -> + io:format(" decoded", []), + exit({unexpected_decode_success, Msg}); + _Else when DecodeExpect == error -> + io:format(" decode failed ", []), + ok; + Else when DecodeExpect == ok -> + io:format(" decode failed ", []), + exit({unexpected_decode_result, Else}) + end. + +compact_otp5290_msg01() -> + "!/" ?VERSION_STR " <ml>\nT=12345678{C=*{CA{TP,PR}}}". + +compact_otp5290_msg02() -> + "!/" ?VERSION_STR " <ml>\nT=12345678{C=*{CA{TP,PR,TP}}}". + + +compact_otp5793_msg01(suite) -> + []; +compact_otp5793_msg01(Config) when is_list(Config) -> + d("compact_otp5793_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5793(ok, pretty_otp5793_msg1()). + +compact_otp5793(Expected, Msg) -> + expect_codec(Expected, megaco_compact_text_encoder, Msg, []). + + +%% -------------------------------------------------------------- + +compact_otp5993_msg01(suite) -> + []; +compact_otp5993_msg01(Config) when is_list(Config) -> + d("compact_otp5993_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5993(ok, compact_otp5993_msg01()). + +compact_otp5993_msg02(suite) -> + []; +compact_otp5993_msg02(Config) when is_list(Config) -> + d("compact_otp5993_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5993(ok, compact_otp5993_msg02()). + +compact_otp5993_msg03(suite) -> + []; +compact_otp5993_msg03(Config) when is_list(Config) -> + d("compact_otp5993_msg03 -> entry", []), + ?ACQUIRE_NODES(1, Config), + compact_otp5993(ok, compact_otp5993_msg03()). + +compact_otp5993(Expected, Msg) -> + expect_codec(Expected, megaco_compact_text_encoder, Msg, []). + +compact_otp5993_msg01() -> + MT = h221, + T = #megaco_term_id{id = ?A4444}, + TL = [T], + MD = #'MuxDescriptor'{muxType = MT, + termList = TL}, + compact_otp5993_msg(MD). + +compact_otp5993_msg02() -> + MT = h223, + T1 = #megaco_term_id{id = ?A4445}, + T2 = #megaco_term_id{id = ?A5556}, + TL = [T1, T2], + MD = #'MuxDescriptor'{muxType = MT, + termList = TL}, + compact_otp5993_msg(MD). + +compact_otp5993_msg(MD) when is_record(MD, 'MuxDescriptor') -> + AmmDesc = {muxDescriptor, MD}, + AmmReq = #'AmmRequest'{terminationID = [hd(MD#'MuxDescriptor'.termList)], + descriptors = [AmmDesc]}, + Cmd = {addReq, AmmReq}, + CmdReq = #'CommandRequest'{command = Cmd}, + ActReq = #'ActionRequest'{contextId = 5993, + commandRequests = [CmdReq]}, + TransReq = #'TransactionRequest'{transactionId = 3995, + actions = [ActReq]}, + Trans = {transactionRequest, TransReq}, + Body = {transactions, [Trans]}, + Msg = #'Message'{version = ?VERSION, + mId = ?MG1_MID, + messageBody = Body}, + #'MegacoMessage'{mess = Msg}. + +compact_otp5993_msg03() -> + T1 = #megaco_term_id{id = ?A4445}, + T2 = #megaco_term_id{id = ?A5556}, + TIDs = [T1, T2], + AudRep = {contextAuditResult, TIDs}, + CmdRep = {auditValueReply, AudRep}, + ActRep = #'ActionReply'{contextId = 5993, + commandReply = [CmdRep]}, + TransRes = {actionReplies, [ActRep]}, + TransRep = #'TransactionReply'{transactionId = 3995, + transactionResult = TransRes}, + Trans = {transactionReply, TransRep}, + Body = {transactions, [Trans]}, + Msg = #'Message'{version = ?VERSION, + mId = ?MG1_MID, + messageBody = Body}, + #'MegacoMessage'{mess = Msg}. + + +%% -------------------------------------------------------------- + +compact_otp6017_msg01(suite) -> + []; +compact_otp6017_msg01(Config) when is_list(Config) -> + d("compact_otp6017_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + ok = compact_otp6017(0), + ok. + +compact_otp6017_msg02(suite) -> + []; +compact_otp6017_msg02(Config) when is_list(Config) -> + d("compact_otp6017_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + ok = compact_otp6017(16#FFFFFFFE), + ok. + +compact_otp6017_msg03(suite) -> + []; +compact_otp6017_msg03(Config) when is_list(Config) -> + d("compact_otp6017_msg03 -> entry", []), + ?ACQUIRE_NODES(1, Config), + ok = compact_otp6017(16#FFFFFFFF), + ok. + +compact_otp6017(BadCID) -> + M = compact_otp6017_msg(BadCID), + Bin = list_to_binary(M), + case decode_message(megaco_compact_text_encoder, false, [], Bin) of + {ok, Msg} -> + exit({unexpected_decode_success, {Msg, M}}); + {error, Reason} when is_list(Reason) -> % Expected result + case lists:keysearch(reason, 1, Reason) of + {value, {reason, {_Line, _Mod, {bad_ContextID, BadCID}}}} -> + io:format(" ~w", [BadCID]), + ok; + {value, {reason, ActualReason}} -> + exit({unexpected_reason, ActualReason}); + false -> + exit({reason_not_found, Reason}) + end; + Crap -> + exit({unexpected_decode_result, Crap}) + end. + +compact_otp6017_msg(CID) when is_integer(CID) -> + "MEGACO/" ?VERSION_STR " MG1 T=12345678{C=" ++ + integer_to_list(CID) ++ + "{SC=root{SV{MT=RS,RE=901}}}}". + + +%% -------------------------------------------------------------- + +compact_otp7138_msg01(suite) -> + []; +compact_otp7138_msg01(Config) when is_list(Config) -> +%% put(dbg, true), +%% put(severity, trc), + d("compact_otp7138_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = compact_otp7138_msg01(), + EC = [], + ok = compact_otp7138(EC, Msg), + ok. + +compact_otp7138_msg02(suite) -> + []; +compact_otp7138_msg02(Config) when is_list(Config) -> +%% put(dbg, true), +%% put(severity, trc), + d("compact_otp7138_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = compact_otp7138_msg02(), + EC = [], + ok = compact_otp7138(EC, Msg), + ok. + +compact_otp7138_msg01() -> + <<"!/2 <gw>\nT=1111{C=1{N=mgw2dev1/1{OE=16777985{ctyp/dtone{dtt=CT}}}}}">>. + +compact_otp7138_msg02() -> + <<"!/2 <gw>\nT=1111{C=1{N=mgw2dev1/1{OE=16777985{ctyp/dtone{dtt=\"CT\"}}}}}">>. + +compact_otp7138(EC, BinMsg) -> + d("compact_otp7138 -> " + "~n ~p", [binary_to_list(BinMsg)]), + Codec = megaco_compact_text_encoder, + case decode_message(Codec, false, EC, BinMsg) of + {ok, Msg} -> + case encode_message(Codec, EC, Msg) of + {ok, BinMsg} -> + d("compact_otp7138 -> encode successfull: " + "~n ~p", [binary_to_list(BinMsg)]), + ok; + {ok, BinMsg2} -> + d("compact_otp7138 -> encode successfull but result differ: " + "~n ~p", [binary_to_list(BinMsg2)]), + ok; + {error, Reason} -> + e("encode failed: ~p", [Reason]), + {error, Reason} + end; + {error, Reason} -> + e("decode failed: ~p", [Reason]), + {error, Reason} + end. + + +compact_otp7457_msg01(suite) -> + []; +compact_otp7457_msg01(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("compact_otp7457_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = compact_otp7457_msg01(), + EC = [], + ok = compact_otp7457(EC, Msg), + ok. + +compact_otp7457_msg02(suite) -> + []; +compact_otp7457_msg02(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("compact_otp7457_msg02 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = compact_otp7457_msg02(), + EC = [], + ok = compact_otp7457(EC, Msg), + ok. + +compact_otp7457_msg03(suite) -> + []; +compact_otp7457_msg03(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("compact_otp7457_msg03 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = compact_otp7457_msg03(), + EC = [], + ok = compact_otp7457(EC, Msg), + ok. + +compact_otp7457_msg01() -> + <<"!/2 <mg1>\nT=15{C=-{SC=tdm12/1/1/*{SV{MT=RS,RE=900}}}}\n">>. + +compact_otp7457_msg02() -> + <<"!/2 <mg1>\nT=15{C=-{O-SC=tdm12/1/1/*{SV{MT=RS,RE=900}}}}\n">>. + +compact_otp7457_msg03() -> + <<"!/2 <mg1>\nT=15{C=-{W-SC=tdm12/1/1/*{SV{MT=RS,RE=900}}}}\n">>. + +compact_otp7457(EC, BinMsg) -> + d("compact_otp7457 -> " + "~n ~p", [binary_to_list(BinMsg)]), + Codec = megaco_compact_text_encoder, + case decode_message(Codec, false, EC, BinMsg) of + {ok, Msg} -> + case encode_message(Codec, EC, Msg) of + {ok, BinMsg} -> + d("compact_otp7457 -> encode successfull: " + "~n ~p", [binary_to_list(BinMsg)]), + ok; + {ok, BinMsg2} -> + d("compact_otp7457 -> " + "encode successfull but result differ: " + "~n ~p", [binary_to_list(BinMsg2)]), + ok; + {error, Reason} -> + e("encode failed: ~p", [Reason]), + {error, Reason} + end; + {error, Reason} -> + e("decode failed: ~p", [Reason]), + {error, Reason} + end. + +compact_otp7534_msg01(suite) -> + []; +compact_otp7534_msg01(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("compact_otp7534_msg01 -> entry", []), + Msg = otp7534_msg01(), + compact_otp7534([], Msg). + + +compact_otp7576_msg01(suite) -> + []; +compact_otp7576_msg01(Config) when is_list(Config) -> +%% put(dbg, true), +%% put(severity, trc), + d("compact_otp7576_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = compact_otp7576_msg01(), + EC = [], + ok = compact_otp7576(EC, Msg), + ok. + +compact_otp7576_msg01() -> + M = "!/" + ?VERSION_STR + "[130.100.144.37]:2944\nT=10032{C=${tp{*,*,is,st=1},pr=6,a=rtp/2/${m{st=1{o{mo=so,rv=ON},l{ +v=0 +c=IN IP4 $ +m=audio $ RTP/AVP 0 +b=AS:64 +a=rtpmap:0 PCMU/8000 +}}},e=1{G/CAUSE}},a=rtp/2/${m{st=1{o{mo=rc,rv=ON},l{ +v=0 +c=IN IP4 $ +m=audio $ RTP/AVP 0 +b=AS:64 +a=rtpmap:0 PCMU/8000 +},r{ +v=0 +c=IN IP4 130.100.126.77 +m=audio 8014 RTP/AVP 0 +b=AS:64 +a=rtpmap:0 PCMU/8000 +}}},e=1{G/CAUSE}}}}", + list_to_binary(M). + +compact_otp7576(EC, BinMsg) -> + d("compact_otp7576 -> " + "~n ~p", [binary_to_list(BinMsg)]), + Codec = megaco_compact_text_encoder, + case decode_message(Codec, false, EC, BinMsg) of + {ok, Msg} -> + case encode_message(Codec, EC, Msg) of + {ok, BinMsg} -> + d("compact_otp7138 -> encode successfull: " + "~n ~p", [binary_to_list(BinMsg)]), + ok; + {ok, BinMsg2} -> + d("compact_otp7138 -> encode successfull but result differ: " + "~n ~p", [binary_to_list(BinMsg2)]), + case decode_message(Codec, false, EC, BinMsg2) of + {ok, Msg} -> + d("compact_otp7138 -> " + "extra verification decode ok", []), + ok; + {ok, Msg2} -> + e("verification decode generated other message: " + "~n Msg: ~p" + "~n Msg2: ~p", [Msg, Msg2]), + {error, {verification_decode, Msg, Msg2}} + end; + {error, Reason} -> + e("encode failed: ~p", [Reason]), + {error, Reason} + end; + {error, Reason} -> + e("decode failed: ~p", [Reason]), + {error, Reason} + end. + + +%% -------------------------------------------------------------- +%% + +compact_otp7671_msg01(suite) -> + []; +compact_otp7671_msg01(Config) when is_list(Config) -> + put(severity, trc), + put(dbg, true), + d("compact_otp7671_msg01 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = compact_otp7671( compact_otp7671_msg01(), [] ), + erase(dbg), + erase(severity), + ok. + +compact_otp7671(Msg, Conf) -> + compact_otp7671(Msg, Conf, ok). + +compact_otp7671(Msg, Conf, ExpectedEncode) -> + compact_otp7671(Msg, Conf, ExpectedEncode, ok). + +compact_otp7671(Msg, Conf, ExpectedEncode, ExpectedDecode) -> + otp7671(Msg, megaco_compact_text_encoder, Conf, + ExpectedEncode, ExpectedDecode). + +%% "!/" ?VERSION_STR " <ml>\nT=172047781{C=-{MF=root{DM=DmName}}}", +compact_otp7671_msg01() -> + pretty_otp7671_msg01(). + + +%% ============================================================== +%% +%% F l e x C o m p a c t T e s t c a s e s +%% + +flex_compact_otp7138_msg01(suite) -> + []; +flex_compact_otp7138_msg01(Config) when is_list(Config) -> + %% put(dbg, true), + %% put(severity, trc), + d("flex_compact_otp7138_msg01 -> entry", []), + Msg = compact_otp7138_msg01(), + Conf = flex_scanner_conf(Config), + compact_otp7138([Conf], Msg). + +flex_compact_otp7138_msg02(suite) -> + []; +flex_compact_otp7138_msg02(Config) when is_list(Config) -> + %% put(dbg, true), + %% put(severity, trc), + d("flex_compact_otp7138_msg02 -> entry", []), + Msg = compact_otp7138_msg02(), + Conf = flex_scanner_conf(Config), + compact_otp7138([Conf], Msg). + + +flex_compact_otp7431_msg01(suite) -> + []; +flex_compact_otp7431_msg01(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg01 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(ok, flex_compact_otp7431_msg1(), [Conf]). + +flex_compact_otp7431_msg02(suite) -> + []; +flex_compact_otp7431_msg02(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg02 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(error, flex_compact_otp7431_msg2(), [Conf]). + +flex_compact_otp7431_msg03(suite) -> + []; +flex_compact_otp7431_msg03(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg03 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(error, flex_compact_otp7431_msg3(), [Conf]). + +flex_compact_otp7431_msg04(suite) -> + []; +flex_compact_otp7431_msg04(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg04 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(error, flex_compact_otp7431_msg4(), [Conf]). + +flex_compact_otp7431_msg05(suite) -> + []; +flex_compact_otp7431_msg05(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg05 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(error, flex_compact_otp7431_msg5(), [Conf]). + +flex_compact_otp7431_msg06(suite) -> + []; +flex_compact_otp7431_msg06(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg06 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(error, flex_compact_otp7431_msg6(), [Conf]). + +flex_compact_otp7431_msg07(suite) -> + []; +flex_compact_otp7431_msg07(Config) when is_list(Config) -> + %% put(severity,trc), + %% put(dbg,true), + d("flex_comppact_otp7431_msg07 -> entry", []), + Conf = flex_scanner_conf(Config), + flex_compact_otp7431(error, flex_compact_otp7431_msg7(), [Conf]). + + +flex_compact_otp7431(Expected, Msg, Conf) -> + otp7431(Expected, megaco_compact_text_encoder, Msg, Conf). + +flex_compact_otp7431_msg1() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v=0 +o=- 2890844526 2890842807 IN IP4 124.124.124.222 +s=- +t= 0 0 +c=IN IP4 124.124.124.222 +m=audio 2222 RTP/AVP 4 +a=ptime:30 +a=recvonly +}}}}}}". + +flex_compact_otp7431_msg2() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v=0 +o=- 2890844526 2890842807 IN IP4 124.124.124.222 +s=- +t= 0 0 +c=IN IP4 124.124.124.222 +m=audio 2222 RTP/AVP 4 +a=ptime:30 +a= } +}}}}}". + + +flex_compact_otp7431_msg3() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v=0 +o=- 2890844526 2890842807 IN IP4 124.124.124.222 +s=- +t= 0 0 +c=IN IP4 124.124.124.222 +m=audio 2222 RTP/AVP 4 +a=ptime:30 +a } +}}}}}". + + +flex_compact_otp7431_msg4() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v=0 +o=- 2890844526 2890842807 IN IP4 124.124.124.222 +s=- +t= 0 0 +c=IN IP4 124.124.124.222 +m=audio 2222 RTP/AVP 4 +a=ptime:30 +a} +}}}}}". + + +flex_compact_otp7431_msg5() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v= } +}}}}}". + + +flex_compact_otp7431_msg6() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v } +}}}}}". + +flex_compact_otp7431_msg7() -> + "!/1 [124.124.124.222]:55555 +P=10003{C=2000{A=a4444,A=a4445{M{ST=1{L{ +v} +}}}}}". + +flex_compact_otp7457_msg01(suite) -> + []; +flex_compact_otp7457_msg01(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("flex_compact_otp7457_msg01 -> entry", []), + Msg = compact_otp7457_msg01(), + Conf = flex_scanner_conf(Config), + compact_otp7457([Conf], Msg). + +flex_compact_otp7457_msg02(suite) -> + []; +flex_compact_otp7457_msg02(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("flex_compact_otp7457_msg02 -> entry", []), + Msg = compact_otp7457_msg02(), + Conf = flex_scanner_conf(Config), + compact_otp7457([Conf], Msg). + +flex_compact_otp7457_msg03(suite) -> + []; +flex_compact_otp7457_msg03(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("flex_compact_otp7457_msg03 -> entry", []), + Msg = compact_otp7457_msg03(), + Conf = flex_scanner_conf(Config), + compact_otp7457([Conf], Msg). + +flex_compact_otp7534_msg01(suite) -> + []; +flex_compact_otp7534_msg01(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("flex_compact_otp7534_msg01 -> entry", []), + Msg = otp7534_msg01(), + Conf = flex_scanner_conf(Config), + compact_otp7534([Conf], Msg). + +otp7534_msg01() -> + <<"!/2 bgwch3_1\nP=62916991{C=-{AV=root{M{TS{ipra/ar=[interconnect,interconnect1,internal],SI=IV}},PG{root-2,ocp-1,it-1,nt-1,rtp-1,gm-1,ds-1,tman-1,xnq-1}}}}">>. + +compact_otp7534(EC, BinMsg) -> + Codec = megaco_compact_text_encoder, + otp7534(Codec, EC, BinMsg). + +otp7534(Codec, EC, BinMsg) -> + d("otp7534 -> " + "~n Codec: ~p" + "~n ~p", [Codec, binary_to_list(BinMsg)]), + case decode_message(Codec, false, EC, BinMsg) of + {ok, Msg} -> + case encode_message(Codec, EC, Msg) of + {ok, BinMsg} -> + d("otp7457 -> encode successfull: " + "~n ~p", [binary_to_list(BinMsg)]), + ok; + {ok, BinMsg2} -> + d("otp7457 -> " + "encode successfull but result differ: " + "~n ~p", [binary_to_list(BinMsg2)]), + ok; + {error, Reason} -> + e("encode failed: ~p", [Reason]), + {error, Reason} + end; + {error, Reason} -> + e("decode failed: ~p", [Reason]), + {error, Reason} + end. + + +flex_compact_otp7573_msg01(suite) -> + []; +flex_compact_otp7573_msg01(Config) when is_list(Config) -> + put(dbg, true), + put(severity, trc), + d("flex_compact_otp7573_msg01 -> entry", []), + Msg = otp7573_msg01(), + Conf = flex_scanner_conf(Config), + compact_otp7573([Conf], Msg). + +otp7573_msg01() -> + <<"!/2 <aa>\nP=37775561{C=-{AV=root{M{TS{root/maxnumberofcontexts=16000,root/maxterminationspercontext=2,root/normalmgexecutiontime=3000,root/normalmgcexecutiontime=3000,root/mgprovisionalresponsetimervalue=2000,root/mgcprovisionalresponsetimervalue=2000,root/mgcoriginatedpendinglimit=5,root/mgoriginatedpendinglimit=5,ipra/ar=[\"\"],SI=IV}},PG{root-2,ocp-1,it-1,nt-1,rtp-1,gm-1,ds-1,tman-1,xnq-1,ipra-1}}}}">>. + +compact_otp7573(EC, BinMsg) -> + Codec = megaco_compact_text_encoder, + otp7573(Codec, EC, BinMsg). + +otp7573(Codec, EC, BinMsg) -> + d("otp7573 -> " + "~n Codec: ~p" + "~n ~p", [Codec, binary_to_list(BinMsg)]), + case decode_message(Codec, false, EC, BinMsg) of + {ok, Msg} -> + case encode_message(Codec, EC, Msg) of + {ok, BinMsg} -> + d("otp7573 -> encode successfull: " + "~n ~p", [binary_to_list(BinMsg)]), + ok; + {ok, BinMsg2} -> + d("otp7573 -> " + "encode successfull but result differ: " + "~n ~p", [binary_to_list(BinMsg2)]), + ok; + {error, Reason} -> + e("encode failed: ~p", [Reason]), + {error, Reason} + end; + {error, Reason} -> + e("decode failed: ~p", [Reason]), + {error, Reason} + end. + + +flex_compact_otp7576_msg01(suite) -> + []; +flex_compact_otp7576_msg01(Config) when is_list(Config) -> +%% put(dbg, true), +%% put(severity, trc), + d("flex_compact_otp7576_msg01 -> entry", []), + Msg = compact_otp7576_msg01(), + Conf = flex_scanner_conf(Config), + compact_otp7576([Conf], Msg). + + +%% ============================================================== +%% +%% P r e t t y T e s t c a s e s +%% + +pretty_otp4632_msg1(suite) -> + []; +pretty_otp4632_msg1(Config) when is_list(Config) -> + d("pretty_otp4632_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4632_msg1(), + case encode_message(megaco_pretty_text_encoder, [], Msg0) of + {ok, BinMsg} when is_binary(BinMsg) -> + {ok, Msg1} = decode_message(megaco_pretty_text_encoder, false, + [], BinMsg), + ok = chk_MegacoMessage(Msg0, Msg1); + Else -> + t("pretty_otp4632_msg1 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4632_msg1() -> + msg4(?MG1_MID_NO_PORT, "901 mg col boot"). + +pretty_otp4632_msg2(suite) -> + []; +pretty_otp4632_msg2(Config) when is_list(Config) -> + d("pretty_otp4632_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4632_msg2(), + case encode_message(megaco_pretty_text_encoder, [], Msg0) of + {ok, BinMsg} when is_binary(BinMsg) -> + {ok, Msg1} = decode_message(megaco_pretty_text_encoder, false, + [], BinMsg), + ok = chk_MegacoMessage(Msg0,Msg1); + Else -> + t("pretty_otp4632_msg2 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4632_msg2() -> + msg4(?MG1_MID_NO_PORT, "901"). + + +pretty_otp4632_msg3(suite) -> + []; +pretty_otp4632_msg3(Config) when is_list(Config) -> + d("pretty_otp4632_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4632_msg3(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, + false, [], Bin0) of + {ok, Msg} when is_record(Msg, 'MegacoMessage') -> + {ok, Bin1} = encode_message(megaco_pretty_text_encoder, [], Msg), + Msg1 = binary_to_list(Bin1), + %% io:format("Msg1:~n~s~n", [Msg1]), + Msg0 = Msg1, + ok; + Else -> + t("pretty_otp4632_msg3 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4632_msg3() -> + M = "MEGACO/" ?VERSION_STR " [124.124.124.222]\nTransaction = 9998 {\n\tContext = - {\n\t\tServiceChange = root {\n\t\t\tServices {\n\t\t\t\tMethod = Restart,\n\t\t\t\tServiceChangeAddress = 55555,\n\t\t\t\tProfile = resgw/1,\n\t\t\t\tReason = \"901\"\n\t\t\t}\n\t\t}\n\t}\n}", + M. + + +pretty_otp4632_msg4(suite) -> + []; +pretty_otp4632_msg4(Config) when is_list(Config) -> + d("pretty_otp4632_msg4 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4632_msg4(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {ok, Msg} when is_record(Msg, 'MegacoMessage') -> + {ok, Bin1} = encode_message(megaco_pretty_text_encoder, [], Msg), + Msg1 = binary_to_list(Bin1), + %% io:format("Msg1:~n~s~n", [Msg1]), + pretty_otp4632_msg4_chk(Msg0,Msg1); + Else -> + t("pretty_otp4632_msg4 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + + +pretty_otp4632_msg4() -> + M = "MEGACO/" ?VERSION_STR " [124.124.124.222]\nTransaction = 9998 {\n\tContext = - {\n\t\tServiceChange = root {\n\t\t\tServices {\n\t\t\t\tMethod = Restart,\n\t\t\t\tServiceChangeAddress = 55555,\n\t\t\t\tProfile = resgw/1,\n\t\t\t\tReason = 901\n\t\t\t}\n\t\t}\n\t}\n}", + M. + + +pretty_otp4632_msg4_chk([], []) -> + exit(messages_not_eq); +pretty_otp4632_msg4_chk([], Rest1) -> + exit({messages_not_eq1, Rest1}); +pretty_otp4632_msg4_chk(Rest0, []) -> + exit({messages_not_eq0, Rest0}); +pretty_otp4632_msg4_chk([$R,$e,$a,$s,$o,$n,$ ,$=,$ ,$9,$0,$1|_Rest0], + [$R,$e,$a,$s,$o,$n,$ ,$=,$ ,$",$9,$0,$1,$"|_Rest1]) -> + ok; +pretty_otp4632_msg4_chk([_|Rest0], [_|Rest1]) -> + pretty_otp4632_msg4_chk(Rest0,Rest1). + + +pretty_otp4710_msg1(suite) -> + []; +pretty_otp4710_msg1(Config) when is_list(Config) -> + d("pretty_otp4710_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4710_msg1(), + case encode_message(megaco_pretty_text_encoder, [], Msg0) of + {ok, Bin} when is_binary(Bin) -> + {ok, Msg1} = decode_message(megaco_pretty_text_encoder, false, + [], Bin), + ok = chk_MegacoMessage(Msg0,Msg1); + Else -> + t("pretty_otp4710_msg1 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4710_msg1() -> + msg40(). + + +pretty_otp4710_msg2(suite) -> + []; +pretty_otp4710_msg2(Config) when is_list(Config) -> + d("pretty_otp4710_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4710_msg2(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {ok, Msg} when is_record(Msg, 'MegacoMessage') -> + {ok, Bin1} = encode_message(megaco_pretty_text_encoder, [], Msg), + Msg1 = binary_to_list(Bin1), + %% io:format("Msg1:~n~s~n", [Msg1]), + pretty_otp4710_msg2_chk(Msg0,Msg1); + Else -> + t("pretty_otp4710_msg2 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4710_msg2() -> + "Authentication = 0xEFCDAB89:0x12345678:0x1234567889ABCDEF76543210\nMEGACO/" ?VERSION_STR " [124.124.124.222]\nTransaction = 9998 {\n\tContext = - {\n\t\tServiceChange = root {\n\t\t\tServices {\n\t\t\t\tMethod = Restart,\n\t\t\t\tServiceChangeAddress = 55555,\n\t\t\t\tProfile = resgw/1,\n\t\t\t\tReason = \"901 mg col boot\"\n\t\t\t}\n\t\t}\n\t}\n}". + +pretty_otp4710_msg2_chk(Msg,Msg) -> + ok; +pretty_otp4710_msg2_chk( + [$A,$u,$t,$h,$e,$n,$t,$i,$c,$a,$t,$i,$o,$n,$=,$ |Msg0], + [$A,$u,$t,$h,$e,$n,$t,$i,$c,$a,$t,$i,$o,$n,$=,$ |Msg1]) -> + {AH0, Rest0} = pretty_otp4710_msg2_chk_ah(Msg0, []), + {AH1, Rest1} = pretty_otp4710_msg2_chk_ah(Msg1, []), + case AH0 == AH1 of + true -> + exit({message_not_equal, Rest0, Rest1}); + false -> + exit({auth_header_not_equal, AH0, AH1}) + end. + +pretty_otp4710_msg2_chk_ah([], _Acc) -> + exit(no_auth_header_found); +pretty_otp4710_msg2_chk_ah([$M,$E,$G,$A,$C,$O,$/,_|Rest], Acc) -> + {lists:reverse(Acc), Rest}; +pretty_otp4710_msg2_chk_ah([C|R], Acc) -> + pretty_otp4710_msg2_chk_ah(R, [C|Acc]). + + +pretty_otp4945_msg1(suite) -> + []; +pretty_otp4945_msg1(Config) when is_list(Config) -> + d("pretty_otp4945_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4945_msg1(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {missing_required_serviceChangeParm, [serviceChangeReason]} -> + ok; + Else -> + t("pretty_otp4945_msg1 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + io:format("pretty_otp4945_msg1 -> " + "~n Else: ~w" + "~n", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4945_msg1() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Method = Restart, + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp4945_msg2(suite) -> + []; +pretty_otp4945_msg2(Config) when is_list(Config) -> + d("pretty_otp4945_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4945_msg2(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {missing_required_serviceChangeParm, [serviceChangeMethod]} -> + ok; + Else -> + t("pretty_otp4945_msg2 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + t("pretty_otp4945_msg2 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4945_msg2() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Reason = 901, + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp4945_msg3(suite) -> + []; +pretty_otp4945_msg3(Config) when is_list(Config) -> + d("pretty_otp4945_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4945_msg3(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {missing_required_serviceChangeParm, [serviceChangeReason, serviceChangeMethod]} -> + ok; + {missing_required_serviceChangeParm, [serviceChangeMethod, serviceChangeReason]} -> + ok; + Else -> + t("pretty_otp4945_msg3 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + t("pretty_otp4945_msg3 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4945_msg3() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp4945_msg4(suite) -> + []; +pretty_otp4945_msg4(Config) when is_list(Config) -> + d("pretty_otp4945_msg4 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4945_msg4(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {ok, _} -> + ok; + Else -> + t("pretty_otp4945_msg4 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4945_msg4() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Method = Restart, + Reason = 901, + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp4945_msg5(suite) -> + []; +pretty_otp4945_msg5(Config) when is_list(Config) -> + d("pretty_otp4945_msg5 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4945_msg5(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {at_most_once_serviceChangeParm, {profile, _Val1, _Val2}} -> + ok; + Else -> + io:format("pretty_otp4945_msg6 -> " + "~n Else: ~w" + "~n", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + t("pretty_otp4945_msg5 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4945_msg5() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Method = Restart, + Reason = 901, + Profile = ResGW/1, + ServiceChangeAddress = 55555, + Profile = ResGW/2 + } + } + } +}". + + +pretty_otp4945_msg6(suite) -> + []; +pretty_otp4945_msg6(Config) when is_list(Config) -> + d("pretty_otp4945_msg6 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4945_msg6(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {not_both_address_mgcid_serviceChangeParm, _Val1, _Val2} -> + ok; + Else -> + io:format("pretty_otp4945_msg6 -> " + "~n Else: ~w" + "~n", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + t("pretty_otp4945_msg6 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4945_msg6() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Method = Restart, + Reason = 901, + ServiceChangeAddress = 55555, + MgcIdToTry = kalle, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp4949_msg1(suite) -> + []; +pretty_otp4949_msg1(Config) when is_list(Config) -> + d("pretty_otp4949_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4949_msg1(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {ok, _} -> + ok; + Else -> + t("pretty_otp4949_msg1 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4949_msg1() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Reply = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp4949_msg2(suite) -> + []; +pretty_otp4949_msg2(Config) when is_list(Config) -> + d("pretty_otp4949_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4949_msg2(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {at_most_once_servChgReplyParm, {profile, _Val1, _Val2}} -> + ok; + Else -> + io:format("pretty_otp4949_msg2 -> " + "~n Else: ~w" + "~n", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + t("pretty_otp4949_msg2 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4949_msg2() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Reply = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Profile = ResGW/1, + ServiceChangeAddress = 55555, + Profile = ResGW/2 + } + } + } +}". + + +pretty_otp4949_msg3(suite) -> + []; +pretty_otp4949_msg3(Config) when is_list(Config) -> + d("pretty_otp4949_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp4949_msg3(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {not_both_address_mgcid_servChgReplyParm, _Val1, _Val2} -> + ok; + Else -> + io:format("pretty_otp4949_msg3 -> " + "~n Else: ~w" + "~n", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + t("pretty_otp4949_msg3 -> " + "~n Else: ~w", [Else]), + exit({unexpected_decode_result, Else}) + end. + +pretty_otp4949_msg3() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Reply = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + ServiceChangeAddress = 55555, + MgcIdToTry = kalle, + Profile = ResGW/1 + } + } + } +}". + + +pretty_otp5042_msg1(suite) -> + []; +pretty_otp5042_msg1(Config) when is_list(Config) -> + d("pretty_otp5042_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg0 = pretty_otp5042_msg1(), + Bin0 = list_to_binary(Msg0), + case decode_message(megaco_pretty_text_encoder, false, [], Bin0) of + {error, [{reason, Reason}|_]} -> + case Reason of + {_, _Mod, {bad_timeStamp, TimeStamp}} -> + exit({bad_timeStamp, TimeStamp}); + _ -> + io:format("pretty_otp5042_msg1 -> " + "~n Reason: ~w" + "~n", [Reason]), + exit({unexpected_decode_result, Reason}) + end; + {ok, M} -> + t("pretty_otp5042_msg1 -> successfull decode:" + "~n~p", [M]), + ok + end. + +pretty_otp5042_msg1() -> +"MEGACO/" ?VERSION_STR " <CATAPULT>:2944 +Transaction = 102 { +Context = 5 { Notify = MUX/1 { ObservedEvents = 1 { +h245bh/h245msgin { Stream = 1 +, h245enc = +0270020600088175000653401004100403E802E00180018001780680000034301160000700088175010101007A0100020001800001320000C0000219D005027F0070500100040100021080000319D005027F00504001008000041C001250000700088175010000400280010003000880000518AA027F400006850130008011020100000001030002000300040005000006 + } } + } } }". + + +pretty_otp5068_msg1(suite) -> + []; +pretty_otp5068_msg1(Config) when is_list(Config) -> + d("pretty_otp5068_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + Msg = pretty_otp5068_msg1(), + case encode_message(megaco_pretty_text_encoder, [], Msg) of + {error, Reason} -> +% io:format("pretty_otp5068_msg1 -> " +% "~n Reason: ~w" +% "~n", [Reason]), + exit({unexpected_encode_result, Reason}); + {ok, Bin} -> +% io:format("pretty_otp5068_msg1 -> successfull encode:" +% "~n~s~n", [binary_to_list(Bin)]), + case decode_message(megaco_pretty_text_encoder, false, [], Bin) of + {ok, _} -> +% io:format("pretty_otp5068_msg1 -> ok~n", []), + ok; + Else -> +% io:format("pretty_otp5068_msg1 -> ~n~p~n", [Else]), + exit({unexpected_decode_result, Else}) + end + end. + +pretty_otp5068_msg1() -> +{'MegacoMessage', + asn1_NOVALUE, + {'Message', + 2, + {deviceName,[109,103,51,51]}, + {transactions, + [{transactionReply, + {'TransactionReply', + 190, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', %% Comments: Detta upprepas m�nga g�nger + 0, + asn1_NOVALUE, + asn1_NOVALUE, + [{auditValueReply, + {auditResult, + {'AuditResult', + {megaco_term_id,false, + [[99,101,100,101,118,49,47,52,47,49,47,49],[51,49]]}, + [{mediaDescriptor, + {'MediaDescriptor', + {'TerminationStateDescriptor', + [], + asn1_NOVALUE, + inSvc}, + asn1_NOVALUE}}]}}}]}]}}}]}}}. + + + +pretty_otp5085_msg1(suite) -> + []; +pretty_otp5085_msg1(Config) when is_list(Config) -> + d("pretty_otp5085_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(ok, pretty_otp5085_msg1()). + +pretty_otp5085_msg2(suite) -> + []; +pretty_otp5085_msg2(Config) when is_list(Config) -> + d("pretty_otp5085_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(error, pretty_otp5085_msg2()). + +pretty_otp5085_msg3(suite) -> + []; +pretty_otp5085_msg3(Config) when is_list(Config) -> + d("pretty_otp5085_msg3 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(ok, pretty_otp5085_msg3()). + +pretty_otp5085_msg4(suite) -> + []; +pretty_otp5085_msg4(Config) when is_list(Config) -> + d("pretty_otp5085_msg4 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(ok, pretty_otp5085_msg4()). + +pretty_otp5085_msg5(suite) -> + []; +pretty_otp5085_msg5(Config) when is_list(Config) -> + d("pretty_otp5085_msg5 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(ok, pretty_otp5085_msg5()). + +pretty_otp5085_msg6(suite) -> + []; +pretty_otp5085_msg6(Config) when is_list(Config) -> + d("pretty_otp5085_msg6 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(ok, pretty_otp5085_msg6()). + +pretty_otp5085_msg7(suite) -> + []; +pretty_otp5085_msg7(Config) when is_list(Config) -> + d("pretty_otp5085_msg7 -> entry", []), + ?ACQUIRE_NODES(1, Config), + pretty_otp5085(ok, pretty_otp5085_msg7()). + +pretty_otp5085(Expected, Msg) -> + pretty_otp5085(Expected, Msg, []). + +pretty_otp5085(Expected, Msg, Conf) -> + t("pretty_otp5085 -> entry with" + "~n Expected: ~p" + "~n Msg: ~p", [Expected, Msg]), + case (catch encode_message(megaco_pretty_text_encoder, Conf, Msg)) of + {error, Reason} when Expected == error -> + d("pretty_otp5085 -> encode failed as expected" + "~n Reason: ~w", [Reason]), + ok; + {error, Reason} -> + e("pretty_otp5085 -> encode failed unexpectedly: " + "~n Reason: ~w", [Reason]), + exit({unexpected_encode_result, Reason}); + {ok, Bin} when Expected == error -> + e("pretty_otp5085 -> encode succeded unexpectedly: " + "~n ~w", [binary_to_list(Bin)]), + exit({unexpected_encode_result, binary_to_list(Bin)}); + {ok, Bin} -> + d("pretty_otp5085 -> successfull encode as expected:" + "~n~s", [binary_to_list(Bin)]), + case decode_message(megaco_pretty_text_encoder, false, Conf, Bin) of + {ok, Msg} -> + d("pretty_otp5085 -> successfull decode~n", []), + ok; + {ok, Msg2} -> + e("pretty_otp5085 -> successfull decode" + " - but not equal", []), + exit({unexpected_decode_result, Msg, Msg2}); + Else -> + e("pretty_otp5085 -> decode failed:~n~p", [Else]), + exit({unexpected_decode_result, Else}) + end + end. + +pretty_otp5085_msg1() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"mg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + {'ErrorDescriptor',504,asn1_NOVALUE}, + asn1_NOVALUE, + [] + } + ] + } + } + } + ] + } + } + }. + +pretty_otp5085_msg2() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"mg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + asn1_NOVALUE, + asn1_NOVALUE, + [] + } + ] + } + } + } + ] + } + } + }. + +pretty_otp5085_msg3() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"mg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + asn1_NOVALUE, + #'ContextRequest'{priority = 3}, + [] + } + ] + } + } + } + ] + } + } + }. + +pretty_otp5085_msg4() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"mg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + asn1_NOVALUE, + asn1_NOVALUE, + [{addReply, cre_AmmsReply([#megaco_term_id{id = ?A4444}])}, + {notifyReply, cre_NotifyRep([#megaco_term_id{id = ?A5555}])}] + } + ] + } + } + } + ] + } + } + }. + +pretty_otp5085_msg5() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"mg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + asn1_NOVALUE, + #'ContextRequest'{priority = 5}, + [{addReply, cre_AmmsReply([#megaco_term_id{id = ?A4444}])}, + {notifyReply, cre_NotifyRep([#megaco_term_id{id = ?A5555}])}] + } + ] + } + } + } + ] + } + } + }. + +pretty_otp5085_msg6() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"msg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + {'ErrorDescriptor',504,asn1_NOVALUE}, + #'ContextRequest'{priority = 6}, + [{addReply, cre_AmmsReply([#megaco_term_id{id = ?A4444}])}, + {notifyReply, cre_NotifyRep([#megaco_term_id{id = ?A5555}])}] + } + ] + } + } + } + ] + } + } + }. + +pretty_otp5085_msg7() -> + {'MegacoMessage', + asn1_NOVALUE, + {'Message', + ?VERSION, + {deviceName,"msg36"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 230, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 400, + {'ErrorDescriptor',504,asn1_NOVALUE}, + #'ContextRequest'{priority = 7}, + [{notifyReply, cre_NotifyRep([#megaco_term_id{id = ?A5555}])}] + } + ] + } + } + } + ] + } + } + }. + + + +pretty_otp5600_msg1(suite) -> + []; +pretty_otp5600_msg1(Config) when is_list(Config) -> + d("pretty_otp5600_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + %% put(severity,trc), + %% put(dbg,true), + pretty_otp5600(ok, pretty_otp5600_msg1()). + +pretty_otp5600_msg2(suite) -> + []; +pretty_otp5600_msg2(Config) when is_list(Config) -> + d("pretty_otp5600_msg2 -> entry", []), + ?ACQUIRE_NODES(1, Config), + %% put(severity,trc), + %% put(dbg,true), + pretty_otp5600(ok, pretty_otp5600_msg2()). + +pretty_otp5600(Expected, Msg) -> + pretty_otp5600(Expected, Msg, []). + +pretty_otp5600(Expected, Msg, Conf) -> + t("pretty_otp5600 -> entry with" + "~n Expected: ~p" + "~n Msg: ~p", [Expected, Msg]), + case (catch encode_message(megaco_pretty_text_encoder, Conf, Msg)) of + {error, Reason} when Expected == error -> + d("pretty_otp5600 -> encode failed as expected" + "~n Reason: ~w", [Reason]), + ok; + {error, Reason} -> + e("pretty_otp5600 -> encode failed unexpectedly: " + "~n Reason: ~w", [Reason]), + exit({unexpected_encode_result, Reason}); + {ok, Bin} when Expected == error -> + e("pretty_otp5600 -> encode succeded unexpectedly: " + "~n ~w", [binary_to_list(Bin)]), + exit({unexpected_encode_result, binary_to_list(Bin)}); + {ok, Bin} -> + d("pretty_otp5600 -> successfull encode as expected:" + "~n~s", [binary_to_list(Bin)]), + case decode_message(megaco_pretty_text_encoder, false, Conf, Bin) of + {ok, Msg} -> + d("pretty_otp5600 -> successfull decode~n", []), + ok; + {ok, Msg2} -> + e("pretty_otp5600 -> successfull decode" + " - but not equal", []), + exit({unexpected_decode_result, Msg, Msg2}); + Else -> + e("pretty_otp5600 -> decode failed:~n~p", [Else]), + exit({unexpected_decode_result, Else}) + end + end. + + +pretty_otp5600_msg1() -> + SRE = #'SecondRequestedEvent'{ pkgdName = "al/on", + evParList = [] }, + + SED = #'SecondEventsDescriptor'{ requestID = 2, + eventList = [ SRE ] }, + + SIG = { signal, #'Signal'{ signalName = "cg/dt", + sigParList = [] } }, + + RA = #'RequestedActions'{ secondEvent = SED, + signalsDescriptor = [ SIG ] }, + + RE = #'RequestedEvent'{ pkgdName = "al/of", + eventAction = RA, + evParList = [] }, + + EV = #'EventsDescriptor'{ requestID = 1, eventList = [ RE ] }, + + TermID = {megaco_term_id, true, [[$*]] }, + + AMMR = #'AmmRequest'{ terminationID = [ TermID ], + descriptors = [ { eventsDescriptor, EV } ] }, + + CR = #'CommandRequest'{command = {modReq, AMMR}}, + + AR = #'ActionRequest'{contextId = ?megaco_null_context_id, + commandRequests = [CR]}, + ARs = [AR], + TR = #'TransactionRequest'{transactionId = 5600, actions = ARs}, + TRs = [{transactionRequest, TR}], + Mess = #'Message'{version = ?VERSION, + mId = ?MGC_MID, + messageBody = {transactions, TRs}}, + #'MegacoMessage'{mess = Mess}. + + +pretty_otp5600_msg2() -> + SIG = { signal, #'Signal'{ signalName = "cg/dt", + sigParList = [] } }, + + SRA = #'SecondRequestedActions'{ signalsDescriptor = [ SIG ] }, + + SRE = #'SecondRequestedEvent'{ pkgdName = "al/on", + eventAction = SRA, + evParList = [] }, + + SED = #'SecondEventsDescriptor'{ requestID = 2, + eventList = [ SRE ] }, + + RA = #'RequestedActions'{ secondEvent = SED }, + + RE = #'RequestedEvent'{ pkgdName = "al/of", + eventAction = RA, + evParList = [] }, + + EV = #'EventsDescriptor'{ requestID = 1, eventList = [ RE ] }, + + TermID = {megaco_term_id, true, [[$*]] }, + + AMMR = #'AmmRequest'{ terminationID = [ TermID ], + descriptors = [ { eventsDescriptor, EV } ] }, + + CR = #'CommandRequest'{command = {modReq, AMMR}}, + + AR = #'ActionRequest'{contextId = ?megaco_null_context_id, + commandRequests = [CR]}, + ARs = [AR], + TR = #'TransactionRequest'{transactionId = 5600, actions = ARs}, + TRs = [{transactionRequest, TR}], + Mess = #'Message'{version = ?VERSION, + mId = ?MGC_MID, + messageBody = {transactions, TRs}}, + #'MegacoMessage'{mess = Mess}. + + +pretty_otp5601_msg1(suite) -> + []; +pretty_otp5601_msg1(Config) when is_list(Config) -> + d("pretty_otp5601_msg1 -> entry", []), + ?ACQUIRE_NODES(1, Config), + %% put(severity,trc), + %% put(dbg,true), + pretty_otp5601(ok, pretty_otp5601_msg1()). + +pretty_otp5601(Expected, Msg) -> + pretty_otp5601(Expected, Msg, []). + +pretty_otp5601(Expected, Msg, Conf) -> + t("pretty_otp5601 -> entry with" + "~n Expected: ~p" + "~n Msg: ~p", [Expected, Msg]), + case (catch encode_message(megaco_pretty_text_encoder, Conf, Msg)) of + {error, Reason} when Expected == error -> + d("pretty_otp5601 -> encode failed as expected" + "~n Reason: ~w", [Reason]), + ok; + {error, Reason} -> + e("pretty_otp5601 -> encode failed unexpectedly: " + "~n Reason: ~w", [Reason]), + exit({unexpected_encode_result, Reason}); + {ok, Bin} when Expected == error -> + e("pretty_otp5601 -> encode succeded unexpectedly: " + "~n ~w", [binary_to_list(Bin)]), + exit({unexpected_encode_result, binary_to_list(Bin)}); + {ok, Bin} -> + d("pretty_otp5601 -> successfull encode as expected:" + "~n~s", [binary_to_list(Bin)]), + case decode_message(megaco_pretty_text_encoder, false, Conf, Bin) of + {ok, Msg} -> + d("pretty_otp5601 -> successfull decode~n", []), + ok; + {ok, Msg2} -> + e("pretty_otp5601 -> successfull decode" + " - but not equal", []), + exit({unexpected_decode_result, Msg, Msg2}); + Else -> + e("pretty_otp5601 -> decode failed:~n~p", [Else]), + exit({unexpected_decode_result, Else}) + end + end. + +pretty_otp5601_msg1() -> + SRE1 = #'SecondRequestedEvent'{ pkgdName = "al/on", + evParList = [] }, + + SRA = #'SecondRequestedActions'{ eventDM = { digitMapName, "dialllan0" }}, + + SRE2 = #'SecondRequestedEvent'{ pkgdName = "dd/ce", + eventAction = SRA, + evParList = [] }, + + SED = #'SecondEventsDescriptor'{ requestID = 2, + eventList = [ SRE1, SRE2 ] }, + + RA = #'RequestedActions'{ secondEvent = SED }, + + RE = #'RequestedEvent'{ pkgdName = "al/of", + eventAction = RA, + evParList = [] }, + + EV = #'EventsDescriptor'{ requestID = 1, eventList = [ RE ] }, + + TermID = {megaco_term_id, true, [[$*]] }, + + AMMR = #'AmmRequest'{ terminationID = [ TermID ], + descriptors = [ { eventsDescriptor, EV } ] }, + + CR = #'CommandRequest'{command = {modReq, AMMR}}, + + AR = #'ActionRequest'{contextId = ?megaco_null_context_id, + commandRequests = [CR]}, + ARs = [AR], + TR = #'TransactionRequest'{transactionId = 5600, actions = ARs}, + TRs = [{transactionRequest, TR}], + Mess = #'Message'{version = ?VERSION, + mId = ?MGC_MID, + messageBody = {transactions, TRs}}, + #'MegacoMessage'{mess = Mess}. + + +pretty_otp5793_msg01(suite) -> + []; +pretty_otp5793_msg01(Config) when is_list(Config) -> + d("pretty_otp5793_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), +%% put(severity,trc), +%% put(dbg,true), + pretty_otp5793(ok, pretty_otp5793_msg1()). + +pretty_otp5793(Expected, Msg) -> + expect_codec(Expected, megaco_pretty_text_encoder, Msg, []). + +pretty_otp5793(Expected, Msg, Conf) -> + expect_codec(Expected, megaco_pretty_text_encoder, Msg, Conf). + + +pretty_otp5793_msg1() -> + {'MegacoMessage',asn1_NOVALUE, + {'Message',2, + {deviceName,"bs_sbg_4/99"}, + {transactions, + [{transactionReply, + {'TransactionReply', + 370, + asn1_NOVALUE, + {actionReplies, + [{'ActionReply', + 3, + asn1_NOVALUE, + asn1_NOVALUE, + [{auditValueReply, + {contextAuditResult, + [{megaco_term_id, + false, + ["ip", + "104", + "1", + "18"]}]}}, + {auditValueReply, + {contextAuditResult, + [{megaco_term_id, + false, + ["ip", + "104", + "2", + "19"]}]}}]}]}}}]}}}. + + +pretty_otp5882_msg01(suite) -> + []; +pretty_otp5882_msg01(Config) when is_list(Config) -> + d("pretty_otp5882_msg01 -> entry", []), + ?ACQUIRE_NODES(1, Config), + %% put(severity,trc), + %% put(dbg,true), + pretty_otp5882(). + +pretty_otp5882() -> + otp5882(megaco_pretty_text_encoder, []). + +otp5882(Codec, Conf) -> + Msg = pretty_otp5882_msg01(), + case (catch encode_message(Codec, Conf, Msg)) of + {error, {message_encode_failed, {error, {ActualReason, _}}, _}} -> + case ActualReason of + {invalid_LocalControlDescriptor, empty} -> + ok; + _ -> + exit({unexpected_error_actual_reason, ActualReason}) + end; + {error, Reason} -> + exit({unexpected_error_reason, Reason}); + {ok, Bin} -> + exit({unexpected_encode_sucess, binary_to_list(Bin)}) + end. + +pretty_otp5882_msg01() -> + LCD = #'LocalControlDescriptor'{}, % Create illegal LCD + Parms = ?MSG_LIB:cre_StreamParms(LCD), + StreamDesc = ?MSG_LIB:cre_StreamDescriptor(1, Parms), + MediaDesc = ?MSG_LIB:cre_MediaDescriptor([StreamDesc]), + AmmReq = ?MSG_LIB:cre_AmmRequest([#megaco_term_id{id = ?A4445}], + [{mediaDescriptor, MediaDesc}]), + Cmd = ?MSG_LIB:cre_Command(modReq, AmmReq), + CmdReq = ?MSG_LIB:cre_CommandRequest(Cmd), + CID = ?MSG_LIB:cre_ContextID(5882), + ActReq = ?MSG_LIB:cre_ActionRequest(CID, [CmdReq]), + Actions = [ActReq], + TransId = ?MSG_LIB:cre_TransactionId(7302), + TransReq = ?MSG_LIB:cre_TransactionRequest(TransId, Actions), + Trans = ?MSG_LIB:cre_Transaction(TransReq), + Mid = ?MG1_MID, + Mess = ?MSG_LIB:cre_Message(?VERSION, Mid, [Trans]), + ?MSG_LIB:cre_MegacoMessage(Mess). + + +%% -------------------------------------------------------------- +%% +pretty_otp6490_msg01(suite) -> + []; +pretty_otp6490_msg01(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp6490_msg01 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp6490( pretty_otp6490_msg01(), [] ), + %% erase(dbg), + %% erase(severity), + ok. + +pretty_otp6490_msg02(suite) -> + []; +pretty_otp6490_msg02(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp6490_msg02 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp6490( pretty_otp6490_msg02(), [] ), + %% erase(severity), + %% erase(dbg), + ok. + +pretty_otp6490_msg03(suite) -> + []; +pretty_otp6490_msg03(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp6490_msg03 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp6490( pretty_otp6490_msg03(), [] ), + %% erase(severity), + %% erase(dbg), + ok. + +pretty_otp6490_msg04(suite) -> + []; +pretty_otp6490_msg04(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp6490_msg04 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp6490( pretty_otp6490_msg04(), [] ), + %% erase(severity), + %% erase(dbg), + ok. + +pretty_otp6490_msg05(suite) -> + []; +pretty_otp6490_msg05(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp6490_msg05 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp6490( pretty_otp6490_msg05(), [] ), + %% erase(severity), + %% erase(dbg), + ok. + +pretty_otp6490_msg06(suite) -> + []; +pretty_otp6490_msg06(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp6490_msg06 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp6490( pretty_otp6490_msg06(), [] ), + %% erase(severity), + %% erase(dbg), + ok. + +pretty_otp6490(Msg, Conf) -> + pretty_otp6490(Msg, Conf, ok). + +pretty_otp6490(Msg, Conf, ExpectedEncode) -> + pretty_otp6490(Msg, Conf, ExpectedEncode, ok). + +pretty_otp6490(Msg, Conf, ExpectedEncode, ExpectedDecode) -> + otp6490(Msg, megaco_pretty_text_encoder, Conf, + ExpectedEncode, ExpectedDecode). + +otp6490(Msg, Codec, Conf, ExpectedEncode, ExpectedDecode) -> + case (catch encode_message(Codec, Conf, Msg)) of + {error, _Reason} when ExpectedEncode == error -> + ok; + {error, Reason} when ExpectedEncode == ok -> + exit({unexpected_encode_failure, Reason}); + {ok, Bin} when ExpectedEncode == error -> + exit({unexpected_encode_success, Msg, binary_to_list(Bin)}); + {ok, Bin} when ExpectedEncode == ok -> + case decode_message(Codec, false, Conf, Bin) of + {ok, Msg} when ExpectedDecode == ok -> + ok; + {ok, Msg} when ExpectedDecode == error -> + exit({unexpected_decode_success, Msg}); + {ok, Msg2} when ExpectedDecode == ok -> + exit({unexpected_decode_result, Msg, Msg2}); + {ok, Msg2} when ExpectedDecode == error -> + exit({unexpected_decode_success, Msg, Msg2}); + {error, _Reason} when ExpectedDecode == error -> + ok; + {error, Reason} when ExpectedDecode == ok -> + exit({unexpected_decode_failure, Msg, Reason}) + end + end. + + +pretty_otp6490_msg(EBD) -> + AmmDesc = ?MSG_LIB:cre_AmmDescriptor(EBD), + AmmReq = cre_AmmReq([#megaco_term_id{id = ?A4445}], [AmmDesc]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + CID = cre_CtxID(64901), + ActReq = cre_ActReq(CID, [CmdReq]), + Actions = [ActReq], + TransId = cre_TransId(64902), + TransReq = cre_TransReq(TransId, Actions), + Trans = cre_Trans(TransReq), + Mid = ?MG1_MID, + Mess = cre_Msg(Mid, [Trans]), + cre_MegacoMessage(Mess). + +pretty_otp6490_msg01() -> + EvSpecs = [], % This will result in an error + EBD = EvSpecs, % This is because the lib checks that the size is valid + pretty_otp6490_msg(EBD). + +pretty_otp6490_msg02() -> + EvPar = ?MSG_LIB:cre_EventParameter("sune", ["mangs"]), + PkgdName = ?MSG_LIB:cre_PkgdName("foo", "a"), + EvName = ?MSG_LIB:cre_EventName(PkgdName), + EvSpec = ?MSG_LIB:cre_EventSpec(EvName, [EvPar]), + EvSpecs = [EvSpec], + EBD = ?MSG_LIB:cre_EventBufferDescriptor(EvSpecs), + pretty_otp6490_msg(EBD). + +pretty_otp6490_msg03() -> + EvPar1 = ?MSG_LIB:cre_EventParameter("sune", ["mangs"]), + EvPar2 = ?MSG_LIB:cre_EventParameter("kalle", ["anka"]), + EvPar3 = ?MSG_LIB:cre_EventParameter("flippa", ["ur"]), + PkgdName = ?MSG_LIB:cre_PkgdName("foo", "a"), + EvName = ?MSG_LIB:cre_EventName(PkgdName), + EvSpec = ?MSG_LIB:cre_EventSpec(EvName, [EvPar1,EvPar2,EvPar3]), + EvSpecs = [EvSpec], + EBD = ?MSG_LIB:cre_EventBufferDescriptor(EvSpecs), + pretty_otp6490_msg(EBD). + +pretty_otp6490_msg04() -> + EvPar1 = ?MSG_LIB:cre_EventParameter("sune", ["mangs"]), + EvPar2 = ?MSG_LIB:cre_EventParameter("kalle", ["anka"]), + EvPar3 = ?MSG_LIB:cre_EventParameter("flippa", ["ur"]), + PkgdName1 = ?MSG_LIB:cre_PkgdName("foo", "a"), + EvName1 = ?MSG_LIB:cre_EventName(PkgdName1), + EvSpec1 = ?MSG_LIB:cre_EventSpec(EvName1, [EvPar1,EvPar2,EvPar3]), + EvPar4 = ?MSG_LIB:cre_EventParameter("hej", ["hopp"]), + PkgdName2 = ?MSG_LIB:cre_PkgdName("bar", "b"), + EvName2 = ?MSG_LIB:cre_EventName(PkgdName2), + EvSpec2 = ?MSG_LIB:cre_EventSpec(EvName2, [EvPar4]), + EvSpecs = [EvSpec1,EvSpec2], + EBD = ?MSG_LIB:cre_EventBufferDescriptor(EvSpecs), + pretty_otp6490_msg(EBD). + +pretty_otp6490_msg05() -> + EvPar = ?MSG_LIB:cre_EventParameter("sune", ["mangs"]), + PkgdName = ?MSG_LIB:cre_PkgdName("foo", root), + EvName = ?MSG_LIB:cre_EventName(PkgdName), + EvSpec = ?MSG_LIB:cre_EventSpec(EvName, [EvPar]), + EvSpecs = [EvSpec], + EBD = ?MSG_LIB:cre_EventBufferDescriptor(EvSpecs), + pretty_otp6490_msg(EBD). + +pretty_otp6490_msg06() -> + EvPar = ?MSG_LIB:cre_EventParameter("sune", ["mangs"]), + PkgdName = ?MSG_LIB:cre_PkgdName(root, root), + EvName = ?MSG_LIB:cre_EventName(PkgdName), + EvSpec = ?MSG_LIB:cre_EventSpec(EvName, [EvPar]), + EvSpecs = [EvSpec], + EBD = ?MSG_LIB:cre_EventBufferDescriptor(EvSpecs), + pretty_otp6490_msg(EBD). + + +%% -------------------------------------------------------------- +%% +pretty_otp7249_msg01(suite) -> + []; +pretty_otp7249_msg01(doc) -> + "Ticket OTP-7249 has really nothing to to with just version 2 " + "although the test message is version 2. Instead the decode " + "is actually done by the mini decoder, which is where the bug " + "manifests itself. The bug is in effect located in the (plain) " + "text scanner. "; +pretty_otp7249_msg01(Config) when is_list(Config) -> + %% put(severity, trc), + %% put(dbg, true), + d("pretty_otp7249_msg01 -> entry", []), + ok = pretty_otp7249( pretty_otp7249_msg01() ), + %% erase(dbg), + %% erase(severity), + ok. + + +pretty_otp7249_msg01() -> + "MEGACO/2 <AGW95_DCT_2_DPNSS>\r\nTransaction = 500017 { \r\nContext = - { ServiceChange = ROOT { Services { \r\nMethod = Disconnected, Reason = 900, 20070116T15233997 } \r\n } } } \r\n". + +pretty_otp7249(EncodedMsg) -> + Codec = megaco_pretty_text_encoder, + Conf = [], + Bin = list_to_binary(EncodedMsg), + case decode_mini_message(Codec, Conf, Bin) of + {ok, Msg} when is_record(Msg, 'MegacoMessage') -> + %% io:format("Msg: ~n~p" + %% "~n", [Msg]), + ok; + {error, Reason} -> + exit({unexpected_decode_failure, EncodedMsg, Reason}) + end. + + + +%% -------------------------------------------------------------- +%% + +pretty_otp7671_msg01(suite) -> + []; +pretty_otp7671_msg01(Config) when is_list(Config) -> +%% put(severity, trc), +%% put(dbg, true), + d("pretty_otp7671_msg01 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp7671( pretty_otp7671_msg01(), [] ), +%% erase(dbg), +%% erase(severity), + ok. + +pretty_otp7671_msg02(suite) -> + []; +pretty_otp7671_msg02(Config) when is_list(Config) -> +%% put(severity, trc), +%% put(dbg, true), + d("pretty_otp7671_msg02 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp7671( pretty_otp7671_msg02(), [] ), +%% erase(dbg), +%% erase(severity), + ok. + +pretty_otp7671_msg03(suite) -> + []; +pretty_otp7671_msg03(Config) when is_list(Config) -> +%% put(severity, trc), +%% put(dbg, true), + d("pretty_otp7671_msg03 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp7671( pretty_otp7671_msg03(), [] ), +%% erase(dbg), +%% erase(severity), + ok. + +pretty_otp7671_msg04(suite) -> + []; +pretty_otp7671_msg04(Config) when is_list(Config) -> +%% put(severity, trc), +%% put(dbg, true), + d("pretty_otp7671_msg04 -> entry", []), + %% ?ACQUIRE_NODES(1, Config), + ok = pretty_otp7671( pretty_otp7671_msg04(), [] , error, ignore), +%% erase(dbg), +%% erase(severity), + ok. + +pretty_otp7671_msg05(suite) -> + []; +pretty_otp7671_msg05(Config) when is_list(Config) -> +%% put(severity, trc), +%% put(dbg, true), + d("pretty_otp7671_msg05 -> entry", []), + Check = fun(M1, M2) -> cmp_otp7671_msg05(M1, M2) end, + ok = pretty_otp7671( pretty_otp7671_msg05(), [] , ok, ok, Check), +%% erase(dbg), +%% erase(severity), + ok. + + +pretty_otp7671(Msg, Conf) -> + pretty_otp7671(Msg, Conf, ok). + +pretty_otp7671(Msg, Conf, ExpectedEncode) -> + pretty_otp7671(Msg, Conf, ExpectedEncode, ok). + +pretty_otp7671(Msg, Conf, ExpectedEncode, ExpectedDecode) -> + otp7671(Msg, megaco_pretty_text_encoder, Conf, + ExpectedEncode, ExpectedDecode). + +pretty_otp7671(Msg, Conf, ExpectedEncode, ExpectedDecode, Check) -> + otp7671(Msg, megaco_pretty_text_encoder, Conf, + ExpectedEncode, ExpectedDecode, Check). + +otp7671(Msg, Codec, Conf, ExpectedEncode, ExpectedDecode) -> + Check = fun(M1, M2) -> + exit({unexpected_decode_result, M1, M2}) + end, + otp7671(Msg, Codec, Conf, ExpectedEncode, ExpectedDecode, Check). + +otp7671(Msg, Codec, Conf, ExpectedEncode, ExpectedDecode, Check) + when is_function(Check) -> + case (catch encode_message(Codec, Conf, Msg)) of + {error, _Reason} when ExpectedEncode =:= error -> + ok; + {error, Reason} when ExpectedEncode =:= ok -> + exit({unexpected_encode_failure, Reason}); + {ok, Bin} when ExpectedEncode =:= error -> + exit({unexpected_encode_success, Msg, binary_to_list(Bin)}); + {ok, Bin} when ExpectedEncode =:= ok -> + case decode_message(Codec, false, Conf, Bin) of + {ok, Msg} when ExpectedDecode =:= ok -> + ok; + {ok, Msg2} when ExpectedDecode =:= ok -> + Check(Msg, Msg2); + {ok, Msg} when ExpectedDecode =:= error -> + exit({unexpected_decode_success, Msg}); + {ok, Msg2} when ExpectedDecode =:= error -> + exit({unexpected_decode_success, Msg, Msg2}); + {error, _Reason} when ExpectedDecode =:= error -> + ok; + {error, Reason} when ExpectedDecode == ok -> + exit({unexpected_decode_failure, Msg, Reason}) + end + end. + + +pretty_otp7671_msg(DigitMapDesc) -> + AmmReq = cre_AmmReq([#megaco_term_id{id = ["root"]}], + [{digitMapDescriptor, DigitMapDesc}]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + msg_request(?MGC_MID, 10001, ?megaco_null_context_id, [CmdReq]). + +pretty_otp7671_msg01() -> + Name = "dialplan01", + DigitMapDesc = cre_DigitMapDesc(Name), + pretty_otp7671_msg(DigitMapDesc). + +pretty_otp7671_msg02() -> + Name = "dialplan02", + Body = "(0s| 00s|[1-7]xlxx|8lxxxxxxx|#xxxxxxx|*xx|9l1xxxxxxxxxx|9l011x.s)", + Value = cre_DigitMapValue(Body), + DigitMapDesc = cre_DigitMapDesc(Name, Value), + pretty_otp7671_msg(DigitMapDesc). + +pretty_otp7671_msg03() -> + Body = "(0s| 00s|[1-7]xlxx|8lxxxxxxx|#xxxxxxx|*xx|9l1xxxxxxxxxx|9l011x.s)", + Value = cre_DigitMapValue(Body), + DigitMapDesc = cre_DigitMapDesc(Value), + pretty_otp7671_msg(DigitMapDesc). + +pretty_otp7671_msg04() -> + DigitMapDesc = cre_DigitMapDesc(), + pretty_otp7671_msg(DigitMapDesc). + +pretty_otp7671_msg05() -> + {'MegacoMessage',asn1_NOVALUE, + {'Message',?VERSION, + {domainName,{'DomainName',"tgc",asn1_NOVALUE}}, + {transactions, + [{transactionRequest, + {'TransactionRequest',12582952, + [{'ActionRequest',0,asn1_NOVALUE,asn1_NOVALUE, + [{'CommandRequest', + {modReq, + {'AmmRequest', + [{megaco_term_id,false,["root"]}], + [{digitMapDescriptor, + {'DigitMapDescriptor',"dialplan1", + {'DigitMapValue',asn1_NOVALUE,asn1_NOVALUE,asn1_NOVALUE,[], + asn1_NOVALUE}}}]}}, + asn1_NOVALUE,asn1_NOVALUE}]}]}}]}}}. + +cmp_otp7671_msg05(#'MegacoMessage'{authHeader = asn1_NOVALUE, + mess = M1}, + #'MegacoMessage'{authHeader = asn1_NOVALUE, + mess = M2}) -> + #'Message'{messageBody = Body1} = M1, + #'Message'{messageBody = Body2} = M2, + {transactions, Trans1} = Body1, + {transactions, Trans2} = Body2, + [{transactionRequest, TR1}] = Trans1, + [{transactionRequest, TR2}] = Trans2, + #'TransactionRequest'{actions = Acts1} = TR1, + #'TransactionRequest'{actions = Acts2} = TR2, + [#'ActionRequest'{commandRequests = CR1}] = Acts1, + [#'ActionRequest'{commandRequests = CR2}] = Acts2, + [#'CommandRequest'{command = Cmd1}] = CR1, + [#'CommandRequest'{command = Cmd2}] = CR2, + {modReq, #'AmmRequest'{descriptors = Descs1}} = Cmd1, + {modReq, #'AmmRequest'{descriptors = Descs2}} = Cmd2, + [{digitMapDescriptor, + #'DigitMapDescriptor'{digitMapName = Name, + digitMapValue = Value1}}] = Descs1, + [{digitMapDescriptor, + #'DigitMapDescriptor'{digitMapName = Name, + digitMapValue = Value2}}] = Descs2, + #'DigitMapValue'{startTimer = asn1_NOVALUE, + shortTimer = asn1_NOVALUE, + longTimer = asn1_NOVALUE, + digitMapBody = [], + durationTimer = asn1_NOVALUE} = Value1, + asn1_NOVALUE = Value2, + ok. + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +expect_codec(Expect, Codec, Msg, Conf) -> + t("expect_codec -> entry with" + "~n Expect: ~p" + "~n Msg: ~p", [Expect, Msg]), + case (catch encode_message(Codec, Conf, Msg)) of + {error, _Reason} when Expect == error -> + d("expect_codec -> encode failed as expected" + "~n _Reason: ~w", [_Reason]), + ok; + {error, Reason} -> + e("expect_codec -> encode failed unexpectedly: " + "~n Reason: ~w", [Reason]), + exit({unexpected_encode_result, Reason}); + {ok, Bin} when Expect == error -> + e("expect_codec -> encode succeded unexpectedly: " + "~n ~w", [binary_to_list(Bin)]), + exit({unexpected_encode_result, binary_to_list(Bin)}); + {ok, Bin} -> + d("expect_codec -> successfull encode as expected:" + "~n~s", [binary_to_list(Bin)]), + case (catch decode_message(Codec, false, Conf, Bin)) of + {ok, Msg} -> + d("expect_codec -> successfull decode~n", []), + ok; + {ok, Msg2} -> + e("expect_codec -> successfull decode" + " - but not equal", []), + chk_MegacoMessage(Msg, Msg2); + %% exit({unexpected_decode_result, Msg, Msg2}); + Else -> + e("expect_codec -> decode failed:~n~p", [Else]), + exit({unexpected_decode_result, Else}) + end; + Else -> + e("expect_codec -> encode failed:~n~p", [Else]), + exit({unexpected_encode_result, Else}) + end. + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +msgs() -> + Msgs = msgs1() ++ msgs2() ++ msgs3() ++ msgs4(), + [M || {_, M, _, _} <- Msgs]. + +msgs1() -> + Plain = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:plain_encode_decode(Codec, DD, Ver, + EC, M) + end, + [ + {msg01a, msg1a(), Plain, [{dbg,false}]}, + {msg01b, msg1b(), Plain, [{dbg,false}]}, + {msg02, msg2(), Plain, [{dbg,false}]}, + {msg03, msg3(), Plain, [{dbg,false}]}, + {msg04, msg4(), Plain, [{dbg,false}]}, + {msg05, msg5(), Plain, [{dbg,false}]}, + {msg06a, msg6a(), Plain, [{dbg,false}]}, + {msg06b, msg6b(), Plain, [{dbg,false}]}, + {msg07, msg7(), Plain, [{dbg,false}]}, + {msg08a, msg8a(), Plain, [{dbg,false}]}, + {msg08b, msg8b(), Plain, [{dbg,false}]}, + {msg09, msg9(), Plain, [{dbg,false}]}, + {msg10, msg10(), Plain, [{dbg,false}]}, + {msg11, msg11(), Plain, [{dbg,false}]}, + {msg12, msg12(), Plain, [{dbg,false}]}, + {msg13, msg13(), Plain, [{dbg,false}]}, + {msg14, msg14(), Plain, [{dbg,false}]}, + {msg15, msg15(), Plain, [{dbg,false}]}, + {msg16, msg16(), Plain, [{dbg,false}]}, + {msg17, msg17(), Plain, [{dbg,false}]}, + {msg18, msg18(), Plain, [{dbg,false}]}, + {msg19, msg19(), Plain, [{dbg,false}]}, + {msg20, msg20(), Plain, [{dbg,false}]}, + {msg21, msg21(), Plain, [{dbg,false}]}, + {msg22a, msg22a(), Plain, [{dbg,false}]}, + {msg22b, msg22b(), Plain, [{dbg,false}]}, + {msg22c, msg22c(), Plain, [{dbg,false}]}, + {msg22d, msg22d(), Plain, [{dbg,false}]}, + {msg22e, msg22e(), Plain, [{dbg,false}]}, + {msg22f, msg22f(), Plain, [{dbg,false}]}, + {msg23a, msg23a(), Plain, [{dbg,false}]}, + {msg23b, msg23b(), Plain, [{dbg,false}]}, + {msg23c, msg23c(), Plain, [{dbg,false}]}, + {msg23d, msg23d(), Plain, [{dbg,false}]}, + {msg24, msg24(), Plain, [{dbg,false}]}, + {msg25, msg25(), Plain, [{dbg,false}]}, + {msg30a, msg30a(), Plain, [{dbg,false}]}, + {msg30b, msg30b(), Plain, [{dbg,false}]}, + {msg30c, msg30c(), Plain, [{dbg,false}]}, + {msg30d, msg30d(), Plain, [{dbg,false}]} + ]. + + +msgs2() -> + TransFirst = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:trans_first_encode_decode(Codec, DD, + Ver, EC, M) + end, + ActionsFirst = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:actions_first_encode_decode(Codec, DD, + Ver, EC, M) + end, + ActionFirst = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:action_first_encode_decode(Codec, DD, + Ver, EC, M) + end, + [ + {msg01a_tf, msg1a(), TransFirst, [{dbg,false}]}, + {msg02_tf, msg2(), TransFirst, [{dbg,false}]}, + {msg10_tf, msg10(), TransFirst, [{dbg,false}]}, + {msg11_tf, msg11(), TransFirst, [{dbg,false}]}, + {msg23d_tf, msg23d(), TransFirst, [{dbg,false}]}, + {msg30b_tf, msg30b(), TransFirst, [{dbg,false}]}, + {msg30c_tf, msg30c(), TransFirst, [{dbg,false}]}, + {msg01a_asf, msg1a(), ActionsFirst, [{dbg,false}]}, + {msg02_asf, msg2(), ActionsFirst, [{dbg,false}]}, + {msg10_asf, msg10(), ActionsFirst, [{dbg,false}]}, + {msg23d_asf, msg23d(), ActionsFirst, [{dbg,false}]}, + {msg01a_af, msg1a(), ActionFirst, [{dbg,false}]}, + {msg02_af, msg2(), ActionFirst, [{dbg,false}]}, + {msg10_af, msg10(), ActionFirst, [{dbg,false}]}, + {msg23d_af, msg23d(), ActionFirst, [{dbg,false}]} + ]. + + +msgs3() -> + Plain = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:plain_encode_decode(Codec, DD, Ver, + EC, M) + end, + [{msgs3_name(Name), rfc3525_decode(M), Plain, [{dbg, false}]} || + {Name, M} <- rfc3525_msgs()]. + +msgs3_name(N) -> + list_to_atom("rfc3525_" ++ atom_to_list(N)). + +rfc3525_decode(M) when is_list(M) -> + rfc3525_decode(list_to_binary(M)); +rfc3525_decode(M) when is_binary(M) -> + case (catch decode_message(megaco_pretty_text_encoder, false, [], M)) of + {ok, Msg} -> + Msg; + Error -> + {error, {rfc3525_decode_error, Error}} + end. + + +msgs4() -> + Plain = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:plain_encode_decode(Codec, DD, Ver, + EC, M) + end, + [ + {msg51a, msg51a(), Plain, [{dbg, false}]}, + {msg51b, msg51b(), Plain, [{dbg, false}]}, + {msg51c, msg51c(), Plain, [{dbg, false}]}, + {msg51d, msg51d(), Plain, [{dbg, false}]}, + {msg51e, msg51e(), Plain, [{dbg, false}]}, + {msg51f, msg51f(), Plain, [{dbg, false}]}, + {msg51g, msg51g(), Plain, [{dbg, false}]}, + {msg51h, msg51h(), Plain, [{dbg, false}]}, + {msg51i, msg51i(), Plain, [{dbg, false}]}, + {msg52, msg52(), Plain, [{dbg, false}]}, + {msg53, msg53(), Plain, [{dbg, false}]}, + {msg54a, msg54a(), Plain, [{dbg, false}]}, + {msg54b, msg54b(), Plain, [{dbg, false}]}, + {msg54c, msg54c(), Plain, [{dbg, false}]}, + {msg55, msg55(), Plain, [{dbg, false}]}, + {msg56, msg56(), Plain, [{dbg, false}]}, + {msg57, msg57(), Plain, [{dbg, false}]}, + {msg58a, msg58a(), Plain, [{dbg, false}]}, + {msg58b, msg58b(), Plain, [{dbg, false}]} + ]. + + +msgs5() -> + Plain = + fun(Codec, DD, Ver, EC, M) -> + megaco_codec_test_lib:plain_encode_decode(Codec, DD, Ver, + EC, M) + end, + + PlainEDFail = + fun(Codec, DD, Ver, EC, M) -> + Res = + megaco_codec_test_lib:plain_encode_decode(Codec, DD, Ver, + EC, M), + case Res of + {error, {message_encode_failed, Reason, _M}} -> + case Reason of + {error, {{deprecated, _}, _}} -> + ok; + _ -> + Res + end; + _ -> + Res + end + end, + + PlainDE = + fun(Codec, _DD, Ver, EC, B) -> + Res = + megaco_codec_test_lib:decode_message(Codec, false, Ver, + EC, B), + case Res of + {ok, M} -> + #'MegacoMessage'{mess = Mess} = M, + #'Message'{messageBody = {transactions, TRs}} = Mess, + [{transactionRequest, TR}] = TRs, + #'TransactionRequest'{actions = Actions} = TR, + [Action] = Actions, + #'ActionRequest'{commandRequests = CmdReqs} = Action, + [CmdReq] = CmdReqs, + #'CommandRequest'{command = Cmd} = CmdReq, + {addReq,AmmReq} = Cmd, + #'AmmRequest'{descriptors = []} = AmmReq, + ok; + _ -> + Res + end + end, + + [ + {msg61a, msg61a(), Plain, [{dbg, false}]}, + {msg61b, msg61b(), Plain, [{dbg, false}]}, + {msg61c, msg61c(), Plain, [{dbg, false}]}, + {msg62a, msg62a(), PlainEDFail, [{dbg, false}]}, + {msg62b, msg62b(), PlainDE, [{dbg, false}]} + ]. + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +msg_actions([], Actions) -> + lists:reverse(Actions); +msg_actions([{CtxId, CmdReqs}|ActionInfo], Actions) -> + Action = ?MSG_LIB:cre_ActionRequest(CtxId,CmdReqs), + msg_actions(ActionInfo, [Action|Actions]). + +megaco_trans_req([], Transactions) -> + {transactions, lists:reverse(Transactions)}; +megaco_trans_req([{TransId, ActionInfo}|TransInfo], Transactions) -> + Actions = msg_actions(ActionInfo, []), + TR = ?MSG_LIB:cre_TransactionRequest(TransId, Actions), + Trans = ?MSG_LIB:cre_Transaction(TR), + megaco_trans_req(TransInfo, [Trans|Transactions]). + +megaco_message(Version, Mid, Body) -> + Mess = ?MSG_LIB:cre_Message(Version, Mid, Body), + ?MSG_LIB:cre_MegacoMessage(Mess). + +msg_request(Mid, TransInfo) -> + TransReq = megaco_trans_req(TransInfo, []), + megaco_message(?VERSION, Mid, TransReq). + +msg_request(Mid, TransId, ContextId, CmdReq) -> + Action = ?MSG_LIB:cre_ActionRequest(ContextId, CmdReq), + Actions = [Action], + TR = ?MSG_LIB:cre_TransactionRequest(TransId, Actions), + Trans = ?MSG_LIB:cre_Transaction(TR), + Mess = ?MSG_LIB:cre_Message(?VERSION, Mid, [Trans]), + ?MSG_LIB:cre_MegacoMessage(Mess). + +msg_request(Auth, Mid, TransId, ContextId, CmdReq) -> + Action = ?MSG_LIB:cre_ActionRequest(ContextId, CmdReq), + Actions = [Action], + TR = ?MSG_LIB:cre_TransactionRequest(TransId, Actions), + Trans = ?MSG_LIB:cre_Transaction(TR), + Mess = ?MSG_LIB:cre_Message(?VERSION, Mid, [Trans]), + ?MSG_LIB:cre_MegacoMessage(Auth, Mess). + +msg_reply(Mid, TransId, ContextId, CmdReply) -> + Action = cre_ActRep(ContextId, CmdReply), + Actions = [Action], + TR = cre_TransRep(TransId, Actions), + Trans = ?MSG_LIB:cre_Transaction(TR), + Mess = ?MSG_LIB:cre_Message(?VERSION, Mid, [Trans]), + ?MSG_LIB:cre_MegacoMessage(Mess). + +msg_ack(Mid, [Range|_] = Ranges) when is_tuple(Range) -> + msg_ack(Mid, [Ranges]); + +msg_ack(Mid, Ranges) -> + %% TRAs = make_tras(Ranges, []), + TRAs = make_tras(Ranges), + Req = {transactions, TRAs}, + cre_MegacoMessage(?VERSION, Mid, Req). + +make_tras(TRARanges) -> + F = fun(R) -> {transactionResponseAck, make_tra(R)} end, + lists:map(F, TRARanges). + +make_tra(Ranges) -> + F = fun({F,L}) -> cre_TransAck(F,L) end, + lists:map(F, Ranges). + + +%% ------------------------------------------------------------------------- + + +msg1(Mid, Tid) -> + Gain = cre_PropParm("tdmc/gain", "2"), + Ec = cre_PropParm("tdmc/ec", "g165"), + LCD = cre_LocalControlDesc(sendRecv,[Gain, Ec]), + V = cre_PropParm("v", "0"), + %% C = cre_PropParm("c", "IN IP4 $ "), + C = cre_PropParm("c", [$I,$N,$ ,$I,$P,$4,$ ,$$,$ ]), + M = cre_PropParm("m", "audio $ RTP/AVP 0"), + A = cre_PropParm("a", "fmtp:PCMU VAD=X-NNVAD"), + LD = cre_LocalRemoteDesc([[V, C, M, A]]), + Parms = cre_StreamParms(LCD,LD), + StreamDesc = cre_StreamDesc(1,Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + ReqEvent = cre_ReqedEv("al/of"), + EventsDesc = cre_EvsDesc(2222,[ReqEvent]), + AmmReq = cre_AmmReq([#megaco_term_id{id = Tid}], + [{mediaDescriptor, MediaDesc}, + {eventsDescriptor, EventsDesc}]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + msg_request(Mid, 9999, ?megaco_null_context_id, [CmdReq]). + +msg1a() -> + msg1a(?MGC_MID). +msg1a(Mid) -> + msg1(Mid, ?A4444). + +msg1b() -> + msg1b(?MGC_MID). +msg1b(Mid) -> + msg1(Mid, ?A4445). + + +%% -------------------------- + + +msg2() -> + msg2(?MGC_MID). +msg2(Mid) -> + msg2(Mid, ?A4444). +msg2(Mid, Tid) -> + Gain = cre_PropParm("tdmc/gain", "2"), + Ec = cre_PropParm("tdmc/ec", "g165"), + LCD = cre_LocalControlDesc(sendRecv,[Gain, Ec]), + V = cre_PropParm("v", "0"), + %% C = cre_PropParm("c", "IN IP4 $ "), + C = cre_PropParm("c", [$I,$N,$ ,$I,$P,$4,$ ,$$,$ ]), + M = cre_PropParm("m", "audio $ RTP/AVP 0"), + A = cre_PropParm("a", "fmtp:PCMU VAD=X-NNVAD"), + LD = cre_LocalRemoteDesc([[V, C, M, A]]), + Parms = cre_StreamParms(LCD,LD), + StreamDesc = cre_StreamDesc(1,Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + EventParm = cre_EvParm("strict",["exact"]), + ReqEvent = cre_ReqedEv("al/of", [EventParm]), + EventsDesc = cre_EvsDesc(2222,[ReqEvent]), + AmmReq = cre_AmmReq([#megaco_term_id{id = Tid}], + [{mediaDescriptor, MediaDesc}, + {eventsDescriptor, EventsDesc}]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + msg_request(Mid, 9999, ?megaco_null_context_id, [CmdReq]). + + +%% -------------------------- + +msg3() -> + msg3(?MG1_MID). +msg3(Mid) -> + TimeStamp = cre_TimeNot("19990729", "22000000"), + Event = cre_ObsEv("al/of",TimeStamp), + Desc = cre_ObsEvsDesc(2222,[Event]), + NotifyReq = cre_NotifyReq([#megaco_term_id{id = ?A4444}],Desc), + CmdReq = cre_CmdReq({notifyReq, NotifyReq}), + msg_request(Mid, 10000, ?megaco_null_context_id, [CmdReq]). + + +%% -------------------------- + +msg4() -> + msg4(?MG1_MID_NO_PORT, "901 mg col boot"). +msg4(Mid, Reason) when is_list(Reason) -> + Address = {portNumber, ?DEFAULT_PORT}, + Profile = cre_SvcChProf("resgw",1), + Parm = cre_SvcChParm(restart,Address,[Reason],Profile), + Req = cre_SvcChReq([?megaco_root_termination_id],Parm), + CmdReq = cre_CmdReq({serviceChangeReq, Req}), + msg_request(Mid, 9998, ?megaco_null_context_id, [CmdReq]). + + +%% -------------------------- + +msg5() -> + msg5(?MGC_MID). +msg5(Mid) -> + Address = {portNumber, ?DEFAULT_PORT}, + Profile = cre_SvcChProf("resgw",1), + Parm = cre_SvcChResParm(Address,Profile), + Reply = cre_SvcChRep([?megaco_root_termination_id], + {serviceChangeResParms,Parm}), + msg_reply(Mid, 9998, ?megaco_null_context_id, + [{serviceChangeReply, Reply}]). + + +%% -------------------------- + +msg6(Mid, Tid) -> + Reply = cre_AmmsReply([#megaco_term_id{id = Tid}]), + msg_reply(Mid, 9999, ?megaco_null_context_id, [{modReply, Reply}]). + +msg6a() -> + msg6a(?MG1_MID). +msg6a(Mid) -> + msg6(Mid, ?A4444). + +msg6b() -> + msg6b(?MG2_MID). +msg6b(Mid) -> + msg6(Mid, ?A5555). + + +%% -------------------------- + +msg7() -> + msg7(?MGC_MID). +msg7(Mid) -> + Reply = cre_NotifyRep([#megaco_term_id{id = ?A4444}]), + msg_reply(Mid, 10000, ?megaco_null_context_id, [{notifyReply, Reply}]). + + +%% -------------------------- + +msg8(Mid, DigitMapValue) -> + Strict = cre_EvParm("strict",["state"]), + On = cre_ReqedEv("al/on", [Strict]), + Name = "dialplan00", + Action = cre_ReqedActs(Name), + Ce = cre_ReqedEv("dd/ce", Action), + EventsDesc = cre_EvsDesc(2223,[On, Ce]), + Signal = cre_Sig("cg/rt"), + DigMapDesc = cre_DigitMapDesc(Name, DigitMapValue), + AmmReq = cre_AmmReq([#megaco_term_id{id = ?A4444}], + [{eventsDescriptor, EventsDesc}, + {signalsDescriptor, [{signal, Signal}]}, + {digitMapDescriptor, DigMapDesc}]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + msg_request(Mid, 10001, ?megaco_null_context_id, [CmdReq]). + +msg8a() -> + msg8a(?MGC_MID). +msg8a(Mid) -> + Body = "(0s| 00s|[1-7]xlxx|8lxxxxxxx|#xxxxxxx|*xx|9l1xxxxxxxxxx|9l011x.s)", + Value = cre_DigitMapValue(Body), + msg8(Mid, Value). + +msg8b() -> + msg8b(?MGC_MID). +msg8b(Mid) -> + Body = "(0s| 00s|[1-7]xlxx|8lxxxxxxx|#xxxxxxx|*xx|9l1xxxxxxxxxx|9l011x.s)", + Value = cre_DigitMapValue(Body, 1, 23, 99), + msg8(Mid, Value). + + +%% -------------------------- + +msg9() -> + msg9(?MG1_MID). +msg9(Mid) -> + TimeStamp = cre_TimeNot("19990729","22010001"), + Parm = cre_EvParm("ds",["916135551212"]), + Event = cre_ObsEv("dd/ce",TimeStamp,[Parm]), + Desc = cre_ObsEvsDesc(2223,[Event]), + NotifyReq = cre_NotifyReq([#megaco_term_id{id = ?A4444}], Desc), + CmdReq = cre_CmdReq({notifyReq, NotifyReq}), + msg_request(Mid, 10002, ?megaco_null_context_id, [CmdReq]). + + +%% -------------------------- + +msg10() -> + msg10(?MGC_MID). +msg10(Mid) -> + AmmReq = cre_AmmReq([#megaco_term_id{id = ?A4444}],[]), + CmdReq = cre_CmdReq({addReq, AmmReq}), + Jit = cre_PropParm("nt/jit", "40"), + LCD = cre_LocalControlDesc(recvOnly,[Jit]), + V = cre_PropParm("v", "0"), + C = cre_PropParm("c", "IN IP4 $ "), + M = cre_PropParm("m", "audio $ RTP/AVP 4"), + A = cre_PropParm("a", "ptime:30"), + V2 = cre_PropParm("v", "0"), + C2 = cre_PropParm("c", "IN IP4 $ "), + M2 = cre_PropParm("m", "audio $ RTP/AVP 0"), + LD = cre_LocalRemoteDesc([[V, C, M, A], [V2, C2, M2]]), + Parms = cre_StreamParms(LCD, LD), + StreamDesc = cre_StreamDesc(1,Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + ChooseTid = #megaco_term_id{contains_wildcards = true, + id = [[?megaco_choose]]}, + AmmReq2 = cre_AmmReq([ChooseTid],[{mediaDescriptor, MediaDesc}]), + CmdReq2 = cre_CmdReq({addReq, AmmReq2}), + msg_request(Mid, 10003, ?megaco_choose_context_id, [CmdReq, CmdReq2]). + + +msg11() -> + msg11(?MG1_MID). +msg11(Mid) -> + V = cre_PropParm("v", "0"), + C = cre_PropParm("c", "IN IP4 124.124.124.222"), + M = cre_PropParm("m", "audio 2222 RTP/AVP 4"), + A = cre_PropParm("a", "ptime:30"), + A2 = cre_PropParm("a", "recvonly"), + LD = cre_LocalRemoteDesc([[V, C, M, A, A2]]), + Parms = cre_StreamParmsL(LD), + StreamDesc = cre_StreamDesc(1, Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + Reply = cre_AmmsReply([#megaco_term_id{id = ?A4444}]), + Reply2 = cre_AmmsReply([#megaco_term_id{id = ?A4445}], + [{mediaDescriptor, MediaDesc}]), + msg_reply(Mid, 10003, 2000, [{addReply, Reply}, {addReply, Reply2}]). + + +%% -------------------------- + +msg12() -> + msg12(?MGC_MID). +msg12(Mid) -> + LCD = cre_LocalControlDesc(sendRecv), + Parms = cre_StreamParms(LCD), + StreamDesc = cre_StreamDesc(1,Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + Signal = cre_Sig("al/ri"), + Descs = [{mediaDescriptor, MediaDesc}, + {signalsDescriptor, [{signal, Signal}]}], + AmmReq = cre_AmmReq([#megaco_term_id{id = ?A5555}], Descs), + CmdReq = cre_CmdReq({addReq, AmmReq}), + Jit = cre_PropParm("nt/jit", "40"), + LCD2 = cre_LocalControlDesc(sendRecv, [Jit]), + V = cre_PropParm("v", "0"), + C = cre_PropParm("c", "IN IP4 $ "), + M = cre_PropParm("m", "audio $ RTP/AVP 4"), + A = cre_PropParm("a", "ptime:30"), + LD2 = cre_LocalRemoteDesc([[V, C, M, A]]), + V2 = cre_PropParm("v", "0"), + C2 = cre_PropParm("c", "IN IP4 124.124.124.222"), + M2 = cre_PropParm("m", "audio 2222 RTP/AVP 4"), + RD2 = cre_LocalRemoteDesc([[V2, C2, M2]]), + Parms2 = cre_StreamParms(LCD2,LD2,RD2), + StreamDesc2 = cre_StreamDesc(1,Parms2), + MediaDesc2 = cre_MediaDesc(StreamDesc2), + ChooseTid = #megaco_term_id{contains_wildcards = true, + id = [[?megaco_choose]]}, + AmmReq2 = cre_AmmReq([ChooseTid],[{mediaDescriptor, MediaDesc2}]), + CmdReq2 = cre_CmdReq({addReq, AmmReq2}), + msg_request(Mid, 50003, ?megaco_choose_context_id, [CmdReq, CmdReq2]). + + +%% -------------------------- + +msg13() -> + msg13(?MG2_MID). +msg13(Mid) -> + V = cre_PropParm("v", "0"), + C = cre_PropParm("c", "IN IP4 125.125.125.111"), + M = cre_PropParm("m", "audio 1111 RTP/AVP 4"), + LD = cre_LocalRemoteDesc([[V, C, M]]), + Parms = cre_StreamParmsL(LD), + StreamDesc = cre_StreamDesc(1,Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + Reply = cre_AmmsReply([#megaco_term_id{id = ?A5556}], + [{mediaDescriptor, MediaDesc}]), + msg_reply(Mid, 50003, 5000, [{addReply, Reply}]). + + +%% -------------------------- + +msg14() -> + msg14(?MGC_MID). +msg14(Mid) -> + %% Cmd 1) + Signal = cre_Sig("cg/rt"), + AmmReq1 = cre_AmmReq([#megaco_term_id{id = ?A4444}], + [{signalsDescriptor, [{signal, Signal}]}]), + CmdReq1 = cre_CmdReq({modReq, AmmReq1}), + + %% Cmd 2) + Gain = cre_PropParm("tdmc/gain", "2"), + Ec = cre_PropParm("tdmc/ec", "g165"), + LCD = cre_LocalControlDesc(sendRecv, [Gain, Ec]), + Parms2 = cre_StreamParms(LCD), + StreamDesc2 = cre_StreamDesc(1,Parms2), + MediaDesc2 = cre_MediaDesc(StreamDesc2), + AmmReq2 = cre_AmmReq([#megaco_term_id{id = ?A4445}], + [{mediaDescriptor, MediaDesc2}]), + CmdReq2 = cre_CmdReq({modReq, AmmReq2}), + + %% Cmd 3) + V = cre_PropParm("v", "0"), + C = cre_PropParm("c", "IN IP4 125.125.125.111"), + M = cre_PropParm("m", "audio 1111 RTP/AVP 4"), + RD = cre_LocalRemoteDesc([[V, C, M]]), + Parms3 = cre_StreamParmsR(RD), + StreamDesc3 = cre_StreamDesc(2,Parms3), + MediaDesc3 = cre_MediaDesc(StreamDesc3), + AmmReq3 = cre_AmmReq([#megaco_term_id{id = ?A4445}], + [{mediaDescriptor, MediaDesc3}]), + CmdReq3 = cre_CmdReq({modReq, AmmReq3}), + msg_request(Mid, 10005, 2000, [CmdReq1, CmdReq2, CmdReq3]). + + +%% -------------------------- + +msg15() -> + msg15(?MG1_MID). +msg15(Mid) -> + Reply = cre_AmmsReply([#megaco_term_id{id = ?A4444}]), + Reply2 = cre_AmmsReply([#megaco_term_id{id = ?A4445}]), + msg_reply(Mid, 10005, 2000, [{modReply, Reply}, {modReply, Reply2}]). + + +%% -------------------------- + +msg16() -> + msg16(?MG2_MID). +msg16(Mid) -> + TimeStamp = cre_TimeNot("19990729","22020002"), + Event = cre_ObsEv("al/of",TimeStamp), + Desc = cre_ObsEvsDesc(1234,[Event]), + NotifyReq = cre_NotifyReq([#megaco_term_id{id = ?A5555}],Desc), + CmdReq = cre_CmdReq({notifyReq, NotifyReq}), + msg_request(Mid, 50005, 5000, [CmdReq]). + + +%% -------------------------- + +msg17() -> + msg17(?MGC_MID). +msg17(Mid) -> + Reply = cre_NotifyRep([#megaco_term_id{id = ?A5555}]), + msg_reply(Mid, 50005, ?megaco_null_context_id, [{notifyReply, Reply}]). + + +%% -------------------------- + +msg18() -> + msg18(?MGC_MID). +msg18(Mid) -> + On = cre_ReqedEv("al/on"), + EventsDesc = cre_EvsDesc(1235,[On]), + AmmReq = cre_AmmReq([#megaco_term_id{id = ?A5555}], + [{eventsDescriptor, EventsDesc}, + {signalsDescriptor, []}]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + msg_request(Mid, 50006, 5000, [CmdReq]). + + +%% -------------------------- + +msg19() -> + msg19(?MG2_MID). +msg19(Mid) -> + Reply = cre_AmmsReply([#megaco_term_id{id = ?A4445}]), + msg_reply(Mid, 50006, 5000, [{modReply, Reply}]). + + +%% -------------------------- + +msg20() -> + msg20(?MGC_MID). +msg20(Mid) -> + LCD = cre_LocalControlDesc(sendRecv), + Parms = cre_StreamParms(LCD), + StreamDesc = cre_StreamDesc(1,Parms), + MediaDesc = cre_MediaDesc(StreamDesc), + AmmReq = cre_AmmReq([#megaco_term_id{id = ?A4445}], + [{mediaDescriptor, MediaDesc}]), + CmdReq = cre_CmdReq({modReq, AmmReq}), + AmmReq2 = cre_AmmReq([#megaco_term_id{id = ?A4444}], + [{signalsDescriptor, []}]), + CmdReq2 = cre_CmdReq({modReq, AmmReq2}), + msg_request(Mid, 10006, 2000, [CmdReq, CmdReq2]). + + +%% -------------------------- + +msg21() -> + msg21(?MGC_MID). +msg21(Mid) -> + Tokens = [mediaToken, eventsToken, signalsToken, + digitMapToken, statsToken, packagesToken], + AuditDesc = cre_AuditDesc(Tokens), + Req = cre_AuditReq(#megaco_term_id{id = ?A5556},AuditDesc), + CmdReq = cre_CmdReq({auditValueRequest, Req}), + msg_request(Mid, 50007, ?megaco_null_context_id, [CmdReq]). + + +%% -------------------------- + +msg22a() -> + msg22(1). + +msg22b() -> + msg22(10). + +msg22c() -> + msg22(25). + +msg22d() -> + msg22(50). + +msg22e() -> + msg22(75). + +msg22f() -> + msg22(100). + +msg22(N) -> + msg22(?MG2_MID, N). +msg22(Mid, N) -> + Jit = cre_PropParm("nt/jit", "40"), + LCD = cre_LocalControlDesc(sendRecv,[Jit]), + LDV = cre_PropParm("v", "0"), + LDC = cre_PropParm("c", "IN IP4 125.125.125.111"), + LDM = cre_PropParm("m", "audio 1111 RTP/AVP 4"), + LDA = cre_PropParm("a", "ptime:30"), + LD = cre_LocalRemoteDesc([[LDV, LDC, LDM, LDA]]), + RDV = cre_PropParm("v", "0"), + RDC = cre_PropParm("c", "IN IP4 124.124.124.222"), + RDM = cre_PropParm("m", "audio 2222 RTP/AVP 4"), + RDA = cre_PropParm("a", "ptime:30"), + RD = cre_LocalRemoteDesc([[RDV, RDC, RDM, RDA]]), + StreamParms = cre_StreamParms(LCD,LD,RD), + StreamDesc = cre_StreamDesc(1,StreamParms), + Media = cre_MediaDesc(StreamDesc), + PackagesItem = cre_PkgsItem("nt",1), + PackagesItem2 = cre_PkgsItem("rtp",1), + Stat = cre_StatsParm("rtp/ps","1200"), + Stat2 = cre_StatsParm("nt/os","62300"), + Stat3 = cre_StatsParm("rtp/pr","700"), + Stat4 = cre_StatsParm("nt/or","45100"), + Stat5 = cre_StatsParm("rtp/pl","0.2"), + Stat6 = cre_StatsParm("rtp/jit","20"), + Stat7 = cre_StatsParm("rtp/delay","40"), + Statistics = [Stat, Stat2, Stat3, Stat4, Stat5, Stat6, Stat7], + Audits = [{mediaDescriptor, Media}, + {packagesDescriptor, [PackagesItem, PackagesItem2]}, + {statisticsDescriptor, Statistics}], + Reply = {auditResult, + cre_AuditRes(#megaco_term_id{id = ?A5556},Audits)}, + msg_reply(Mid, 50007, ?megaco_null_context_id, + lists:duplicate(N,{auditValueReply, Reply})). +%% msg_reply(Mid, 50007, ?megaco_null_context_id, +%% lists.duplicate([{auditValueReply, Reply}]). + + +%% -------------------------- + +msg23a() -> + msg23a(?MG2_MID). +msg23a(Mid) -> + TimeStamp = cre_TimeNot("19990729","24020002"), + Event = cre_ObsEv("al/on",TimeStamp), + Desc = cre_ObsEvsDesc(1235,[Event]), + NotifyReq = cre_NotifyReq([#megaco_term_id{id = ?A5555}],Desc), + CmdReq = cre_CmdReq({notifyReq, NotifyReq}), + msg_request(Mid, 50008, 5000, [CmdReq]). + + +msg23b() -> + msg23b(?MG2_MID). +msg23b(Mid) -> + TimeStamp = cre_TimeNot("19990729","24020002"), + Event = cre_ObsEv("al/on",TimeStamp), + Desc = cre_ObsEvsDesc(1235,[Event]), + NotifyReq1 = cre_NotifyReq([#megaco_term_id{id = ?A5555}],Desc), + CmdReq1 = cre_CmdReq({notifyReq, NotifyReq1}), + NotifyReq2 = cre_NotifyReq([#megaco_term_id{id = ?A5556}],Desc), + CmdReq2 = cre_CmdReq({notifyReq, NotifyReq2}), + ActionInfo = [{5000, [CmdReq1]}, {5001, [CmdReq2]}], + TransInfo = [{50008, ActionInfo}], + msg_request(Mid, TransInfo). + + +msg23c() -> + msg23c(?MG2_MID). +msg23c(Mid) -> + TimeStamp = cre_TimeNot("19990729","24020002"), + Event = cre_ObsEv("al/on",TimeStamp), + Desc = cre_ObsEvsDesc(1235,[Event]), + NotifyReq1 = cre_NotifyReq([#megaco_term_id{id = ?A5555}],Desc), + CmdReq1 = cre_CmdReq({notifyReq, NotifyReq1}), + NotifyReq2 = cre_NotifyReq([#megaco_term_id{id = ?A5556}],Desc), + CmdReq2 = cre_CmdReq({notifyReq, NotifyReq2}), + ActionInfo1 = [{5000, [CmdReq1]}], + ActionInfo2 = [{5001, [CmdReq2]}], + TransInfo = [{50008, ActionInfo1}, {50009, ActionInfo2}], + msg_request(Mid, TransInfo). + + +msg23d() -> + msg23d(?MG2_MID). +msg23d(Mid) -> + TimeStamp = cre_TimeNot("19990729","24020002"), + Event = cre_ObsEv("al/on",TimeStamp), + Desc = cre_ObsEvsDesc(1235,[Event]), + NotifyReq1 = cre_NotifyReq([#megaco_term_id{id = ?A5555}],Desc), + CmdReq1 = cre_CmdReq({notifyReq, NotifyReq1}), + NotifyReq2 = cre_NotifyReq([#megaco_term_id{id = ?A5556}],Desc), + CmdReq2 = cre_CmdReq({notifyReq, NotifyReq2}), + NotifyReq3 = cre_NotifyReq([#megaco_term_id{id = ?A4444}],Desc), + CmdReq3 = cre_CmdReq({notifyReq, NotifyReq3}), + NotifyReq4 = cre_NotifyReq([#megaco_term_id{id = ?A4445}],Desc), + CmdReq4 = cre_CmdReq({notifyReq, NotifyReq4}), + ActionInfo1 = [{5000, [CmdReq1]}, {5001, [CmdReq2]}], + ActionInfo2 = [{5003, [CmdReq3]}, {5004, [CmdReq4]}], + TransInfo = [{50008, ActionInfo1}, {50009, ActionInfo2}], + msg_request(Mid, TransInfo). + + +%% -------------------------- + +msg24() -> + msg24(?MGC_MID). +msg24(Mid) -> + AuditDesc = cre_AuditDesc([statsToken]), + SubReq = cre_SubReq([#megaco_term_id{id = ?A5555}], AuditDesc), + SubReq2 = cre_SubReq([#megaco_term_id{id = ?A5556}], AuditDesc), + CmdReq = cre_CmdReq({subtractReq, SubReq}), + CmdReq2 = cre_CmdReq({subtractReq, SubReq2}), + msg_request(Mid, 50009, 5000, [CmdReq, CmdReq2]). + + +%% -------------------------- + +msg25() -> + msg25(?MG2_MID). +msg25(Mid) -> + Stat11 = cre_StatsParm("nt/os","45123"), + Stat12 = cre_StatsParm("nt/dur", "40"), + Stats1 = [Stat11, Stat12], + Reply1 = cre_AmmsReply([#megaco_term_id{id = ?A5555}], + [{statisticsDescriptor, Stats1}]), + Stat21 = cre_StatsParm("rtp/ps","1245"), + Stat22 = cre_StatsParm("nt/os", "62345"), + Stat23 = cre_StatsParm("rtp/pr", "780"), + Stat24 = cre_StatsParm("nt/or", "45123"), + Stat25 = cre_StatsParm("rtp/pl", "10"), + Stat26 = cre_StatsParm("rtp/jit", "27"), + Stat27 = cre_StatsParm("rtp/delay","48"), + Stats2 = [Stat21, Stat22, Stat23, Stat24, Stat25, Stat26, Stat27], + Reply2 = cre_AmmsReply([#megaco_term_id{id = ?A5556}], + [{statisticsDescriptor, Stats2}]), + msg_reply(Mid, 50009, 5000, + [{subtractReply, Reply1}, {subtractReply, Reply2}]). + + +msg30a() -> + msg_ack(?MG2_MID, [{9,9}]). + +msg30b() -> + msg_ack(?MG2_MID, [{9,13}]). + +msg30c() -> + msg_ack(?MG2_MID, + [{9,13}, {15,15}, {33,40}, {50,60}, {70,80}, {85,90}, + {101,105},{109,119},{121,130},{140,160},{170,175},{180,189}, + {201,205},{209,219},{221,230},{240,260},{270,275},{280,289}, + {301,305},{309,319},{321,330},{340,360},{370,375},{380,389}, + {401,405},{409,419},{421,430},{440,460},{470,475},{480,489}, + {501,505},{509,519},{521,530},{540,560},{570,575},{580,589} + ]). + +%% Don't think this will be used by the megaco stack, but since it +%% seem's to be a valid construction... +msg30d() -> + msg_ack(?MG2_MID, + [[{9,13}, {15,15}, {33,40}, {50,60}, {70,80}, {85,90}], + [{101,105},{109,119},{121,130},{140,160},{170,175},{180,189}], + [{201,205},{209,219},{221,230},{240,260},{270,275},{280,289}], + [{301,305},{309,319},{321,330},{340,360},{370,375},{380,389}], + [{401,405},{409,419},{421,430},{440,460},{470,475},{480,489}], + [{501,505},{509,519},{521,530},{540,560},{570,575},{580,589}] + ]). + + + +msg40() -> + msg40(?MG1_MID_NO_PORT, "901 mg col boot"). +msg40(Mid, Reason) when is_list(Reason) -> + Address = {portNumber, ?DEFAULT_PORT}, + Profile = cre_SvcChProf("resgw",1), + Parm = cre_SvcChParm(restart,Address,[Reason],Profile), + Req = cre_SvcChReq([?megaco_root_termination_id],Parm), + CmdReq = cre_CmdReq({serviceChangeReq, Req}), + Auth = cre_AuthHeader(), + msg_request(Auth, Mid, 9998, ?megaco_null_context_id, [CmdReq]). + + +msg50(Mid, APT) -> + AD = cre_AuditDesc(asn1_NOVALUE, APT), + Req = cre_AuditReq(#megaco_term_id{id = ?A5556},AD), + CmdReq = cre_CmdReq({auditValueRequest, Req}), + msg_request(Mid, 50007, ?megaco_null_context_id, [CmdReq]). + +%% IndAudMediaDescriptor: +msg51(Mid, IATSDorStream) -> + IAMD = cre_IndAudMediaDesc(IATSDorStream), + IAP = cre_IndAudParam(IAMD), + APT = [IAP], + msg50(Mid, APT). + +msg51a() -> + msg51a(?MG2_MID). +msg51a(Mid) -> + PP = cre_IndAudPropertyParm("tdmc/gain"), + PPs = [PP], + IATSD = cre_IndAudTermStateDesc(PPs), + msg51(Mid, IATSD). + +msg51b() -> + msg51b(?MG2_MID). +msg51b(Mid) -> + PP = cre_IndAudPropertyParm("nt/jit"), + PPs = [PP], + IATSD = cre_IndAudTermStateDesc(PPs), + msg51(Mid, IATSD). + +msg51c() -> + msg51c(?MG2_MID). +msg51c(Mid) -> + IATSD = cre_IndAudTermStateDesc([], asn1_NOVALUE, 'NULL'), + msg51(Mid, IATSD). + +msg51d() -> + msg51d(?MG2_MID). +msg51d(Mid) -> + IATSD = cre_IndAudTermStateDesc([], 'NULL', asn1_NOVALUE), + msg51(Mid, IATSD). + +msg51e() -> + msg51e(?MG2_MID). +msg51e(Mid) -> + IALCD = cre_IndAudLocalControlDesc('NULL', asn1_NOVALUE, + asn1_NOVALUE, asn1_NOVALUE), + IASP = cre_IndAudStreamParms(IALCD), + msg51(Mid, IASP). + +msg51f() -> + msg51f(?MG2_MID). +msg51f(Mid) -> + IALCD = cre_IndAudLocalControlDesc(asn1_NOVALUE, 'NULL', + asn1_NOVALUE, asn1_NOVALUE), + IASP = cre_IndAudStreamParms(IALCD), + msg51(Mid, IASP). + +msg51g() -> + msg51g(?MG2_MID). +msg51g(Mid) -> + IALCD = cre_IndAudLocalControlDesc(asn1_NOVALUE, asn1_NOVALUE, + 'NULL', asn1_NOVALUE), + IASP = cre_IndAudStreamParms(IALCD), + msg51(Mid, IASP). + +msg51h() -> + msg51h(?MG2_MID). +msg51h(Mid) -> + Name = "nt/jit", + IAPP = cre_IndAudPropertyParm(Name), + IALCD = cre_IndAudLocalControlDesc(asn1_NOVALUE, asn1_NOVALUE, + asn1_NOVALUE, [IAPP]), + IASP = cre_IndAudStreamParms(IALCD), + SID = 123, + IASD = cre_IndAudStreamDesc(SID, IASP), + msg51(Mid, [IASD]). + + +msg51i() -> + msg51i(?MG2_MID). +msg51i(Mid) -> + Name = "nt/jit", + Name2 = "tdmc/ec", + IAPP = cre_IndAudPropertyParm(Name), + IAPP2 = cre_IndAudPropertyParm(Name2), + IALCD = cre_IndAudLocalControlDesc('NULL', 'NULL', 'NULL', + [IAPP, IAPP2]), + IASP = cre_IndAudStreamParms(IALCD), + SID = 123, + IASD = cre_IndAudStreamDesc(SID, IASP), + msg51(Mid, [IASD]). + + +%% IndAudEventsDescriptor: +msg52() -> + msg52(?MG2_MID). +msg52(Mid) -> + RequestID = 1235, + PkgdName = "tonedet/std", + IAED = cre_IndAudEvsDesc(RequestID, PkgdName), + IAP = cre_IndAudParam(IAED), + APT = [IAP], + msg50(Mid, APT). + +%% IndAudEventBufferDescriptor: +msg53() -> + msg53(?MG2_MID). +msg53(Mid) -> + EN = "tonedet/std", + SID = 1, + IAEBD = cre_IndAudEvBufDesc(EN, SID), + IAP = cre_IndAudParam(IAEBD), + APT = [IAP], + msg50(Mid, APT). + +%% IndAudSignalsDescriptor: +msg54(Mid, Sig) -> + IASD = cre_IndAudSigsDesc(Sig), + IAP = cre_IndAudParam(IASD), + APT = [IAP], + msg50(Mid, APT). + +msg54a() -> + msg54a(?MG2_MID). +msg54a(Mid) -> + SN = "tonegen/pt", + Sig = cre_IndAudSig(SN), + msg54(Mid, Sig). + +msg54b() -> + msg54b(?MG2_MID). +msg54b(Mid) -> + SN = "dg/d0", + Sig = cre_IndAudSig(SN), + msg54(Mid, Sig). + +msg54c() -> + msg54c(?MG2_MID). +msg54c(Mid) -> + SN = "ct/ct", + Sig = cre_IndAudSig(SN), + ID = 4321, + SSL = cre_IndAudSeqSigList(ID, Sig), + msg54(Mid, SSL). + +%% IndAudDigitMapDescriptor: +msg55() -> + msg55(?MG2_MID). +msg55(Mid) -> + DMN = "dialplan00", + IADMD = cre_IndAudDigitMapDesc(DMN), + IAP = cre_IndAudParam(IADMD), + APT = [IAP], + msg50(Mid, APT). + +%% IndAudStatisticsDescriptor: +msg56() -> + msg56(?MG2_MID). +msg56(Mid) -> + SN = "nt/dur", + IASD = cre_IndAudStatsDesc(SN), + IAP = cre_IndAudParam(IASD), + APT = [IAP], + msg50(Mid, APT). + +%% IndAudPackagesDescriptor: +msg57() -> + msg57(?MG2_MID). +msg57(Mid) -> + PN = "al", + PV = 1, + IAPD = cre_IndAudPkgsDesc(PN, PV), + IAP = cre_IndAudParam(IAPD), + APT = [IAP], + msg50(Mid, APT). + +%% Sum it up: +msg58_iaMediaDesc_iap(IATSD) -> + IAMD = cre_IndAudMediaDesc(IATSD), + cre_IndAudParam(IAMD). + +msg58_iaMediaDesc_iap_a() -> + PP = cre_IndAudPropertyParm("tdmc/gain"), + PPs = [PP], + IATSD = cre_IndAudTermStateDesc(PPs), + msg58_iaMediaDesc_iap(IATSD). + +msg58_iaMediaDesc_iap_b() -> + IATSD = cre_IndAudTermStateDesc([], 'NULL', asn1_NOVALUE), + msg58_iaMediaDesc_iap(IATSD). + +msg58_iaEvsDesc_iap() -> + RequestID = 1235, + PkgdName = "tonedet/std", + IAED = cre_IndAudEvsDesc(RequestID, PkgdName), + cre_IndAudParam(IAED). + +msg58_iaEvBufDesc_iap() -> + EN = "tonedet/std", + SID = 1, + IAEBD = cre_IndAudEvBufDesc(EN, SID), + cre_IndAudParam(IAEBD). + +msg58_iaSigsDesc_iap(S) -> + IASD = cre_IndAudSigsDesc(S), + cre_IndAudParam(IASD). + +msg58_iaSigsDesc_iap_a() -> + SN = "tonegen/pt", + Sig = cre_IndAudSig(SN), + msg58_iaSigsDesc_iap(Sig). + +msg58_iaSigsDesc_iap_b() -> + SN = "ct/ct", + Sig = cre_IndAudSig(SN), + ID = 4321, + SSL = cre_IndAudSeqSigList(ID, Sig), + msg58_iaSigsDesc_iap(SSL). + +msg58_iaDigMapDesc_iap() -> + DMN = "dialplan00", + IADMD = cre_IndAudDigitMapDesc(DMN), + cre_IndAudParam(IADMD). + +msg58_iaStatsDesc_iap() -> + SN = "nt/dur", + IASD = cre_IndAudStatsDesc(SN), + cre_IndAudParam(IASD). + +msg58_iaPacksDesc_iap() -> + PN = "al", + PV = 1, + IAPD = cre_IndAudPkgsDesc(PN, PV), + cre_IndAudParam(IAPD). + +msg58a() -> + msg58a(?MG2_MID). +msg58a(Mid) -> + IAMD = msg58_iaMediaDesc_iap_a(), + IAED = msg58_iaEvsDesc_iap(), + IAEBD = msg58_iaEvBufDesc_iap(), + IASiD = msg58_iaSigsDesc_iap_a(), + IADMD = msg58_iaDigMapDesc_iap(), + IAStD = msg58_iaStatsDesc_iap(), + IAPD = msg58_iaPacksDesc_iap(), + APT = [IAMD, IAED, IAEBD, IASiD, IADMD, IAStD, IAPD], + msg50(Mid, APT). + +msg58b() -> + msg58b(?MG2_MID). +msg58b(Mid) -> + IAMD = msg58_iaMediaDesc_iap_b(), + IAED = msg58_iaEvsDesc_iap(), + IAEBD = msg58_iaEvBufDesc_iap(), + IASiD = msg58_iaSigsDesc_iap_b(), + IADMD = msg58_iaDigMapDesc_iap(), + IAStD = msg58_iaStatsDesc_iap(), + IAPD = msg58_iaPacksDesc_iap(), + APT = [IAMD, IAED, IAEBD, IASiD, IADMD, IAStD, IAPD], + msg50(Mid, APT). + + +%% - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +%% Tests some of the changes in the v2 corr 1 (EmergencyOff and ModemDesc) + +%% Emergency On/Off (optional) tests +msg61(EM) -> + TS = cre_TimeNot("19990729", "22000000"), + Event = cre_ObsEv("al/of",TS), + Desc = cre_ObsEvsDesc(2222,[Event]), + NotReq = cre_NotifyReq([#megaco_term_id{id = ?A4444}],Desc), + Cmd = ?MSG_LIB:cre_Command(notifyReq, NotReq), + CmdReq = cre_CmdReq(Cmd), + CtxReq = ?MSG_LIB:cre_ContextRequest(15, EM), + ActReq = ?MSG_LIB:cre_ActionRequest(1, CtxReq, [CmdReq]), + Acts = [ActReq], + TR = ?MSG_LIB:cre_TransactionRequest(9898, Acts), + Trans = ?MSG_LIB:cre_Transaction(TR), + Mess = ?MSG_LIB:cre_Message(?VERSION, ?MG1_MID, [Trans]), + ?MSG_LIB:cre_MegacoMessage(Mess). + +msg61a() -> + msg61(false). + +msg61b() -> + msg61(true). + +msg61c() -> + msg61(asn1_NOVALUE). + + +msg62a() -> + MT = ?MSG_LIB:cre_ModemType(v18), + PP = cre_PropParm("c", "IN IP4 $ "), + MD = ?MSG_LIB:cre_ModemDescriptor([MT], [PP]), + AmmDesc = ?MSG_LIB:cre_AmmDescriptor(MD), + TermIDs = [#megaco_term_id{id = ?A4444}], + AmmReq = ?MSG_LIB:cre_AmmRequest(TermIDs, [AmmDesc]), + Cmd = ?MSG_LIB:cre_Command(addReq, AmmReq), + CmdReq = ?MSG_LIB:cre_CommandRequest(Cmd), + ActReq = ?MSG_LIB:cre_ActionRequest(2, [CmdReq]), + Acts = [ActReq], + TR = ?MSG_LIB:cre_TransactionRequest(9898, Acts), + Trans = ?MSG_LIB:cre_Transaction(TR), + Mess = ?MSG_LIB:cre_Message(?VERSION, ?MG1_MID, [Trans]), + ?MSG_LIB:cre_MegacoMessage(Mess). + +msg62b() -> + MP = +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 +Transaction = 9898 { + Context = 2 { + Add = 11111111/00000000/00000000 { + Modem[V18] { + tdmc/gain=2 + } + } + } +}", +% MC = +% "!/" ?VERSION_STR " [124.124.124.222]:55555\nT=9898{C=2{A=11111111/00000000/00000000{MD[V18]{tdmc/gain=2}}}}", + list_to_binary(MP). + +%% - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +%% Pretty RFC 3525 messages: + +%% Added Reason +rfc3525_msg1() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222] Transaction = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + Method = Restart, + Reason = 901, + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + +rfc3525_msg2() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Reply = 9998 { + Context = - { + ServiceChange = ROOT { + Services { + ServiceChangeAddress = 55555, + Profile = ResGW/1 + } + } + } +}". + + +%% Removed "," after LocalControl ending "}" +rfc3525_msg3() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 9999 { + Context = - { + Modify = A4444 { + Media { + Stream = 1 { + LocalControl { + Mode = SendReceive, + tdmc/gain=2, ; in dB, + tdmc/ec=on + } + } + }, + Events = 2222 { + al/of {strict=state} + } + } + } +}". + +%% Removed the outermost "{}" pair (before the Reply token) +rfc3525_msg4() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 9999 { + Context = - { + Modify = A4444 + } +}". + +rfc3525_msg6() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Transaction = 10000 { + Context = - { + Notify = A4444 { + ObservedEvents =2222 { + 19990729T22000000:al/of{init=false} + } + } + } +}". + + +rfc3525_msg7() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Reply = 10000 { + Context = - { + Notify = A4444 + } +}". + +rfc3525_msg8() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 10001 { + Context = - { + Modify = A4444 { + Events = 2223 { + al/on {strict=state}, + dd/ce {DigitMap=Dialplan0} + }, + Signals {cg/dt}, + DigitMap = Dialplan0 { + (0| 00|[1-7]xxx|8xxxxxxx|fxxxxxxx|exx|91xxxxxxxxxx|9011x.) + } + } + } +}". + +rfc3525_msg9() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10001 { + Context = - { + Modify = A4444 + } +}". + +rfc3525_msg10() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Transaction = 10002 { + Context = - { + Notify = A4444 { + ObservedEvents =2223 { + 19990729T22010001:dd/ce { + ds=\"916135551212\", + Meth=UM + } + } + } + } +}". + + +rfc3525_msg11() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Reply = 10002 { + Context = - { + Notify = A4444 + } +}". + +%% Added ? +rfc3525_msg12() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 10003 { + Context = $ { + Add = A4444, + Add = $ { + Media { + Stream = 1 { + LocalControl { + Mode = ReceiveOnly, + nt/jit=40 ; in ms + }, + Local { + v=0 c=IN IP4 $ m=audio $ RTP/AVP 4 a=ptime:30 v=0 c=IN IP4 $ m=audio $ RTP/AVP 0 + } + } + } + } + } +}". + +%% Added ? +rfc3525_msg13() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10003 { + Context = 2000 { + Add = A4444, + Add = A4445 { + Media { + Stream = 1 { + Local { +v=0 +o=- 2890844526 2890842807 IN IP4 124.124.124.222 +s=- +t= 0 0 +c=IN IP4 124.124.124.222 +m=audio 2222 RTP/AVP 4 +a=ptime:30 +a=recvonly + } ; RTP profile for G.723.1 is 4 + } + } + } + } +}". + +%% +%% Added ? +rfc3525_msg14() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 50003 { + Context = $ { + Add = A5555 { + Media { + Stream = 1 { + LocalControl { + Mode = SendReceive + } + } + }, + Events = 1234 { + al/of {strict=state} + }, + Signals {al/ri} + }, + Add = $ { + Media { + Stream = 1 { + LocalControl { + Mode = SendReceive, + nt/jit=40 ; in ms + }, + Local { + v=0 c=IN IP4 $ m=audio $ RTP/AVP 4 a=ptime:30 + }, + Remote { + v=0 c=IN IP4 124.124.124.222 m=audio 2222 RTP/AVP 4 a=ptime:30 + } ; RTP profile for G.723.1 is 4 + } + } + } + } +}". + +%% Added ? +rfc3525_msg15() -> +"MEGACO/" ?VERSION_STR " [125.125.125.111]:55555 Reply = 50003 { + Context = 5000 { + Add = A5555, + Add = A5556 { + Media { + Stream = 1 { + Local { + v=0 o=- 7736844526 7736842807 IN IP4 125.125.125.111 s=- t= 0 0 c=IN IP4 125.125.125.111 m=audio 1111 RTP/AVP 4 + } ; RTP profile for G723.1 is 4 + } + } + } + } +}". + +%% Added ? +rfc3525_msg16a() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 10005 { + Context = 2000 { + Modify = A4444 { + Signals {cg/rt} + }, + Modify = A4445 { + Media { + Stream = 1 { + Remote { + v=0 o=- 7736844526 7736842807 IN IP4 125.125.125.111 s=- t= 0 0 c=IN IP4 125.125.125.111 m=audio 1111 RTP/AVP 4 + } ; RTP profile for G723.1 is 4 + } + } + } + } +}". + +rfc3525_msg16b() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10005 { + Context = 2000 { + Modify = A4444, + Modify = A4445 + } +}". + +rfc3525_msg17a() -> +"MEGACO/" ?VERSION_STR " [125.125.125.111]:55555 Transaction = 50005 { + Context = 5000 { + Notify = A5555 { + ObservedEvents = 1234 { + 19990729T22020002:al/of{init=false} + } + } + } +}". + +rfc3525_msg17b() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Reply = 50005 { + Context = - { + Notify = A5555 + } +}". + +%% Removed "{ }" after Signals +rfc3525_msg17c() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 50006 { + Context = 5000 { + Modify = A5555 { + Events = 1235 { + al/on{strict=state} + }, + Signals ; to turn off ringing + } + } +}". + +rfc3525_msg17d() -> +"MEGACO/" ?VERSION_STR " [125.125.125.111]:55555 Reply = 50006 { + Context = 5000 { + Modify = A4445 + } +}". + +%% Removed "{ }" after Signals +rfc3525_msg18a() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 10006 { + Context = 2000 { + Modify = A4445 { + Media { + Stream = 1 { + LocalControl { + Mode = SendReceive + } + } + } + }, + Modify = A4444 { + Signals + } + } +}". + +rfc3525_msg18b() -> +"MEGACO/" ?VERSION_STR " [124.124.124.222]:55555 Reply = 10006 { + Context = 2000 { + Modify = A4445, + Modify = A4444 + } +}". + +rfc3525_msg19() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 50007 { + Context = - { + AuditValue = A5556 { + Audit { + Media, DigitMap, Events, Signals, Packages, Statistics + } + } + } +}". + +%% Added ? +rfc3525_msg20() -> +"MEGACO/" ?VERSION_STR " [125.125.125.111]:55555 Reply = 50007 { + Context = - { + AuditValue = A5556 { + Media { + TerminationState { + ServiceStates = InService, + Buffer = OFF + }, + Stream = 1 { + LocalControl { + Mode = SendReceive, + nt/jit=40 + }, + Local { + v=0 o=- 7736844526 7736842807 IN IP4 125.125.125.111 s=- t= 0 0 c=IN IP4 125.125.125.111 m=audio 1111 RTP/AVP 4 a=ptime:30 + }, + Remote { + v=0 o=- 2890844526 2890842807 IN IP4 124.124.124.222 s=- t= 0 0 c=IN IP4 124.124.124.222 m=audio 2222 RTP/AVP 4 a=ptime:30 + } + } + }, + Events, + Signals, + DigitMap, + Packages {nt-1, rtp-1}, + Statistics { + rtp/ps=1200, ; packets sent + nt/os=62300, ; octets sent + rtp/pr=700, ; packets received + nt/or=45100, ; octets received + rtp/pl=0.2, ; % packet loss + rtp/jit=20, + rtp/delay=40 ; avg latency + } + } + } +}". + +rfc3525_msg21a() -> +"MEGACO/" ?VERSION_STR " [125.125.125.111]:55555 Transaction = 50008 { + Context = 5000 { + Notify = A5555 { + ObservedEvents =1235 { + 19990729T24020002:al/on {init=false} + } + } + } +}". + +rfc3525_msg21b() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Reply = 50008 { + Context = - { + Notify = A5555 + } +}". + +rfc3525_msg22a() -> +"MEGACO/" ?VERSION_STR " [123.123.123.4]:55555 Transaction = 50009 { + Context = 5000 { + Subtract = A5555 { + Audit { + Statistics + } + }, + Subtract = A5556 { + Audit { + Statistics + } + } + } +}". + +%% Added ? +rfc3525_msg22b() -> +"MEGACO/" ?VERSION_STR " [125.125.125.111]:55555 Reply = 50009 { + Context = 5000 { + Subtract = A5555 { + Statistics { + nt/os=45123, ; Octets Sent + nt/dur=40 ; in seconds + } + }, + Subtract = A5556 { + Statistics { + rtp/ps=1245, ; packets sent + nt/os=62345, ; octets sent + rtp/pr=780, ; packets received + nt/or=45123, ; octets received + rtp/pl=10, ; % packets lost + rtp/jit=27, + rtp/delay=48 ; average latency + } + } + } +}". + +rfc3525_msgs() -> + [ + {msg1, rfc3525_msg1()}, + {msg2, rfc3525_msg2()}, + {msg3, rfc3525_msg3()}, + {msg4, rfc3525_msg4()}, + {msg6, rfc3525_msg6()}, + {msg7, rfc3525_msg7()}, + {msg8, rfc3525_msg8()}, + {msg9, rfc3525_msg9()}, + {msg10, rfc3525_msg10()}, + {msg11, rfc3525_msg11()}, + {msg12, rfc3525_msg12()}, + {msg13, rfc3525_msg13()}, + {msg14, rfc3525_msg14()}, + {msg15, rfc3525_msg15()}, + {msg16a, rfc3525_msg16a()}, + {msg16b, rfc3525_msg16b()}, + {msg17a, rfc3525_msg17a()}, + {msg17b, rfc3525_msg17b()}, + {msg17c, rfc3525_msg17c()}, + {msg17d, rfc3525_msg17d()}, + {msg18a, rfc3525_msg18a()}, + {msg18b, rfc3525_msg18b()}, + {msg19, rfc3525_msg19()}, + {msg20, rfc3525_msg20()}, + {msg21a, rfc3525_msg21a()}, + {msg21b, rfc3525_msg21b()}, + {msg22a, rfc3525_msg22a()}, + {msg22b, rfc3525_msg22b()} + ]. + +rfc3525_msgs_display() -> + Msgs = rfc3525_msgs(), + Fun = fun({Name, Msg}) -> + io:format("~w: ~n~s~n~n", [Name, Msg]) + end, + lists:foreach(Fun, Msgs). + +rfc3525_msgs_test() -> + put(dbg,true), + Res = rfc3525_msgs_test(megaco_pretty_text_encoder, [], 2), + erase(dbg), + io:format("~w~n", [Res]). + +rfc3525_msgs_test(Codec, Config, Ver) -> + io:format("-----------------------------------------" + "~ntesting with" + "~n Codec: ~w" + "~n Config: ~w" + "~n Version: ~w" + "~n", [Codec, Config, Ver]), + Msgs = rfc3525_msgs(), + Test = fun({N,M1}) -> + %% io:format("testing ~w: ", [N]), + io:format("~n*** testing ~w *** ~n~s~n", [N,M1]), + Bin1 = erlang:list_to_binary(M1), + case (catch Codec:decode_message(Config, Ver, Bin1)) of + {ok, M2} -> + %% io:format("d", []), + io:format("decoded:~n~p~n", [M2]), + case (catch Codec:encode_message(Config, Ver, M2)) of + {ok, Bin2} when is_binary(Bin2) -> + %% io:format("e~n", []), + io:format("encode: ~n~s~n", [erlang:binary_to_list(Bin2)]), + {N,ok}; + {ok, M3} -> + %% io:format("e~n", []), + io:format("encode: ~n~s~n", [M3]), + {N,ok}; + E -> + io:format("~n~p~n", [E]), + {N,encode_error} + end; + E -> + io:format("~n~p~n", [E]), + {N,decode_error} + end + end, + [Test(M) || M <- Msgs]. + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +skip(Reason) -> + megaco_codec_test_lib:skip(Reason). + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +decode_message(Codec, DynamicDecode, Conf, Bin) -> + megaco_codec_test_lib:decode_message(Codec, DynamicDecode, ?VERSION, + Conf, Bin). +encode_message(Codec, Conf, Msg) -> + megaco_codec_test_lib:encode_message(Codec, ?VERSION, Conf, Msg). + +test_msgs(Codec, DynamicDecode, Conf, Msgs) -> + megaco_codec_test_lib:test_msgs(Codec, DynamicDecode, ?VERSION, Conf, + fun chk_MegacoMessage/2, Msgs). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +decode_mini_message(Codec, Conf, Bin) -> + Codec:decode_mini_message(Conf, dynamic, Bin). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +chk_MegacoMessage(M1, M2) -> + ?MSG_LIB:chk_MegacoMessage(M1, M2). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +cre_MegacoMessage(Mess) -> + ?MSG_LIB:cre_MegacoMessage(Mess). + +cre_MegacoMessage(V, Mid, Body) -> + Mess = ?MSG_LIB:cre_Message(V, Mid, Body), + ?MSG_LIB:cre_MegacoMessage(Mess). + +cre_AuthHeader() -> + SecParmIdx = [239, 205, 171, 137], + SeqNum = [18, 52, 86, 120], + AD = [18, 52, 86, 120, 137, 171, 205, 239, 118, 84, 50, 16], + cre_AuthHeader(SecParmIdx, SeqNum, AD). + +cre_Msg(Mid, Body) -> + cre_Msg(?VERSION, Mid, Body). + +cre_Msg(V, Mid, Body) -> + ?MSG_LIB:cre_Message(V, Mid, Body). + +cre_AuthHeader(Idx, Num, D) -> + ?MSG_LIB:cre_AuthenticationHeader(Idx, Num, D). + +cre_TransId(TransId) -> + ?MSG_LIB:cre_TransactionId(TransId). + +cre_Trans(Trans) -> + ?MSG_LIB:cre_Transaction(Trans). + +cre_TransReq(TransId, Actions) -> + ?MSG_LIB:cre_TransactionRequest(TransId, Actions). + +cre_TransRep(TransId, Actions) -> + ?MSG_LIB:cre_TransactionReply(TransId, Actions). + +cre_TransAck(First, Last) -> + ?MSG_LIB:cre_TransactionAck(First, Last). + +cre_ActReq(CtxId, CmdReqs) -> + ?MSG_LIB:cre_ActionRequest(CtxId, CmdReqs). + +cre_ActRep(CtxId, CmdReply) -> + ?MSG_LIB:cre_ActionReply(CtxId, CmdReply). + +cre_CtxID(Id) -> + ?MSG_LIB:cre_ContextID(Id). + +%% Ind Aud related: + +cre_IndAudParam(IAP) -> + ?MSG_LIB:cre_IndAuditParameter(IAP). + +cre_IndAudMediaDesc(D) -> + ?MSG_LIB:cre_IndAudMediaDescriptor(D). + +cre_IndAudStreamDesc(SID, SP) -> + ?MSG_LIB:cre_IndAudStreamDescriptor(SID, SP). + +cre_IndAudStreamParms(LCD) -> + ?MSG_LIB:cre_IndAudStreamParms(LCD). + +cre_IndAudLocalControlDesc(SM, RV, RG, PP) -> + ?MSG_LIB:cre_IndAudLocalControlDescriptor(SM, RV, RG, PP). + +cre_IndAudPropertyParm(Name) -> + ?MSG_LIB:cre_IndAudPropertyParm(Name). + +cre_IndAudTermStateDesc(PP) -> + ?MSG_LIB:cre_IndAudTerminationStateDescriptor(PP). + +cre_IndAudTermStateDesc(PP, EBC, SS) -> + ?MSG_LIB:cre_IndAudTerminationStateDescriptor(PP, EBC, SS). + +cre_IndAudEvsDesc(RID, PN) + when is_integer(RID) -> + ?MSG_LIB:cre_IndAudEventsDescriptor(RID, PN). + +cre_IndAudEvBufDesc(EN, SID) -> + ?MSG_LIB:cre_IndAudEventBufferDescriptor(EN, SID). + +cre_IndAudSigsDesc(D) -> + ?MSG_LIB:cre_IndAudSignalsDescriptor(D). + +cre_IndAudSig(SN) -> + ?MSG_LIB:cre_IndAudSignal(SN). + +cre_IndAudSeqSigList(ID, SL) -> + ?MSG_LIB:cre_IndAudSeqSigList(ID, SL). + +cre_IndAudDigitMapDesc(DMN) -> + ?MSG_LIB:cre_IndAudDigitMapDescriptor(DMN). + +cre_IndAudStatsDesc(SN) -> + ?MSG_LIB:cre_IndAudStatisticsDescriptor(SN). + +cre_IndAudPkgsDesc(PN, PV) -> + ?MSG_LIB:cre_IndAudPackagesDescriptor(PN, PV). + +%% Parameter related +cre_PropParm(Name, Val) -> + ?MSG_LIB:cre_PropertyParm(Name, [Val]). + + +%% Statistics related +cre_StatsParm(Name, Val) -> + ?MSG_LIB:cre_StatisticsParameter(Name, [Val]). + + +% Event related +cre_EvParm(Name, Val) -> + ?MSG_LIB:cre_EventParameter(Name, Val). + +cre_ObsEv(Name, Not) -> + ?MSG_LIB:cre_ObservedEvent(Name, Not). +cre_ObsEv(Name, Not, Par) -> + ?MSG_LIB:cre_ObservedEvent(Name, Par, Not). + +cre_ReqedEv(Name) -> + ?MSG_LIB:cre_RequestedEvent(Name). +cre_ReqedEv(Name, Action) -> + ?MSG_LIB:cre_RequestedEvent(Name, Action). + + +cre_ObsEvsDesc(Id, EvList) -> + ?MSG_LIB:cre_ObservedEventsDescriptor(Id, EvList). + +cre_EvsDesc(Id, EvList) -> + ?MSG_LIB:cre_EventsDescriptor(Id, EvList). + + +%% Service change related +cre_SvcChParm(M, A, R, P) -> + ?MSG_LIB:cre_ServiceChangeParm(M, A, P, R). + +cre_SvcChResParm(A, P) -> + ?MSG_LIB:cre_ServiceChangeResParm(A, P). + +cre_SvcChReq(Tids, P) -> + ?MSG_LIB:cre_ServiceChangeRequest(Tids, P). + +cre_SvcChProf(Name, Ver) -> + ?MSG_LIB:cre_ServiceChangeProfile(Name, Ver). + +cre_SvcChRep(Tids, Res) -> + ?MSG_LIB:cre_ServiceChangeReply(Tids, Res). + + +%% Stream related +cre_StreamParms(Lcd) -> + ?MSG_LIB:cre_StreamParms(Lcd). +cre_StreamParms(Lcd, Ld) -> + ?MSG_LIB:cre_StreamParms(Lcd, Ld). +cre_StreamParms(Lcd, Ld, Rd) -> + ?MSG_LIB:cre_StreamParms(Lcd, Ld, Rd). +cre_StreamParmsL(Ld) -> + ?MSG_LIB:cre_StreamParms(asn1_NOVALUE, Ld, asn1_NOVALUE). +cre_StreamParmsR(Rd) -> + ?MSG_LIB:cre_StreamParms(asn1_NOVALUE, asn1_NOVALUE, Rd). + +cre_StreamDesc(Id, P) -> + ?MSG_LIB:cre_StreamDescriptor(Id, P). + + +%% "Local" related +cre_LocalControlDesc(Mode) -> + ?MSG_LIB:cre_LocalControlDescriptor(Mode). +cre_LocalControlDesc(Mode, Parms) -> + ?MSG_LIB:cre_LocalControlDescriptor(Mode, Parms). + +cre_LocalRemoteDesc(Grps) -> + ?MSG_LIB:cre_LocalRemoteDescriptor(Grps). + + +%% DigitMap related +cre_DigitMapDesc() -> + ?MSG_LIB:cre_DigitMapDescriptor(). +cre_DigitMapDesc(NameOrVal) -> + ?MSG_LIB:cre_DigitMapDescriptor(NameOrVal). +cre_DigitMapDesc(Name, Val) -> + ?MSG_LIB:cre_DigitMapDescriptor(Name, Val). + +cre_DigitMapValue(Body) -> + ?MSG_LIB:cre_DigitMapValue(Body). + +cre_DigitMapValue(Body, Start, Short, Long) -> + ?MSG_LIB:cre_DigitMapValue(Start, Short, Long, Body). + +%% Media related +cre_MediaDesc(SD) when is_record(SD, 'StreamDescriptor') -> + cre_MediaDesc([SD]); +cre_MediaDesc(SDs) -> + ?MSG_LIB:cre_MediaDescriptor(SDs). + + +%% Notify related +cre_NotifyReq(Tids, EvsDesc) -> + ?MSG_LIB:cre_NotifyRequest(Tids, EvsDesc). + +cre_NotifyRep(Tids) -> + ?MSG_LIB:cre_NotifyReply(Tids). + + +%% Subtract related +cre_SubReq(Tids, Desc) -> + ?MSG_LIB:cre_SubtractRequest(Tids, Desc). + + +%% Audit related +cre_AuditDesc(Tokens) -> + ?MSG_LIB:cre_AuditDescriptor(Tokens). + +cre_AuditDesc(Tokens, PropertTokens) -> + ?MSG_LIB:cre_AuditDescriptor(Tokens, PropertTokens). + +cre_AuditReq(Tid, Desc) -> + ?MSG_LIB:cre_AuditRequest(Tid, Desc). + +cre_AuditRes(Tid, Res) -> + ?MSG_LIB:cre_AuditResult(Tid, Res). + + +%% AMM/AMMS related +cre_AmmReq(Tids, Descs) -> + ?MSG_LIB:cre_AmmRequest(Tids, Descs). + +cre_AmmsReply(Tids) -> + ?MSG_LIB:cre_AmmsReply(Tids). +cre_AmmsReply(Tids, Descs) -> + ?MSG_LIB:cre_AmmsReply(Tids, Descs). + + +%% Command related +%% cre_command(Tag, Req) -> +%% ?MSG_LIB:cre_Command(Tag, Req). + +cre_CmdReq(Cmd) -> + ?MSG_LIB:cre_CommandRequest(Cmd). + + +%% Actions related +cre_ReqedActs(DmName) -> + EDM = ?MSG_LIB:cre_EventDM(DmName), + ?MSG_LIB:cre_RequestedActions(EDM). + + +%% Signal related +cre_Sig(Name) -> + ?MSG_LIB:cre_Signal(Name). + + +%% Others +cre_TimeNot(D,T) -> + ?MSG_LIB:cre_TimeNotation(D, T). + +cre_PkgsItem(Name, Ver) -> + ?MSG_LIB:cre_PackagesItem(Name, Ver). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +flex_init(Config) -> + megaco_codec_flex_lib:init(Config). + +flex_finish(Config) -> + megaco_codec_flex_lib:finish(Config). + +flex_scanner_conf(Config) -> + megaco_codec_flex_lib:scanner_conf(Config). + +start_flex_scanner() -> + megaco_codec_flex_lib:start(). + +stop_flex_scanner(Pid) -> + megaco_codec_flex_lib:stop(Pid). + + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +t(F,A) -> + p(printable(get(severity),trc),trc,F,A). + +d(F,A) -> + p(printable(get(severity),dbg),dbg,F,A). + +l(F,A) -> + p(printable(get(severity),log),log,F,A). + +e(F,A) -> + p(printable(get(severity),err),err,F,A). + + +printable(trc,_) -> + true; +printable(dbg,trc) -> + false; +printable(dbg,_) -> + true; +printable(log,log) -> + true; +printable(log,err) -> + true; +printable(err,err) -> + true; +printable(_,_) -> + false. + + +p(true,L,F,A) -> + io:format("~s: " ++ F ++ "~n", [image_of(L)|A]); +p(_,_,_,_) -> + ok. + +image_of(trc) -> + "T"; +image_of(dbg) -> + "D"; +image_of(log) -> + "L"; +image_of(err) -> + "E"; +image_of(L) -> + io_lib:format("~p",[L]). + + |