add support for postgres backend

POSTGRES.md

@@ -0,0 +1,77 @@
+## Notes on upgrading to Kamailio 5.5 and moving to Postgres backend.
+
+Thus removing the dependency on KazooDB which is closed source.
+
+First completely remove the current installation 
+
+```
+Removing existing kazoo-kamailo:
+
+  yum remove kazoo-kamailio
+  yum remove kamailio
+  yum remove kazoo-configs-kamailio
+```
+Next install the lastest Kamailio (currently 5.5.0)
+```
+yum -y install yum-utils
+yum-config-manager --add-repo https://rpm.kamailio.org/centos/kamailio.repo
+yum install kamailio kamailio-kazoo kamailio-outbound kamailio-presence kamailio-tls   kamailio-utils kamailio-uuid    kamailio-websocket kamailio-xmpp kamailio-postgresql
+```
+Now install latest postgres (currently 12.7)
+```
+# Install the repository RPM:
+sudo yum install -y https://download.postgresql.org/pub/repos/yum/reporpms/EL-6-x86_64/pgdg-redhat-repo-latest.noarch.rpm
+sudo yum install -y postgresql12-server
+/usr/pgsql-12/bin/postgresql-12-setup  initdb
+
+sudo chkconfig postgresql-12 on
+sudo service postgresql-12 start
+```
+Create Kamailio DB
+```
+su postgres -c '/usr/pgsql-12/bin/createdb kamailio'
+```
+Add DB user and grant privileges
+```
+sudo su postgres -c psql
+	CREATE USER kamailio WITH PASSWORD 'kamailio';
+	GRANT ALL privileges on database kamailio to kamailio;
+```
+Modify default postgres authentication to allow kamailio access
+```
+vi /var/lib/pgsql/12/data/pg_hba.conf
+
+# "local" is for Unix domain socket connections only
+local   all             all                                     password
+# IPv4 local connections:
+host    all             all             127.0.0.1/32            password
+# IPv6 local connections:
+host    all             all             ::1/128                 password
+```
+Resart postgres and check kamailio access to DB
+```
+systemctl restart postgresql-12
+psql -U kamailio -d postgres://kamailio:kamailio@127.0.0.1/kamailio
+```
+Get the postgres kamailio configs:
+```
+git clone https://github.com/kageds/kazoo-configs-kamailio /etc/kazoo/kamailio
+cd /etc/kazoo/kamailio
+git checkout 4.3-postgres
+```
+Initialize the kamailio database with all the required tables:
+```
+psql -U kamailio -d postgres://kamailio:kamailio@127.0.0.1/kamailio -f /etc/kazoo/kamailo/db_scripts/kamailio_initdb_postgres.sql
+```
+Notice that the backend DB in local.cfg is now postgres
+```
+#!trydef KZ_DB_MODULE postgres
+#!substdef "!KAMAILIO_DBMS!postgres!g"
+#!substdef "!KAZOO_DB_URL!postgres://kamailio:kamailio@127.0.0.1/kamailio!g"
+```
+Start kamailio (NOT kazoo-kamailio)
+```
+systemctl enable kamailio
+systemctl start kamailio
+```
+

kamailio/db_queries_kazoo.cfg

@@ -25,3 +25,9 @@
 
 #!substdef "!KZQ_RESET_PUBLISHER_ZONE_UPDATE!INSERT INTO tmp_probe select distinct a.event, a.presentity_uri, 0 from presentities a inner join wdispatcher c on a.sender = c.destination inner join active_watchers b on a.presentity_uri = b.presentity_uri and a.event = b.event where zone = \"\$var(Zone)\" and state in('early', 'confirmed', 'onthephone', 'busy', 'ringing')!g"
 #!substdef "!KZQ_PRESENCE_ZONE_RESET!delete from presentity where id in(select a.id from presentities a join wdispatcher c on a.sender = c.destination where zone = \"\$var(Zone)\")!g"
+
+#!substdef "!KZQ_DELETE_FROM_ACTIVE_WATCHERS_WHERE_EXPIRES!DELETE FROM active_watchers WHERE expires > 0 AND datetime(expires, 'unixepoch') < datetime('now', '-90 seconds')!g"
+#!substdef "!KZQ_DELETE_FROM_ACTIVE_WATCHERS_WHERE_PRESENTITY!DELETE FROM ACTIVE_WATCHERS WHERE PRESENTITY_URI=\"\$subs(uri)\" AND EVENT=\"\$subs(event)\" AND FROM_USER = \"\$subs(from_user)\" AND FROM_DOMAIN=\"\$subs(from_domain)\" AND CALLID <> \"\$subs(callid)\"!g"
+#!substdef "!KZQ_DELETE_FROM_PRESENTITY_WHERE_EXPIRES!DELETE FROM PRESENTITY WHERE expires > 0 AND datetime(expires, 'unixepoch') < datetime('now')!g"
+#!substdef "!KZQ_DELETE_FROM_PRESENTITY_WHERE_DIALOG_TERMINATED!DELETE FROM PRESENTITY WHERE ID IN(select id from presentities where event = 'dialog' and state = 'terminated' and received < datetime('now', '-5 minutes'))!g"
+

kamailio/db_queries_postgres.cfg

@@ -12,3 +12,12 @@
 #!substdef "!KZQ_PRESENCE_SEARCH_DETAIL!select * from active_watchers_log where presentity_uri = '\$var(presentity_uri)'!g"
 #!substdef "!KZQ_PRESENCE_SEARCH_SUMMARY!select * from active_watchers where watcher_domain = '\$var(Domain)'!g"
 #!substdef "!KZQ_PRESENCE_RESET!delete from presentity where sender = '\$var(MediaUrl)'!g"
+
+#!substdef "!KZQ_REPLACE_WATCHERS_LOG!INSERT INTO active_watchers_log (presentity_uri, watcher_username, watcher_domain, event, callid, to_user, to_domain, user_agent, time, result, sent_msg, received_msg) VALUES ('\$subs(uri)', '\$subs(watcher_username)', '\$subs(watcher_domain)', '\$subs(event)','\$subs(callid)','\$subs(to_user)','\$subs(to_domain)', '\$(subs(user_agent){s.escape.common}{s.replace,\\\',''}{s.replace,\$\$,})', \$TS, \$notify_reply(\$rs), '\$(mb{s.replace,\\\',''}{s.replace,\$\$,''})', '\$(notify_reply(\$mb){s.replace,\\\',''}{s.replace,\$\$,''})') ON CONFLICT (presentity_uri, watcher_username, watcher_domain, event) DO UPDATE SET presentity_uri = excluded.presentity_uri, watcher_username = excluded.watcher_username, watcher_domain = excluded.watcher_domain, event = excluded.event!g"
+
+#!substdef "!KZQ_DELETE_FROM_ACTIVE_WATCHERS_WHERE_EXPIRES!DELETE FROM active_watchers WHERE expires > 0 AND to_timestamp(expires) < now() - interval '90 seconds'!g"
+#!substdef "!KZQ_DELETE_FROM_ACTIVE_WATCHERS_WHERE_PRESENTITY!DELETE FROM ACTIVE_WATCHERS WHERE PRESENTITY_URI='\$subs(uri)' AND EVENT='\$subs(event)' AND FROM_USER = '\$subs(from_user)' AND FROM_DOMAIN='\$subs(from_domain)' AND CALLID <> '\$subs(callid)'!g"
+#!substdef "!KZQ_DELETE_FROM_PRESENTITY_WHERE_EXPIRES!DELETE FROM PRESENTITY WHERE expires > 0 AND to_timestamp(expires) < now()!g"
+#!substdef "!KZQ_DELETE_FROM_PRESENTITY_WHERE_DIALOG_TERMINATED!DELETE FROM PRESENTITY WHERE ID IN(select id from presentities where event = 'dialog' and state = 'terminated' and received < now() - interval '5 minutes'))!g"
+#!substdef "!KZQ_HAS_PRESENTITY!select count(*) as count from presentity where username = '\$subs(to_user)' and domain = '\$subs(to_domain)' and event = '\$subs(event)'!g"
+

kamailio/dispatcher-role-5.5.cfg

@@ -0,0 +1,309 @@
+### DISPATCHER ROLE ####
+
+#!trydef KZ_DISPATCHER_PROBE_MODE 1
+#!trydef DISPATCHER_ADD_SERVERS 1
+#!trydef DISPATCHER_ADD_SECONDARY_IP 1
+#!trydef DISPATCHER_SECONDARY_IP_GROUP 3
+#!trydef DISPATCHER_ALG 0
+#!trydef KZ_DISPATCHER_HASH_SIZE 8
+#!trydef KZ_DISPATCHER_ADD_FLAGS 9
+#!trydef KZ_DISPATCHER_PRIMARY_GROUP 1
+#!trydef KZ_DISPATCHER_SECONDARY_GROUP 2
+#!trydef KZ_DISPATCHER_CLASSIFY_GROUP 3
+#!trydef KZ_DISPATCHER_ALTNET1_PRIMARY_GROUP 51
+#!trydef KZ_DISPATCHER_ALTNET1_SECONDARY_GROUP 52
+#!trydef KZ_DISPATCHER_ALTNET2_PRIMARY_GROUP 53
+#!trydef KZ_DISPATCHER_ALTNET2_SECONDARY_GROUP 54
+#!trydef KZ_DISPATCHER_PRESENCE_PRIMARY_GROUP 10
+#!trydef KZ_DISPATCHER_PRESENCE_SECONDARY_GROUP 11
+#!trydef KZ_DISPATCHER_REGISTRAR_PRIMARY_GROUP 20
+#!trydef KZ_DISPATCHER_REGISTRAR_SECONDARY_GROUP 21
+#!trydef KZ_DISPATCHER_MAX_RETRIES 2
+#!trydef KZ_DISPATCHER_ROUTE_ASSOCIATED_MEDIA 1
+#!trydef KZ_DISPATCHER_CLASSIFY_FLAGS 2
+#!trydef KZ_DISPATCHER_PRINT_ROUTES 1
+
+kazoo.dispatcher_auto_add = DISPATCHER_ADD_SERVERS descr "adds media servers reported by ecallmgr"
+kazoo.dispatcher_add_secondary_ip = DISPATCHER_ADD_SECONDARY_IP descr "adds internal ip from media servers reported by ecallmgr"
+kazoo.dispatcher_add_secondary_ip_group = DISPATCHER_SECONDARY_IP_GROUP descr "sets the group where to add internal ip from media servers reported by ecallmgr"
+kazoo.dispatcher_algorithm = DISPATCHER_ALG descr "dispatcher algorithm to use"
+kazoo.dispatcher_primary_group = KZ_DISPATCHER_PRIMARY_GROUP descr "dispatcher primary group"
+kazoo.dispatcher_secondary_group = KZ_DISPATCHER_SECONDARY_GROUP descr "dispatcher secondary group"
+kazoo.dispatcher_max_retries = KZ_DISPATCHER_MAX_RETRIES descr "max number of retries for media servers"
+kazoo.dispatcher_route_to_associated_media = KZ_DISPATCHER_ROUTE_ASSOCIATED_MEDIA descr "routes to associated media for atxfer"
+kazoo.dispatcher_classify_flags = KZ_DISPATCHER_CLASSIFY_FLAGS descr "dispatch classifier flags"
+kazoo.dispatcher_print_routes = KZ_DISPATCHER_PRINT_ROUTES descr "should we log the selected routes"
+
+
+####### Dispatcher module  ########
+loadmodule "dispatcher.so"
+modparam("dispatcher", "db_url", "KAZOO_DB_URL")
+modparam("dispatcher", "flags", 2)
+modparam("dispatcher", "use_default", 0)
+modparam("dispatcher", "force_dst", 1)
+modparam("dispatcher", "hash_pvar", "$avp(ds_grp)")
+modparam("dispatcher", "setid_pvname", "$var(setid)")
+modparam("dispatcher", "attrs_pvname", "$var(attrs)")
+modparam("dispatcher", "ds_ping_method", "OPTIONS")
+modparam("dispatcher", "ds_ping_interval", 10)
+modparam("dispatcher", "ds_probing_threshold", 3)
+modparam("dispatcher", "ds_probing_mode", KZ_DISPATCHER_PROBE_MODE)
+modparam("dispatcher", "ds_ping_reply_codes", "501,403,404,400,200")
+modparam("dispatcher", "ds_ping_from", "sip:sipcheck@MY_HOSTNAME")
+modparam("dispatcher", "xavp_dst", "ds_dst")
+modparam("dispatcher", "xavp_ctx", "ds_ctx")
+modparam("dispatcher", "ds_hash_size", KZ_DISPATCHER_HASH_SIZE)
+
+## Dispatcher Groups:
+## 1 - Primary media servers
+## 2 - Backup media servers
+## 3 - Alternate media server IPs (used only for classification)
+## 10 - Presence servers (if not locally handled)
+## 20 - Registrar servers (if not locally handled)
+
+
+modparam("rtimer", "timer", "name=dispatcher_reload;interval=20;mode=1;")
+modparam("rtimer", "exec", "timer=dispatcher_reload;route=DISPATCHER_RELOAD")
+
+####### Dispatcher Logic ########
+route[DISPATCHER_CLASSIFY_SOURCE]
+{
+    route_if_exists("DISPATCHER_CUSTOM_NETWORK_CLASSIFY");
+
+    if (!isflagset(FLAG_NETWORK_CLASSIFIED)) {
+       if (is_myself("$ou")) {
+           xlog("$var(log_request_level)", "$ci|log|original R-URI ($ou) is this proxy, treating as external sources\n");
+       } else {
+           $var(classify_dispatcher_flag) = $(sel(cfg_get.kazoo.dispatcher_classify_flags){s.int});
+           if (ds_is_from_list(KZ_DISPATCHER_PRIMARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_SECONDARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_CLASSIFY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_ALTNET1_PRIMARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_ALTNET1_SECONDARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_ALTNET2_PRIMARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_ALTNET2_SECONDARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_PRESENCE_PRIMARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_PRESENCE_SECONDARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_REGISTRAR_PRIMARY_GROUP, "$var(classify_dispatcher_flag)") ||
+               ds_is_from_list(KZ_DISPATCHER_REGISTRAR_SECONDARY_GROUP, "$var(classify_dispatcher_flag)")) {
+               xlog("$var(log_request_level)", "$ci|log|originated from internal sources\n");
+               setflag(FLAG_INTERNALLY_SOURCED);
+           } else {
+               xlog("$var(log_request_level)", "$ci|log|originated from external sources\n");
+           }
+       }
+    }
+}
+
+# Take the routes from dispatcher - hash over callid
+# If prefered route defined, reorder the destionations
+route[DISPATCHER_FIND_ROUTES]
+{
+
+    $var(ds_primary_group) = $(sel(cfg_get.kazoo.dispatcher_primary_group){s.int});
+    $var(ds_backup_group) = $(sel(cfg_get.kazoo.dispatcher_secondary_group){s.int});
+    
+    #!ifndef PRESENCE_ROLE
+    if (is_method("SUBSCRIBE")) {
+        $var(ds_primary_group) = KZ_DISPATCHER_PRESENCE_PRIMARY_GROUP;
+        $var(ds_backup_group)  = KZ_DISPATCHER_PRESENCE_SECONDARY_GROUP;
+    }
+    #!endif
+
+    #!ifndef REGISTRAR_ROLE
+    if (is_method("REGISTER")) {
+        $var(ds_primary_group) = KZ_DISPATCHER_REGISTRAR_PRIMARY_GROUP;
+        $var(ds_backup_group)  = KZ_DISPATCHER_REGISTRAR_SECONDARY_GROUP;
+    }
+    #!endif
+
+    #!ifdef PRESENCE_ROLE
+    route(PRESENCE_FAST_PICKUP_ATTEMPT);
+    #!endif
+
+    route_if_exists("DISPATCHER_CUSTOM_SET_GROUPS");
+
+    $var(ds_group) = $var(ds_primary_group);
+    
+    $var(ds_alg) = $sel(cfg_get.kazoo.dispatcher_algorithm);
+    if(ds_list_exists("$var(ds_backup_group)")) {
+        $var(ds_rule) = $_s($var(ds_primary_group)=$var(ds_alg);$var(ds_backup_group)=$var(ds_alg));
+    } else {
+        $var(ds_rule) = $_s($var(ds_primary_group)=$var(ds_alg));
+    }
+
+    ds_select_routes("$var(ds_rule)", "2");
+    if ($xavp(ds_ctx=>cnt) == 0) {
+        xlog("L_WARN", "$ci|end|no servers available in primary or backup group\n");
+        sl_send_reply("480", "All servers busy");
+        exit;
+    }
+
+    route(PRINT_ROUTES);
+
+    $var(user_source) = $(ct{tobody.user}) + "@" + $si + ":" + $sp;
+    $var(redirect) = @from.uri.user + "@" + @from.uri.host + "->"
+        + @ruri.user + "@" + @ruri.host;
+    if ($sht(redirects=>$var(redirect)) != $null) {
+        $var(prefered_route) = $sht(redirects=>$var(redirect));
+        xlog("L_INFO", "$ci|route|found redirect for $var(redirect) to $var(prefered_route)\n");
+        $avp(AVP_REDIRECT_KEY) = $var(redirect);
+        route(DISPATCHER_PREFERRED_ROUTE);
+    } else if ($sht(associations=>$var(user_source)) != $null) {
+        if($sel(cfg_get.kazoo.dispatcher_route_to_associated_media) == 1) {
+            $var(prefered_route) = $sht(associations=>$var(user_source));
+            xlog("L_INFO", "$ci|route|found association for contact uri $var(user_source)\n");
+            route(DISPATCHER_PREFERRED_ROUTE);
+        }
+        $sht(associations=>$var(user_source)) = $null;
+    }
+
+    $avp(ds_group) = $xavp(ds_dst=>grp);
+    $avp(ds_retries) = 0;
+    ds_set_dst();
+
+}
+
+route[DISPATCHER_PREFERRED_ROUTE]
+{
+    if(!ds_is_from_list(-1, 6, "$var(prefered_route)")) {
+       xlog("L_INFO", "$ci|log|associated media server $var(prefered_route) is inactive, moving to $xavp(ds_dst=>uri)\n");
+       return -1;
+    }
+
+    xlog("L_INFO", "$ci|log|re-ordering the dispatcher list to maintain association with $var(prefered_route)\n");    
+
+    $var(i) = $xavp(ds_ctx=>cnt) - 1;
+    while($var(i) >= 0) {
+       if($xavp(ds_dst[$var(i)]=>uri) == $var(prefered_route)) {
+          $xavp(ds_dst[$var(i)]) = $null;
+       }
+       $var(i) = $var(i) - 1;
+    }
+
+    $xavp(ds_dst=>uri) = $var(prefered_route);
+    $xavp(ds_dst[0]=>grp) = $var(setid);
+    $xavp(ds_dst[0]=>attrs) = $var(attrs);
+
+    return 1;
+}    
+
+route[PRINT_ROUTES]
+{
+    if($sel(cfg_get.kazoo.dispatcher_print_routes) == 0) return;
+
+    $var(i) = 0;
+    while($xavp(ds_dst[$var(i)]=>uri) != $null) {
+       xlog("L_INFO", "$ci|route|group $xavp(ds_dst[$var(i)]=>grp) => $xavp(ds_dst[$var(i)]=>uri) => zone $(xavp(ds_dst[$var(i)]=>attrs){param.value,zone})\n");
+       $var(i) = $var(i) + 1;
+    }
+
+}
+
+#!import_file "dispatcher-next-route.cfg"
+
+#!ifndef CUSTOM_DISPATCHER_NEXT_ROUTE
+# Try next destinations in failure route
+route[DISPATCHER_NEXT_ROUTE]
+{
+
+    if($avp(ds_retries) >= $sel(cfg_get.kazoo.dispatcher_max_retries)) return;
+
+    $avp(ds_retries) = $avp(ds_retries) + 1;
+    if(ds_next_dst()) {
+        xlog("L_INFO", "$ci|log|routing call to next media server $du\n");
+
+        setflag(FLAG_SKIP_NAT_CORRECTION);
+
+        # relay the request to the new media server
+        route(RELAY);
+
+        exit;
+    }
+}
+#!endif
+
+event_route[dispatcher:dst-down]
+{
+    xlog("L_WARNING", "Destination down: $ru , $xavp(ds_dst=>uri), $xavp(ds_dst=>grp), $xavp(ds_dst=>attrs)\n");
+}
+
+event_route[dispatcher:dst-up]
+{
+    xlog("L_WARNING", "Destination up: $ru , $xavp(ds_dst=>uri), $xavp(ds_dst=>grp), $xavp(ds_dst=>attrs)\n");
+}
+
+
+route[DISPATCHER_CHECK_MEDIA_SERVER]
+{
+   $var(check_media_server_ret) = 0;
+   if($sel(cfg_get.kazoo.dispatcher_auto_add) == 1) {
+       $var(SetId) = 1;
+       if($var(Zone) != "MY_AMQP_ZONE") {
+          $var(SetId) = 2;
+       }
+       $var(flags) = KZ_DISPATCHER_ADD_FLAGS;
+       $var(attrs) = $_s(zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName));
+       route_if_exists("DISPATCHER_CUSTOM_MEDIA_CHECK");
+       sql_query("exec", "KZQ_CHECK_MEDIA_SERVER_INSERT");
+       if($sqlrows(exec) > 0) {
+          $shv(dispatcher_reload) = 1;
+          $var(check_media_server_ret) = 1;
+       }
+
+       if($sel(cfg_get.kazoo.dispatcher_add_secondary_ip) == 1) {
+          if($var(MediaIP) != "" && $var(MediaIP) != $(var(MediaUrl){uri.host})) {
+             $var(MediaUrlBack) = $var(MediaUrl);
+             $var(MediaUrl) = $_s($(var(MediaUrlBack){uri.scheme}):$var(MediaIP):$(var(MediaUrlBack){uri.port}));
+             $var(attrs) = $_s(zone=$var(Zone);profile=$var(MediaProfile);duid=$(var(MediaUrl){s.corehash, MEDIA_SERVERS_HASH_SIZE});node=$var(MediaName));
+             $var(SetId) = $sel(cfg_get.kazoo.dispatcher_add_secondary_ip_group);
+             route_if_exists("DISPATCHER_CUSTOM_MEDIA_CHECK");
+             sql_query("exec", "KZQ_CHECK_MEDIA_SERVER_INSERT");
+             if($sqlrows(exec) > 0) {
+                $shv(dispatcher_reload) = 1;
+                $var(check_media_server_ret) = 1;
+             }
+             $var(MediaUrl) = $var(MediaUrlBack);
+          }
+       }
+
+   }
+   return $var(check_media_server_ret);
+}
+
+route[DISPATCHER_RELOAD]
+{
+   if($shv(dispatcher_reload) == 1) {
+      xlog("L_WARNING", "reloading dispatcher table\n");
+      ds_reload();
+   };
+   $shv(dispatcher_reload) = 0;  
+}
+
+route[DISPATCHER_STATUS]
+{
+    jsonrpc_exec('{"jsonrpc": "2.0", "method": "dispatcher.list", "id": 1}');
+    $var(Sets) = $(jsonrpl(body){kz.json, result.NRSETS});
+    $var(i) = 0;
+    $var(ds_groups_json)="";
+    $var(Sep1) = "";
+    while($var(i) < $var(Sets)) {
+       $var(Set) = $(jsonrpl(body){kz.json, result.RECORDS[$var(i)].SET});
+       $var(SetCount) = $(var(Set){kz.json.count,TARGETS});
+       $var(Sep2)="";
+       $var(ds_group_json)="";
+       $var(c) = 0;
+       while($var(c) < $var(SetCount)) {
+           $var(Dest) = $(var(Set){kz.json,TARGETS[$var(c)].DEST});
+           $var(record) = $_s("$(var(Dest){kz.json,URI})" : {"destination" : "$(var(Dest){kz.json,URI})", "flags" : "$(var(Dest){kz.json,FLAGS})", "priority" : $(var(Dest){kz.json,PRIORITY}), "attrs" : "$(var(Dest){kz.json,ATTRS.BODY})"});
+           $var(ds_group_json) = $var(ds_group_json) + $var(Sep2) + $var(record);
+           $var(Sep2) = ",";
+           $var(c) = $var(c) + 1;
+       }
+        $var(ds_groups_json) = $var(ds_groups_json) + $var(Sep1) + $_s("$(var(Set){kz.json,ID})" : { $var(ds_group_json) });
+        $var(Sep1)=", ";
+        $var(i) = $var(i) + 1;
+    }
+}
+
+# vim: tabstop=4 softtabstop=4 shiftwidth=4 expandtab

kamailio/local.cfg

@@ -66,8 +66,9 @@
 ##     remove all but the last '#' and configure the connector
 ##     accordingly.  The example shows how to use postgres.
 ##     See the kamailio documentation for more details.
-# # #!substdef "!KAMAILIO_DBMS!postgres!g"
-# # #!substdef "!KAZOO_DB_URL!postgres://kamailio:kamailio@127.0.0.1/kamailio!g"
+#!trydef KZ_DB_MODULE postgres
+#!substdef "!KAMAILIO_DBMS!postgres!g"
+#!substdef "!KAZOO_DB_URL!postgres://kamailio:kamailio@127.0.0.1/kamailio!g"
 
 ################################################################################
 ## UDP PARAMETERS

kamailio/presence-notify.cfg

@@ -142,11 +142,11 @@ route[PRESENCE_NOTIFY_AMQP]
 
 route[PRESENCE_CLEANUP]
 {
-    $var(Query) = $_s(DELETE FROM active_watchers WHERE expires > 0 AND datetime(expires, 'unixepoch') < datetime('now', '-90 seconds'););
+    $var(Query) = $_s(KZQ_DELETE_FROM_ACTIVE_WATCHERS_WHERE_EXPIRES;);
     mq_add("presence_last_notity", "$uuid(g)", "$var(Query)");
-    $var(Query) = $_s(DELETE FROM PRESENTITY WHERE expires > 0 AND datetime(expires, 'unixepoch') < datetime('now'););
+    $var(Query) = $_s(KZQ_DELETE_FROM_PRESENTITY_WHERE_EXPIRES;);
     mq_add("presence_last_notity", "$uuid(g)", "$var(Query)");
-    $var(Query) = $_s(DELETE FROM PRESENTITY WHERE ID IN(select id from presentities where event = "dialog" and state = "terminated" and received < datetime('now', '-5 minutes')););
+    $var(Query) = $_s(KZQ_DELETE_FROM_PRESENTITY_WHERE_DIALOG_TERMINATED;);
     mq_add("presence_last_notity", "$uuid(g)", "$var(Query)");
     $var(Query) = $_s(DELETE FROM ACTIVE_WATCHERS_LOG WHERE ID IN(select id from active_watchers_log a where not exists(select callid from active_watchers b where b.callid = a.callid and b.watcher_username = a.watcher_username and b.watcher_domain = a.watcher_domain)););
     mq_add("presence_last_notity", "$uuid(g)", "$var(Query)");

kamailio/presence-role.cfg

@@ -49,7 +49,7 @@ modparam("presence_xml", "disable_bla", 1)
 
 modparam("presence", "subs_db_mode", 3)
 modparam("presence", "expires_offset", 0)
-modparam("presence", "send_fast_notify", 1)
+modparam("presence", "send_fast_notify", 0)
 
 modparam("presence", "clean_period", 0)
 modparam("presence", "db_update_period", 0)
@@ -60,7 +60,7 @@ modparam("presence", "min_expires", PRESENCE_MIN_EXPIRES)
 modparam("presence", "max_expires", PRESENCE_MAX_EXPIRES)
 modparam("presence", "sip_uri_match", 1)
 modparam("presence", "waitn_time", 1)
-modparam("presence", "notifier_processes", 0)
+modparam("presence", "notifier_processes", 1)
 modparam("presence", "db_url", "KAZOO_DB_URL")
 modparam("presence", "xavp_cfg", "pres")
 modparam("presence", "local_log_level", 6)
@@ -144,7 +144,7 @@ route[HANDLE_SUBSCRIBE]
 
 route[DELETE_DUPLICATED_SUBSCRIPTIONS]
 {
-    sql_query("exec", '$_s(DELETE FROM ACTIVE_WATCHERS WHERE PRESENTITY_URI="$subs(uri)" AND EVENT="$subs(event)" AND FROM_USER = "$subs(from_user)" AND FROM_DOMAIN="$subs(from_domain)" AND CALLID <> "$subs(callid)")');
+    sql_query("exec", 'KZQ_DELETE_FROM_ACTIVE_WATCHERS_WHERE_PRESENTITY');
 }
 
 route[HANDLE_RESUBSCRIBE]