diff options
Diffstat (limited to 'lib/megaco/test/megaco_mess_otp8212_test.erl')
| -rw-r--r-- | lib/megaco/test/megaco_mess_otp8212_test.erl | 181 |
1 files changed, 181 insertions, 0 deletions
diff --git a/lib/megaco/test/megaco_mess_otp8212_test.erl b/lib/megaco/test/megaco_mess_otp8212_test.erl new file mode 100644 index 0000000000..109886ebc4 --- /dev/null +++ b/lib/megaco/test/megaco_mess_otp8212_test.erl @@ -0,0 +1,181 @@ +%% +%% %CopyrightBegin% +%% +%% Copyright Ericsson AB 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: A fun implementation of user callbacks +%%---------------------------------------------------------------------- + +-module(megaco_mess_otp8212_test). + +-behaviour(megaco_user). + +%% Megaco user callback exports +-export([ + handle_connect/2, handle_connect/3, + handle_disconnect/3, + %% handle_syntax_error/3, handle_syntax_error/4, + %% handle_message_error/3, handle_message_error/4, + handle_trans_request/3, %% handle_trans_request/4, + %% handle_trans_long_request/3, handle_trans_long_request/4, + %% handle_trans_reply/4, handle_trans_reply/5, + %% handle_trans_ack/4, handle_trans_ack/5, + handle_unexpected_trans/3, handle_unexpected_trans/4 %% , + %% handle_trans_request_abort/4, handle_trans_request_abort/5, + %% handle_segment_reply/5, handle_segment_reply/6 + ]). + +%% Megaco encoder callback exports +-export([ + encode_message/3, + decode_message/3 + ]). + +%% Megaco transport callback exports +-export([ + send_message/2 + ]). + +-include("megaco_test_lib.hrl"). +-include_lib("megaco/include/megaco.hrl"). +-include_lib("megaco/include/megaco_message_v1.hrl"). + + +%%---------------------------------------------------------------------- +%% Megaco user callback +%%---------------------------------------------------------------------- + +%% -- handle_connect/2 -- + +handle_connect(_, _) -> + %% i("handle_connect -> entry"), + ok. + +handle_connect(_, _, otp8212_extra) -> + %% i("handle_connect -> entry"), + ok; +handle_connect(_, _, {otp8212_extra, _}) -> + %% i("handle_connect -> entry"), + ok. + +handle_disconnect(Conn, _, {user_disconnect, {otp8212_done, Pid}}) -> + %% i("handle_disconnect -> entry"), + Pid ! {disconnected, Conn}, + ok. + +handle_trans_request(_, _, _) -> %% incoming SC + %% i("handle_trans_request -> entry"), + {discard_ack, ["sc reply"]}. + +handle_unexpected_trans(_ConnHandle, _ProtocolVersion, _Trans) -> +%% i("handle_unexpected_trans -> entry with" +%% "~n ConnHandle: ~p" +%% "~n ProtocolVersion: ~p" +%% "~n Trans: ~p", [ConnHandle, ProtocolVersion, Trans]), + ok. +handle_unexpected_trans(_ConnHandle, _ProtocolVersion, _Trans, {otp8212_extra, Pid}) -> +%% i("handle_unexpected_trans -> entry with" +%% "~n ConnHandle: ~p" +%% "~n ProtocolVersion: ~p" +%% "~n Trans: ~p", [ConnHandle, ProtocolVersion, Trans]), + Pid ! {handle_unexpected_trans, otp8212_extra}, + ok. + + +%%---------------------------------------------------------------------- +%% Megaco encoder callback +%%---------------------------------------------------------------------- + + +%% Should only be encoding MGC's outgoing request, which we expect +%% has transaction id = 1. + +-define(REQUEST(Id, A), + #'MegacoMessage' + {mess + = #'Message' + {version = 1, + mId = {deviceName,"MGC"}, + messageBody + = {transactions, [{transactionRequest, + #'TransactionRequest'{transactionId = Id, + actions = A}}]}}}). + +-define(REPLY(A), + #'MegacoMessage' + {mess + = #'Message' + {version = 1, + mId = {deviceName,"MGC"}, + messageBody + = {transactions, + [{transactionReply, + #'TransactionReply'{transactionResult + = {actionReplies, [A]}}}]}}}). + +request() -> + list_to_binary("!/1 MGC T=1{C=-{SC=ROOT{SV{MT=RS,RE=\"901\"}}}}"). + +sc_reply() -> + list_to_binary("!/1 MGC P=19731{C=-{SC=root}}"). + +encode_message(_, _, ?REQUEST(1, "action request")) -> + %% i("encode_message -> entry with request"), + {ok, request()}; + +encode_message(_, _, ?REPLY("sc reply")) -> + %% i("encode_message -> entry with reply"), + {ok, sc_reply()}. + +decode_message(_, V248, Bin) -> + %% i("decode_message -> entry"), + megaco_compact_text_encoder:decode_message([], V248, Bin). + + +%%---------------------------------------------------------------------- +%% Megaco transport callback +%%---------------------------------------------------------------------- + +%% Outgoing SC reply. +%% send_message(otp8212_scr, _) -> +%% i("send_message(scr) -> entry"), +%% ok; + +%% Outgoing request: fake reception of the the reply. +send_message({RH, ControlPid, _, WrongMidStr}, _) -> + %% i("send_message -> entry"), + spawn(fun() -> receive_reply(200, RH, ControlPid, WrongMidStr) end), + ok. + +receive_reply(After, RH, ControlPid, WrongMidStr) -> + timer:sleep(After), + %% i("receive_reply -> issue reply"), + megaco:process_received_message(RH, ControlPid, + otp8212_sendhandle, + reply(WrongMidStr), + {otp8212_extra, ControlPid}). + +reply(WrongMidStr) -> %% note "wrong" mid. + list_to_binary("!/1 " ++ WrongMidStr ++ " P=1{C=-{SC=root}}"). + +%% i(F) -> +%% i(F, []). + +%% i(F, A) -> +%% io:format(F ++ "~n", A). |