From 8a7de3ea5b94a2ec9f1b326dbb5b8db4aa178b1d Mon Sep 17 00:00:00 2001 From: lazedo Date: Fri, 20 Jan 2017 18:56:48 +0000 Subject: [PATCH] Update presence_notify_sync-role.cfg (#131) --- kamailio/presence_notify_sync-role.cfg | 94 ++++++++++++++++++++++---- 1 file changed, 79 insertions(+), 15 deletions(-) diff --git a/kamailio/presence_notify_sync-role.cfg b/kamailio/presence_notify_sync-role.cfg index 8f9c440..ee89d8f 100644 --- a/kamailio/presence_notify_sync-role.cfg +++ b/kamailio/presence_notify_sync-role.cfg @@ -1,29 +1,93 @@ -######## Presence notify sync ######## -## send notify sync back to kazoo +kazoo.presence_notify = 1 descr "enable/disable sending notify callback to omnipresence" +kazoo.presence_notify_timeout = 200 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; } - $avp(notify_body) = $rb; - $avp(notify_event) = $hdr(Event); - t_on_reply("PRESENCE_NOTIFY_REPLY"); - t_on_failure("PRESENCE_NOTIFY_FAULT"); + 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"); } -onreply_route[PRESENCE_NOTIFY_REPLY] + + +####### 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] { - $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\n"); + 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; + } + } -onreply_route[PRESENCE_NOTIFY_FAULT] +route[PRESENCE_NOTIFY_AMQP] { - $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}); + $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 error $T_reply_code for event $avp(notify_event) : $tu\n"); + xlog("L_INFO", "$ci|log|sent notify callback for event $subs(event) : $tu"); }