src/m3ua_example.erl

-module(m3ua_example).

-include("osmo_util.hrl").
-include("m3ua.hrl").
-include("sccp.hrl").

-export([init/0]).

-record(loop_dat, {
	 scrc_pid,
	 m3ua_pid
	}).

init() ->
	% start the M3UA link to the SG
	Opts = [{user_pid, self()}, {sctp_remote_ip, {192,168,104,2}}, {sctp_remote_port, 2905},
		{sctp_local_port, 60180}, {user_fun, fun m3ua_tx_to_user/2}, {user_args, self()}],
	{ok, M3uaPid} = m3ua_core:start_link(Opts),
	% instantiate SCCP routing instance
	{ok, ScrcPid} = sccp_scrc:start_link([{mtp_tx_action, {callback_fn, fun scrc_tx_to_mtp/2, M3uaPid}}]),
	loop(#loop_dat{m3ua_pid = M3uaPid, scrc_pid = ScrcPid}).

loop(L) ->
	io:format("Example: Entering main loop~n"),
	receive
		{m3ua_prim, Prim} ->
			io:format("Example: Rx M3UA Prim ~p~n", [Prim]),
			rx_m3ua_prim(Prim, L);
		Stop ->
			io:format("Example: Received ~p~n", [Stop]),
			exit(stop_received)
	end,
	loop(L).
	

scrc_tx_to_mtp(Prim, Args) ->
	M3uaPid = Args,
	gen_fsm:send_event(M3uaPid, Prim).

m3ua_tx_to_user(Prim, Args) ->
	UserPid = Args,
	UserPid ! {m3ua_prim, Prim}.


rx_m3ua_prim(#primitive{subsystem = 'M', gen_name = 'SCTP_ESTABLISH', spec_name = confirm}, L) ->
	gen_fsm:send_event(L#loop_dat.m3ua_pid, osmo_util:make_prim('M','ASP_UP',request));

rx_m3ua_prim(#primitive{subsystem = 'M', gen_name = 'ASP_UP', spec_name = confirm}, L) ->
	gen_fsm:send_event(L#loop_dat.m3ua_pid, osmo_util:make_prim('M','ASP_ACTIVE',request));

rx_m3ua_prim(#primitive{subsystem = 'M', gen_name = 'ASP_ACTIVE', spec_name = confirm}, L) ->
	io:format("Example: M3UA now active and ready~n"),
	tx_sccp_udt(L#loop_dat.scrc_pid);

rx_m3ua_prim(P, _L) ->
	io:format("Example: Ignoring M3UA prim ~p~n", [P]),
	ok.


tx_sccp_udt(ScrcPid) ->
	CallingP = #sccp_addr{ssn = ?SCCP_SSN_MSC, point_code = osmo_util:pointcode2int(itu, {1,2,2})},
	CalledP = #sccp_addr{ssn = ?SCCP_SSN_HLR, point_code = osmo_util:pointcode2int(itu, {1,1,1})},
	Data = <<1,2,3,4>>,
	Opts = [{protocol_class, 0}, {called_party_addr, CalledP},
		{calling_party_addr, CallingP}, {user_data, Data}],
	io:format("Example: Sending N-UNITDATA.req to SCRC~n"),
	gen_fsm:send_event(ScrcPid, osmo_util:make_prim('N','UNITDATA',request,Opts)).