You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
93 lines
4.2 KiB
93 lines
4.2 KiB
kazoo.presence_notify = 1 descr "enable/disable sending notify callback to omnipresence"
|
|
kazoo.presence_notify_timeout = 3000 descr "timeout in ms waiting for notify reply"
|
|
kazoo.presence_notify_log_body = 0 descr "logs the body sent in the notification"
|
|
kazoo.presence_notify_log_resp_body = 0 descr "logs the body received from notification"
|
|
kazoo.presence_notify_log_to_table = 0 descr "logs notify/reply to active_watchers_log table"
|
|
kazoo.presence_notify_log_to_amqp = 1 descr "logs notify/reply to amqp"
|
|
|
|
#!trydef PRESENCE_NOTIFY_INIT
|
|
route[PRESENCE_LOCAL_NOTIFY]
|
|
{
|
|
if($rm != "NOTIFY") {
|
|
return;
|
|
}
|
|
t_set_fr(@cfg_get.kazoo.presence_notify_timeout, @cfg_get.kazoo.presence_notify_timeout);
|
|
xlog("L_INFO", "$ci|log|init preparing notify to $du : $ruri");
|
|
}
|
|
|
|
|
|
|
|
####### SQL OPS module ##########
|
|
#!ifndef SQLOPS_LOADED
|
|
loadmodule "sqlops.so"
|
|
modparam("sqlops","sqlcon", "cb=>KAZOO_DB_URL")
|
|
#!trydef SQLOPS_LOADED
|
|
#!endif
|
|
|
|
|
|
####### MQUEUE module ##########
|
|
#!ifndef MQUEUE_LOADED
|
|
loadmodule "mqueue.so"
|
|
#!trydef MQUEUE_LOADED
|
|
#!endif
|
|
modparam("mqueue","mqueue", "name=presence_last_notity")
|
|
|
|
#!ifndef TIMER_LOADED
|
|
loadmodule "timer.so"
|
|
#!trydef TIMER_LOADED
|
|
#!endif
|
|
modparam("timer", "declare_timer", "PRESENCE_LOG_TIMER=PRESENCE_LOG_TIMER_ROUTE,500,fast,enable");
|
|
|
|
|
|
event_route[presence:notify-reply]
|
|
{
|
|
if(@cfg_get.kazoo.presence_notify != 1)
|
|
return;
|
|
|
|
$xavp(pres=>delete_subscription) = 0;
|
|
|
|
if($notify_reply($rs) == 200) {
|
|
xlog("L_INFO", "$ci|end|notified $subs(watcher_username)@$subs(watcher_domain) on behalf of $subs(pres_uri)");
|
|
} else if($notify_reply($rs) == 481 && $subs(reason) == "timeout") {
|
|
xlog("L_INFO","$ci|end|sent subscription $hdr(Subscription-State)");
|
|
} else {
|
|
if($rP != "UDP")
|
|
$xavp(pres=>delete_subscription) = 1;
|
|
xlog("L_ERROR", "$ci|error|received $notify_reply($rs) $subs(reason) when notifying $subs(watcher_username)@$subs(watcher_domain) on behalf of $subs(pres_uri)");
|
|
}
|
|
if(@cfg_get.kazoo.presence_notify_log_body == 1)
|
|
xlog("L_INFO", "$ci|log|sent|body #012$(mb{s.escape.common}{s.replace,\','})#012");
|
|
if(@cfg_get.kazoo.presence_notify_log_resp_body == 1)
|
|
xlog("L_INFO", "$ci|log|resp|body #012$(notify_reply($mb){s.escape.common}{s.replace,\','})#012");
|
|
|
|
if(@cfg_get.kazoo.presence_notify_log_to_amqp == 1) {
|
|
route(PRESENCE_NOTIFY_AMQP);
|
|
}
|
|
|
|
if(@cfg_get.kazoo.presence_notify_log_to_table == 1) {
|
|
$var(Query) = $_s(REPLACE active_watchers_log SET sent_msg="$(mb{s.escape.common}{s.replace,\','})", received_msg="$(notify_reply($mb){s.escape.common}{s.replace,\','})", time=$TS, result=$notify_reply($rs), user_agent="$(subs(user_agent){s.escape.common})", callid="$subs(callid)", to_user="$subs(to_user)", to_domain="$subs(to_domain)" where presentity_uri="$subs(uri)" watcher_username="$subs(watcher_username)" and watcher_domain="$subs(watcher_domain)" event="$subs(event)");
|
|
mq_add("presence_last_notity", "$subs(watcher_username)@$subs(watcher_domain)", "$var(Query)");
|
|
}
|
|
}
|
|
|
|
|
|
route[PRESENCE_LOG_TIMER_ROUTE]
|
|
{
|
|
$var(runloop) = 1;
|
|
while(mq_fetch("presence_last_notity") == 1 && $var(runloop) < MAX_WHILE_LOOPS) {
|
|
# xlog("L_INFO", "Query : $mqv(presence_last_notity)");
|
|
if (sql_query("cb", "$mqv(presence_last_notity)") != 1) {
|
|
xlog("L_ERROR", "$ci|log|error updating active_watchers_log");
|
|
}
|
|
$var(runloop) = $var(runloop) + 1;
|
|
}
|
|
|
|
}
|
|
|
|
route[PRESENCE_NOTIFY_AMQP]
|
|
{
|
|
$var(amqp_payload_request) = $_s({"Event-Category" : "presence", "Event-Name" : "notify", "Event-Package" : "$subs(event)", "Timestamp" : $TS, "Call-ID" : "$subs(callid)", "From" : "$fu", "To" : "$subs(to_user)@$subs(to_domain)", "Sent" : "$(TS{s.ftime,%Y-%m-%d %H:%M:%S})", "Body" : "Hostname : MY_HOSTNAME\r\nTimestamp : $(TS{s.ftime,%Y-%m-%d %H:%M:%S})\r\n$(mb{s.escape.common}{s.replace,\','})\r\nResponse\r\n$(notify_reply($mb){s.escape.common}{s.replace,\','})", "Sequence" : $cs, "Reply" : $notify_reply($rs) });
|
|
$var(rk) = "notify." + $(subs(to_domain){kz.encode}) + "." + $(subs(to_user){kz.encode});
|
|
kazoo_publish("omnipresence", "$var(rk)", $var(amqp_payload_request));
|
|
xlog("L_INFO", "$ci|log|sent notify callback for event $subs(event) : $tu");
|
|
}
|