|
|
######## Presence notify sync ########
|
|
|
## send notify sync back to kazoo
|
|
|
|
|
|
route[PRESENCE_LOCAL_NOTIFY]
|
|
|
{
|
|
|
if($rm != "NOTIFY") {
|
|
|
return;
|
|
|
}
|
|
|
$avp(notify_body) = $rb;
|
|
|
$avp(notify_event) = $hdr(Event);
|
|
|
t_on_reply("PRESENCE_NOTIFY_REPLY");
|
|
|
t_on_failure("PRESENCE_NOTIFY_FAULT");
|
|
|
}
|
|
|
|
|
|
onreply_route[PRESENCE_NOTIFY_REPLY]
|
|
|
{
|
|
|
$var(amqp_payload_request) = '{"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$avp(notify_event)", "Call-ID" : "$ci", "From" : "$fu", "To" : "$tu", "Body" : "$(avp(notify_body){s.escape.common})", "Sequence" : $cs, "Reply" : $T_reply_code }';
|
|
|
$var(rk) = "notify." + $(td{kz.encode}) + "." + $(tU{kz.encode});
|
|
|
kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request));
|
|
|
xlog("L_INFO", "$ci|log|sent notify callback for event $avp(notify_event) : $tu");
|
|
|
}
|
|
|
|
|
|
onreply_route[PRESENCE_NOTIFY_FAULT]
|
|
|
{
|
|
|
$var(amqp_payload_request) = '{"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$avp(notify_event)", "Call-ID" : "$ci", "From" : "$fu", "To" : "$tu", "Body" : "$(avp(notify_body){s.escape.common})", "Sequence" : $cs, "Reply" : $T_reply_code }';
|
|
|
$var(rk) = "notify." + $(td{kz.encode}) + "." + $(tU{kz.encode});
|
|
|
kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request));
|
|
|
xlog("L_INFO", "$ci|log|sent notify callback error $T_reply_code for event $avp(notify_event) : $tu");
|
|
|
}
|