@Ben Kaufman : thanks, I will try that!
@Nick Digalaks : isn't that necessary to have a correct http async transaction? the async_http module does make/need the TM module to be loaded....and all examples I got for the async_http module had t_newtran() method added prior to executing http request....
*Sérgio Charrua*
On Mon, Apr 8, 2024 at 6:20 PM Nick Digalakis ntg_13@hotmail.com wrote:
I didn't test this, but why are you calling t_newtran(); if you only want to send the 300 response?
On Apr 8, 2024 18:12, Sergio Charrua via sr-users < sr-users@lists.kamailio.org> wrote:
Hi all!
For testing purposes, while I am waiting for the ST/SH REST API to be available from other teams, I developed a small python REST API that returns a mockup of a JSON object with some of the required values. The kamailio script, completely stateless as I do not need to keep track of the sessions, iterates through one of the JSON branches and adds the destination URLs to the Contact header and replies a SIP 300 Multiple Choices. This works: the UAC does receive the SIP response with the Contacts , but it also receives a SIP 500 error message right after, and I can't figure out why. And i bet this is simple to solve.... Any clue? I'm aware I'm not processing ACK messages, but the sl_send_reply 403 should do the trick right? ... at least while testing....
Also, as this is a stateless script, is there another way of using async http or making http requests to a REST API without having to use TM Module?
Thanks in advance.
The kamailio script is has follows:
#!KAMAILIO /* add API http timeout */ #!define HTTP_API_TIMEOUT 5000 #!define HTTP_API_ROUTING_ENDPOINT "http://some_python_rest_api/get_route" ### LOG Levels: 3=DBG, 2=INFO, 1=NOTICE, 0=WARN, -1=ERR debug=4 log_stderror=no memdbg=5 memlog=5 log_facility=LOG_LOCAL0 log_prefix="{$mt $hdr(CSeq) $ci} " /* number of SIP routing processes */ children=2 /* set paths to location of modules */ loadmodule "tm.so" loadmodule "jsonrpcs.so" loadmodule "kex.so" loadmodule "corex.so" loadmodule "sl.so" loadmodule "db_mysql.so" loadmodule "rr.so" loadmodule "pv.so" loadmodule "maxfwd.so" loadmodule "ipops.so" loadmodule "textops.so" loadmodule "siputils.so" loadmodule "xlog.so" loadmodule "sanity.so" loadmodule "ctl.so" loadmodule "cfg_rpc.so" loadmodule "uac.so" loadmodule "counters.so" loadmodule "http_async_client.so" loadmodule "jansson.so" loadmodule "usrloc.so" /* listen addresses */ listen=udp:10.20.0.2:5060 listen=udp:10.20.0.2:5062 advertised_address="10.20.0.2"; # ----- http_async_client params ----- modparam("http_async_client", "workers", HTTP_ASYNC_CLIENT_WORKERS) modparam("http_async_client", "connection_timeout", 2000) request_route { #route(HANDLE_DMQ); route(HANDLE_OPTIONS); if (is_method("INVITE")) { xlog("L_INFO","MAIN - calling TO_CARRIER"); route(TO_CARRIER); exit; } else{ sl_send_reply("401","UNAUTHORIZED"); } } route[TO_CARRIER]{ xlog("L_INFO","TO_CARRIER - calling RELAY_API"); route(RELAY_API); #Route relay xlog("L_INFO","TO_CARRIER - return"); return; } # Relay request using the API (response) route[RELAY_API_RESPONSE] { xlog("L_INFO","RELAY_API_RESPONSE - got response from REST API"); if ($http_ok==1 && $http_rs==200) { xlog("L_INFO","RELAY_API_RESPONSE - HTTP RESPONSE: $http_rb\n"); if (jansson_get("json", $http_rb, "$var(json)")) { xlog("L_INFO","RELAY_API_RESPONSE - JSON = $var(json)"); $var(count) = 0; jansson_array_size("routes", $var(json), "$var(size)"); xlog("L_INFO","RELAY_API_RESPONSE - jansson_array_size");
while ( $var(count) < $var(size) ){jansson_get("routes[$var(count)].headers.to.uri", $var(rtjson), "$var(v)");
xlog("L_INFO","JSON - routes[$var(count)]
$var(v)");
#$(avp(mycontacts)[$var(count)]) =$avp(mycontacts) + $var(v) + "\r\n";
$avp(mycontacts) = $avp(mycontacts) +$var(v) + ";";
*append_to_reply("Contact: <" + $var(v)+">"+ "\r\n"); /* ---- IS THERE A BETTER ?? ..... */*
$var(count) = $var(count) + 1; } xlog("L_INFO","RELAY_API_RESPONSE - RELAY"); xlog("L_INFO","MAIN - calling REPLY_302"); route(REPLY_302); return; } } send_reply(500, "API Not Available - http response = $http_rs$http_ok"); exit; } route[RELAY_API] {
xlog("L_INFO","RELAY_API - from_ip $si:$sp from_number $fUto_number $ru"); $http_req(all) = $null; $http_req(suspend) = 1; $http_req(timeout) = HTTP_API_TIMEOUT; $http_req(method) = "POST"; $http_req(hdr) = "Content-Type: application/json"; jansson_set("string","from_ip",$si, "$var(http_routing_query)"); jansson_set("string","from_port",$sp, "$var(http_routing_query)"); jansson_set("string","from_number",$fU, "$var(http_routing_query)"); jansson_set("string","to_number",$ru , "$var(http_routing_query)");
xlog("L_INFO","RELAY_API - API ASYNC ROUTING REQUEST:$var(http_routing_query)\n"); $http_req(body) = $var(http_routing_query); t_newtran(); http_async_query(HTTP_API_ROUTING_ENDPOINT, "RELAY_API_RESPONSE"); xlog("L_INFO","RELAY_API - Waiting for Response"); } route[REPLY_302] { # Sends a 300 Multiple Choices back to the proxy that requested the routing lookup xlog("L_INFO","REPLY_302 - send reply"); sl_send_reply("300", "Multiple Choices"); xlog("L_INFO","REPLY_302 - exit"); exit; } route[HANDLE_OPTIONS]{ if(is_method("OPTIONS")) { sl_send_reply(200, "OK"); exit; } if ($fU=="ping") { sl_send_reply("200","OK"); exit; } }
SNGrep output: 1 - INVITE from UAC to Kamailio
INVITE sip:918228990@10.20.0.2 SIP/2.0 Via: SIP/2.0/UDP 10.20.0.1:5063;branch=z9hG4bK58aa83f4 Max-Forwards: 70 From: "Anonymous" sip:anonymous@anonymous.invalid:5063;tag=as192b8891 To: sip:918228990@10.20.0.2 Contact: sip:anonymous@10.20.0.1:5063 Call-ID: 531668b959674f9f667f1c923d1d6c94@10.20.0.1:5063 CSeq: 102 INVITE User-Agent: SIPp Date: Mon, 08 Apr 2024 15:09:51 GMT Allow: INVITE, ACK, CANCEL, OPTIONS, BYE, REFER, SUBSCRIBE, NOTIFY, INFO, PUBLISH, MESSAGE Supported: replaces, timer Content-Type: application/sdp Content-Length: 270 v=0 o=root 2021555890 2021555890 IN IP4 10.20.0.1 s=SIPp c=IN IP4 10.20.0.1 t=0 0 m=audio 18422 RTP/AVP 8 0 101 a=rtpmap:8 PCMA/8000 a=rtpmap:0 PCMU/8000 a=rtpmap:101 telephone-event/8000 a=fmtp:101 0-16 a=ptime:20 a=maxptime:150 a=sendrecv
2 - Reply from Kamailio to UAC
SIP/2.0 100 trying -- your call is important to us Via: SIP/2.0/UDP 10.20.0.1:5063;branch=z9hG4bK58aa83f4 From: "Anonymous" sip:anonymous@anonymous.invalid:5063;tag=as192b8891 To: sip:918228990@10.20.0.2 Call-ID: 531668b959674f9f667f1c923d1d6c94@10.20.0.1:5063 CSeq: 102 INVITE Server: kamailio (5.7.4 (x86_64/linux)) Content-Length: 0
3 - SIP 300 Multiple Choices from Kamailio to UAC
SIP/2.0 300 Multiple Choices Via: SIP/2.0/UDP 10.20.0.1:5063;branch=z9hG4bK58aa83f4 From: "Anonymous" sip:anonymous@anonymous.invalid:5063;tag=as192b8891 To: <sip:918228990@10.20.0.2
;tag=57c593265e21c2b70aea50cb414df9cd.32679ccd
Call-ID: 531668b959674f9f667f1c923d1d6c94@10.20.0.1:5063 CSeq: 102 INVITE Contact: sip:sip:918228990@10.20.0.2@sip.domain.io Contact: sip:+351sip:918228990@10.20.0.2@10.20.0.3 Server: kamailio (5.7.4 (x86_64/linux)) Content-Length: 0
4 - SIP 500 from Kamailio to UAC
SIP/2.0 500 I'm terribly sorry, server error occurred (1/TM) Via: SIP/2.0/UDP 10.20.0.1:5063;branch=z9hG4bK58aa83f4 From: "Anonymous" sip:anonymous@anonymous.invalid:5063;tag=as192b8891 To: <sip:918228990@10.20.0.2
;tag=4eb2322b7d2b68e6fc3168f503344c21-32679ccd
Call-ID: 531668b959674f9f667f1c923d1d6c94@10.20.0.1:5063 CSeq: 102 INVITE Server: kamailio (5.7.4 (x86_64/linux)) Content-Length: 0
5 - ACK from UAC to Kamailio
ACK sip:918228990@10.20.0.2 SIP/2.0 Via: SIP/2.0/UDP 10.20.0.1:5063;branch=z9hG4bK58aa83f4 Max-Forwards: 70 From: "Anonymous" sip:anonymous@anonymous.invalid:5063;tag=as192b8891 To: <sip:918228990@10.20.0.2
;tag=57c593265e21c2b70aea50cb414df9cd.32679ccd
Contact: sip:anonymous@10.20.0.1:5063 Call-ID: 531668b959674f9f667f1c923d1d6c94@10.20.0.1:5063 CSeq: 102 ACK User-Agent: SIPp Content-Length: 0
and continues with ACK and repeating SIP 500 above....
*Sérgio Charrua*
.