%% Author: mark
%% Created: Sep 15, 2009
%% Description: TODO: Add description to freeswitch_callback
-module(freeswitch_callback).

-behaviour(gen_server).

-record(st, {fsnode, pbxpid}).

-export([start/3, terminate/2, code_change/3, init/1,
	handle_call/3, handle_cast/2, handle_info/2, fetch_handler/1,
	xml_fetch/1]).

start(Node, Section, Pid) ->
    gen_server:start(?MODULE, [Node, Section, Pid], []).

init([Node, Section, Pid]) ->
	io:format( "freeswitch_callback:init( [Node=~w, Section=~w, Pid=~w])~n", [Node, Section, Pid] ),
    {ok, #st{fsnode=Node, pbxpid=Pid}}.

terminate(_Reason, _State) ->
    ok.

code_change(_OldVsn, State, _Extra) ->
    {ok, State}.

%%
%% Callback for freeswitch:start_fetch_handler() called in freeswitch_bind:init()
%%
fetch_handler( FreeswitchNode ) ->
	receive
		{ nodedown, Node } ->
			io:format( "freeswitch_callback:fetch_handler() Node ~w is down~n", [Node] ),
			ok;
		{ fetch, Section, Tag, Key, Value, FetchId, Params } ->
			io:format( "freeswitch_callback:fetch_handler() Invoking xml_fetch()~n" ),
		    {ok, Xml} = xml_fetch( {fetch, Section, Tag, Key, Value, Params} ),
			io:format( "freeswitch_callback:fetch_handler() Sending reply to FreeswitchNode ~w: ~s~n", [FreeswitchNode, Xml] ),
			{api, FreeswitchNode} ! {fetch_reply, FetchId, Xml},
			%% FreeswitchNode ! { fetch_reply, FetchId, Xml },
			io:format( "freeswitch_callback:fetch_handler() Reply sent~n" )
%%			io:format( "freeswitch_callback:fetch_handler() Waiting for confirmation reply was received~n"),
%%			receive
%%				ok ->
%%					io:format( "freeswitch_callback:fetch_handler() Reply receipt confirmed~n" ),
%%					ok;
%%				{error, Reason} ->
%%					io:format( "freeswitch_callback:fetch_handler() Reply receipt failed due to error ~s~n", [Reason] ),
%%					{error, Reason}
%%			end
	end,
	{ ok } = fetch_handler( FreeswitchNode ),
	{ ok }.

dumpParams( Params ) ->
	case Params of
		[] ->
			ok;
		[ H | T ] ->
			case H of
				undefined ->
					io:format( "    undefined~n" );
				{ Key, Value } ->
					io:format( "    ~s=\"~s\"~n", [Key, Value ] )
			end,
			dumpParams( T )
	end.

%%
%%	Configuration handler for mod_sofia.
%%
xml_fetch({fetch, configuration, "configuration", "name", "sofia.conf", Params}) ->
	
	io:format( "freeswitch_callback:handle_call( {fetch, configuration, Tag=\"configuration\", Key=\"name\", Value=\"sofia.conf\", Params=...} )~n"),
	dumpParams( Params ),
	Xml =
"<document type=\"freeswitch/xml\">
	<section name=\"configuration\">
		<configuration name=\"sofia.conf\" description=\"sofia Endpoint\">
			<global_settings>
				<param name=\"log-level\" value=\"0\" />
				<param name=\"auto-restart\" value=\"false\" />
				<param name=\"debug-presence\" value=\"0\" />
			</global_settings>
			<settings>
				<!-- ADD parameters here -->
			</settings>
			<profiles>
				<profile name=\"external\">
					<gateways>
						<!-- Add gateways here -->
						<gateway name=\"asterlink.com\">
							<param name=\"\" value=\"\" />
							<param name=\"\" value=\"\" />
							<param name=\"\" value=\"\" />
							<param name=\"\" value=\"\" />
							<param name=\"\" value=\"\" />
							<param name=\"\" value=\"\" />
							<param name=\"\" value=\"\" />
						</gateway>
					</gateways>
					<aliases>
						<alias name=\"outbound\" />
						<alias name=\"nat\" />
					</aliases>
					<domains>
						<domain name=\"all\" alias=\"false\" parse=\"true\" />
					</domains>
					<settings>
						<param name=\"debug\" value=\"0\" />
						<param name=\"sip-trace\" value=\"no\" />
						<param name=\"rfc2833-pt\" value=\"101\" />
						<param name=\"sip-port\" value=\"6080\" />
						<param name=\"dialplan\" value=\"XML\" />
						<param name=\"context\" value=\"public\" />
						<param name=\"dtmf-duration\" value=\"100\" />
						<param name=\"codec-prefs\" value=\"PCMU,PCMA,GSM\" />
						<param name=\"hold-music\" value=\"local_stream://moh\" />
						<param name=\"rtp-timer-name\" value=\"soft\" />
						<!--param name=\"enable-100rel\" value=\"true\" / -->
						<param name=\"manage-presence\" value=\"false\" />
						<!-- param name=\"dbname\" value=\"share_presence\" / -->
						<!-- param name=\"presence-hosts\" value=\"10.77.0.254\" / -->
						<!-- param name=\"force-register-domain\" value=\"10.77.0.254\" / -->
						<!-- param name=\"force-register-db-domain\" value=\"10.77.0.254\" / -->
						<!-- param name=\"aggressive-nat-detection\" value=\"true\" / -->
						<param name=\"inbound-codec-negotiation\" value=\"generous\" />
						<param name=\"nonce-ttl\" value=\"60\" />
						<param name=\"auth-calls\" value=\"false\" />
						<param name=\"rtp-timeout-sec\" value=\"1800\" />
						<param name=\"rtp-ip\" value=\"10.77.0.254\" />
						<param name=\"sip-ip\" value=\"10.77.0.254\" />
						<param name=\"ext-rtp-ip\" value=\"stun:stun.freeswitch.org\" />
						<param name=\"ext-sip-ip\" value=\"stun:stun.freeswitch.org\" />
						<param name=\"rtp-timout-sec\" value=\"300\" />
						<param name=\"rtp-hold-timeout-sec\" value=\"1800\" />
						<!-- param name=\"enable-3pcc\" value=\"true\" / -->
						<param name=\"tls-bind-params\" value=\"transport=tls\" />
						<param name=\"tls-sip-port\" value=\"6081\" />
						<param name=\"tls-cert-dir\" value=\"/opt/freeswitch/conf/ssl\" />
						<param name=\"tls-version\" value=\"tlsv1\" />
						<!-- param name=\"rtp-autoflush-during-bridge\" value=\"false\" / -->
						<!-- param name=\"rtp-rewrite-timestamp\" value=\"true\" / -->
						<!-- param name=\"pass-rfc2833\" value=\"true\" / -->
						<!-- param name=\"odbc-dsn\" value=\"dsn:user:pass\" / -->
						<!-- param name=\"inbound-bypass-media\" value=\"true\" / -->
						<!-- param name=\"inbound-proxy-media\" value=\"true\" / -->
						<!-- param name=\"inbound-late-negotiation\" value=\"true\" / -->
						<!-- param name=\"accept-blind-reg\" value=\"true\" / -->
						<!-- param name=\"accept-blind-auth\" value=\"true\" / -->
						<!-- param name=\"suppress-cng\" value=\"true\" / -->
						<param name=\"nonce-ttl\" value=\"60\" />
						<!-- param name=\"disable-transcoding\" value=\"true\" / -->
						<!-- param name=\"disable-transfer\" value=\"true\" / -->
						<!-- param name=\"NDLB-broken-auth-hash\" value=\"true\" / -->
						<!-- param name=\"NDLB-received-in-nat-reg-contact\" value=\"true\" / -->
						<param name=\"auth-calls\" value=\"true\" />
						<param name=\"inbound-reg-force-matching-username\" value=\"true\" />
						<param name=\"auth-all-packets\" value=\"false\" />
						<!-- param name=\"ext-rtp-ip\" value=\"stun.freeswitch.org\" / -->
						<!-- param name=\"ext-sip-ip\" value=\"stun.freeswitch.org\" / -->
						<param name=\"rtp-timeout-sec\" value=\"300\" />
						<param name=\"rtp-hold-timeout-sec\" value=\"1800\" />
						<!-- param name=\"vad\" value=\"in\" / -->
						<!-- param name=\"vad\" value=\"out\" / -->
						<!-- param name=\"vad\" value=\"both\" / -->
						<!-- param name=\"alias\" value=\"sip:10.77.0.231:5555\" / -->
						<param name=\"force-register-domain\" value=\"10.77.0.231\" />
						<param name=\"force-register-db-domain\" value=\"10.77.0.231\" />
						<!-- param name=\"force-subscription-expires\" value=\"60\" / -->
						<!-- param name=\"disable-transfer\" value=\"true\" / -->
						<!-- param name=\"disable-register\" value=\"true\" / -->
						<!-- param name=\"enable-3pcc\" value=\"true\" / -->
						<!-- param name=\"NDLB-force-rport\" value=\"true\" / -->
						<param name=\"challenge-realm\" value=\"auto_from\" />
						<!-- param name=\"disable-rtp-auto-adjust\" value=\"true\" / -->
						<!-- param name=\"inbound-use-callid-as-uuid\" value=\"true\" / -->
						<!-- param name=\"outbound-use-uuid-as-callid\" value=\"true\" / -->
						<!-- param name=\"rtp-autofix-timing\" value=\"false\" / -->
						<!-- param name=\"auto-rtp-bugs\" data=\"clear\" / -->
						<!-- param name=\"disable-srv\" value=\"false\" / -->
						<!-- param name=\"disable-naptr\" value=\"false\" / -->
						<!-- param name=\"timer-T1\" value=\"800\" / -->
						<!-- param name=\"timer-T1X64\" value=\"32000\" / -->
						<!-- param name=\"timer-T2\" value=\"4000\" / -->
						<!-- param name=\"timer-T4\" value=\"4000\" / -->
					</settings>
				</profile>
			</profiles>
		</configuration>
	</section>
</document>",
	{ok, Xml };

%%
%%	Configuration handler replies that the requested document section, tag, and key are not
%%	found.
%%
xml_fetch({fetch, configuration, Tag, Key, Value, Params}) ->
	io:format( "freeswitch_callback:handle_call( {fetch, configuration, Tag=~s, Key=~s, Value=~s, Params=...} )~n",
		[Tag, Key, Value]),
	dumpParams( Params ),
	Xml =
"<document type=\"freeswitch/xml\">
	<section name=\"result\">
		<result status=\"not found\" />
	</section>
</document>",
	{ok, Xml };

%%
%%	Directory handler replies that the requested document section, tag, and key are not
%%	found.
%%
xml_fetch({fetch, directory, Tag, Key, Value, Params}) ->
	io:format( "freeswitch_callback:xml_fetch( {fetch, directory, Tag=~s, Key=~s, Value=~s, Params=...} )~n",
		[Tag, Key, Value]),
	dumpParams( Params ),
	Xml =
"<document type=\"freeswitch/xml\">
	<section name=\"result\">
		<result status=\"not found\" />
	</section>
</document>",
	{ok, Xml };

%%
%%	Dialplan handler replies that the requested document section, tag, and key are not
%%	found.
%%
xml_fetch({fetch, dialplan, Tag, Key, Value, Params}) ->
	io:format( "freeswitch_callback:xml_fetch( {fetch, dialplan, Tag=~s, Key=~s, Value=~s, Params=...} )~n",
		[Tag, Key, Value]),
	dumpParams( Params ),
	Xml =
"<document type=\"freeswitch/xml\">
	<section name=\"result\">
		<result status=\"not found\" />
	</section>
</document>",
	{ok, Xml };

%%
%%	Default handler replies that the requested document section, tag, and key are not
%%	found.
%%
xml_fetch({fetch, Section, Tag, Key, Value, Params}) ->
	io:format( "freeswitch_callback:xml_fetch( {fetch, Section=~w, Tag=~s, Key=~s, Value=~s, Params=...} )~n",
		[Section, Tag, Key, Value]),
	dumpParams( Params ),
	Xml =
"<document type=\"freeswitch/xml\">
	<section name=\"result\">
		<result status=\"not found\" />
	</section>
</document>",
	{ok, Xml };

%%
%%	If the request isn't recognized, just log it.
%%
xml_fetch( Request ) ->
	io:format( "freeswitch_callback:xml_fetch( Request=~w ) not recognized~n",
		[Request]),
	Xml =
"<document type=\"freeswitch/xml\">
	<section name=\"result\">
		<result status=\"not found\" />
	</section>
</document>",
	{ok, Xml }.


%%
%%	If the request isn't recognized, just log it and do nothing.
%%
handle_call(Request, _From, State) ->
    io:format("freeswitch_callback:handle_call( ~w, _From, State) unrecognized request~n",
		[Request]),
    {reply, {error, unrecognized_request}, State}.

handle_cast(Message, State) ->
    error_logger:error_msg("~p received unrecognized cast ~p~n",
			   [self(), Message]),
    {noreply, State}.

handle_info(Info, State) ->
	io:format( "freeswitch_callback:handle_info() Info=~w~n", [Info]),
    {noreply, State}.

%%handle_info({fetch, Section, Tag, Key, Value, FetchID, Params}, #st{fsnode=Node, pbxpid=Pid}=State) ->
%%    {ok, XML} = gen_server:call(Pid, {fetch, Section, Tag, Key, Value, Params}),
%%    {api, Node} ! {fetch_reply, FetchID, XML},
%%    receive
%%	ok ->
%%	    {noreply, State};
%%	{error, Reason} ->
%%	    {stop, {error, Reason}, State}
%%    end.
