Hi,
the presentation is from before http_async_client module was written so
the example configuration does not apply straight once you add the http
async request.
> if (is_method("INVITE")) {
> #Push notification
> route(SUSPEND);
> }
>
You don't have to suspend the transaction here, http_async_query will do it
for you if you have to send the push.
I would rather do
if (is_method("INVITE")) {
#Push notification
route(SENDPUSH);
}
In the SENDPUSH route suspend the transaction
$http_req(suspend) = 1;
Then in the HTTP_REPLY route process the return code and either suspend
again the transaction or reply an error message:
route[HTTP_REPLY] {
if ($http_ok && $http_rs == 200) {
route(SUSPEND);
} else if($http_rs == 415) {
send_reply("415", "The other party does not support video
calling!");
} else {
xlog("L_ALERT", "route[HTTP_REPLY]: error $http_err)\n");
send_reply("500", "Server Error");
}
}
Hope this helps.
Cheers,
Federico
On Sat, Apr 27, 2024 at 6:38 PM Masud Muborakshohi via sr-users <
[email protected]> wrote:
> Thank you for quick response!
> But when I leave suspending enabled ($http_req(suspend) = 1, default) the
> call logic does not work, when after receiving a register (with id_index
> and id_label) from party B, the call should continue. I built this
> functionality based on your presentation
> https://www.voztovoice.org/sites/default/files/KamilioWorld2015%20-Federico.Cabiddu-TSILO.pdf
> .
> I’ll give you my routes so that the picture is complete:
> request_route {
> ...
> if (is_method("INVITE")) {
> #Push notification
> route(SUSPEND);
> }
> ...
> }
>
> # Handle SIP registrations
> route[REGISTRAR] {
> if (!is_method("REGISTER")) return;
> ...
> if (!save("location")) {
> sl_reply_error();
> }
> ...
> #Push notification
> if ( (is_method("REGISTER")) && (($hdr(Expires) != "0") ||
> !(($hdr(Contact) =~ "expires=0"))) && ($hdr(id_index) != "" &&
> $hdr(id_label) != "") ) {
> xlog("L_INFO", "New $rm ru=$ru tu=$tu \n");
> route(JOIN);
> }
>
> exit;
> }
>
> #Push notification
> route[SUSPEND] {
> if(!t_is_set("failure_route")) t_on_failure("MANAGE_FAILURE");
> send_reply("100", "Suspending");
> if ( !t_suspend() )
> {
> xlog("L_ERROR","[SUSPEND] failed suspending trasaction
> [$T(id_index):$T(id_label)]\n");
> send_reply("501", "Suspending error");
> exit;
> }
> xlog("L_INFO","[SUSPEND] suspended transaction
> [$T(id_index):$T(id_label)] $fU=> $rU\n");
> $sht(vtp=>join::$rU) = "" + $T(id_index) + ":" + $T(id_label);
> route(SENDPUSH);
> exit;
>
> }
>
> route[SENDPUSH] {
> sl_send_reply("100", "Pushing");
> $http_req(suspend) = 0;
> $http_req(body) = '{ "caller": "' + $fU + '", "phone": "' + $rU +
> '", "id_index": "' + $T(id_index) + '", "id_label": "' + $T(id_label)+ '",
> "call_type": "'+ $var(calltype) +'" }';
> #for apple sandbox test.
> if (is_user_in("Request-URI", "test")) {
> http_async_query("http://127.0.0.1:9996/notification/";,
> "HTTP_REPLY");
> }
> http_async_query("http://127.0.0.1:9999/notification/";,
> "HTTP_REPLY");
> }
>
> #Resuming transaction.
> route[JOIN] {
> xlog("L_INFO","[JOIN] from REGISTER key value [$hdr(id_index)
> -- $hdr(id_label)]\n");
> $var(hjoin) = 0;
> lock("$tU");
> $var(hjoin) = $sht(vtp=>join::$tU);
> $var(hstored) = $sht(vtp=>stored::$tU);
> $sht(vtp=>join::$tU) = $null;
> $var(id_index) = $(var(hjoin){s.select,0,:}{s.int});
> $var(id_label) = $(var(hjoin){s.select,1,:}{s.int});
> unlock("$tU");
> if($var(id_index)!=$null){
> if ($var(hjoin)==0)
> {
> xlog("L_INFO","do ts_append_to() for $tu and
> hstored = $var(hstored)\n");
> if ($var(hstored))
> {
> ts_append_to("$(hdr(id_index){s.int})",
> "$(hdr(id_label){s.int})", "location");
> xlog("L_INFO","do ts_append_to() for $tu
> end \n");
> }
> return;
> }
> xlog("L_INFO","resuming trasaction [$(hdr(id_index){s.int
> }):$(hdr(id_label){s.int})] $tU ($var(hjoin))\n");
> if ( !t_continue("$(hdr(id_index){s.int})",
> "$(hdr(id_label){s.int})", "LOCATION") ){
> send_reply("404", "CALL NOT FOUND");
> }
> }
> }
>
> #processing HTTP responses
> route[HTTP_REPLY] {
> if ($http_ok && $http_rs == 200) {
> xlog("L_INFO", "route[HTTP_REPLY]: status $http_rs\n");
> xlog("L_INFO", "route[HTTP_REPLY]: body $http_rb\n");
> } else if($http_rs == 415 || $http_rs == "415") {
> xlog("L_ERR", "route[HTTP_REPLY]: caller: $fU phone: $ru error:
> $http_err)\n");
> sl_send_reply("415", "The other party does not support
> video calling!");
> } else {
> xlog("L_ALERT", "route[HTTP_REPLY]: error $http_err)\n");
> }
> #exit;
> }
> __________________________________________________________
> Kamailio - Users Mailing List - Non Commercial Discussions
> To unsubscribe send an email to [email protected]
> Important: keep the mailing list in the recipients, do not reply only to
> the sender!
> Edit mailing list options or unsubscribe:
>
__________________________________________________________
Kamailio - Users Mailing List - Non Commercial Discussions
To unsubscribe send an email to [email protected]
Important: keep the mailing list in the recipients, do not reply only to the
sender!
Edit mailing list options or unsubscribe:
