|
|
######## 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 + "." + $tU;
|
|
|
kazoo_publish("dialoginfo_subs", "$var(rk)", $var(amqp_payload_request));
|
|
|
xlog("L_INFO", "$ci|log|event $avp(notify_event)");
|
|
|
}
|
|
|
|
|
|
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 + "." + $tU;
|
|
|
kazoo_publish("dialoginfo_subs", "$var(rk)", $var(amqp_payload_request));
|
|
|
}
|