|
|
@ -79,7 +79,7 @@ route[PRESENCE_SEARCH_DETAIL] |
|
|
while($xavp(ra) != $null) { |
|
|
while($xavp(ra) != $null) { |
|
|
$var(Event) = $xavp(ra=>event); |
|
|
$var(Event) = $xavp(ra=>event); |
|
|
while($xavp(ra) != $null && $var(Event) == $xavp(ra=>event)) { |
|
|
while($xavp(ra) != $null && $var(Event) == $xavp(ra=>event)) { |
|
|
$var(Sub) = $_s("$var(Username)" : {"$xavp(ra=>event)" : { "$xavp(ra=>watcher_username)" : {"kamailio@MY_HOSTNAME" : {"call_id" : "$xavp(ra=>callid)", "time" : $xavp(ra=>time), "result" : $xavp(ra=>result), "sent" : "$(xavp(ra=>sent_msg){s.escape.common})", "received" : "$(xavp(ra=>received_msg){s.escape.common})", "User-Agent" : "$(xavp(ra=>user_agent){s.escape.common}{s.replace,\','}{s.replace,$$,})"}}}}); |
|
|
|
|
|
|
|
|
$var(Sub) = $_s("$var(Username)" : {"$xavp(ra=>event)" : { "$xavp(ra=>watcher_username)" : {"kamailio@MY_HOSTNAME" : {"$xavp(ra=>callid)" : {"time" : $xavp(ra=>time), "result" : $xavp(ra=>result), "sent" : "$(xavp(ra=>sent_msg){s.escape.common})", "received" : "$(xavp(ra=>received_msg){s.escape.common})", "User-Agent" : "$(xavp(ra=>user_agent){s.escape.common}{s.replace,\','}{s.replace,$$,})"}}}}}); |
|
|
xlog("L_DEBUG", "$ci| RESULT \"Subscriptions\" : { $var(Sub) }\n"); |
|
|
xlog("L_DEBUG", "$ci| RESULT \"Subscriptions\" : { $var(Sub) }\n"); |
|
|
$var(amqp_payload_request) = '{"Event-Category" : "presence", "Event-Name" : "search_partial_resp", "Msg-ID" : "$(kzE{kz.json,Msg-ID})", "Subscriptions" : { $var(Sub) } }'; |
|
|
$var(amqp_payload_request) = '{"Event-Category" : "presence", "Event-Name" : "search_partial_resp", "Msg-ID" : "$(kzE{kz.json,Msg-ID})", "Subscriptions" : { $var(Sub) } }'; |
|
|
kazoo_publish("targeted", "$var(Queue)", $var(amqp_payload_request)); |
|
|
kazoo_publish("targeted", "$var(Queue)", $var(amqp_payload_request)); |
|
|
|