Hello Federico! thank you for your detailed answer! Yes, I was already able
to configure it and everything works fine. The only thing that was not clear
was why it is necessary to do t_newtran() before calling the http_async_query()
method? otherwise t_suspend() would throw an error.
--
Отправлено из Mail.ru для Android четверг, 02 мая 2024г., 11:08 +05:00 от
Federico Cabiddu via sr-users [email protected] :
>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:38PM 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:
__________________________________________________________
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:
