add delta logging to registrar

kamailio/registrar-role.cfg

@@ -191,27 +191,30 @@ route[ATTEMPT_AUTHORIZATION]
         exit;
     }
 
+    sl_send_reply("100", "checking your credentials");
     $var(amqp_payload_request) = $_s({"Event-Category" : "directory" , "Event-Name" : "authn_req", "Method" : "REGISTER", "Auth-Nonce" : "$adn", "Auth-Realm" : "$fd", "Auth-User" : "$fU", "From" : "$fu", "To" : "$tu", "Orig-IP" : "$si", "Orig-Port" : "$sp", "User-Agent" : "$(ua{s.escape.common}{s.replace,\','}{s.replace,$$,})", "Contact" : "$(ct{s.escape.common}{s.replace,\','}{s.replace,$$,})", "Call-ID" : "$ci" });
     $var(amqp_routing_key) = "authn.req." + $(fd{kz.encode});
     $avp(kz_timeout) = $sel(cfg_get.kazoo.registrar_query_timeout_ms);
+    $xavp(deltas=>query) = $(TV(Sn){s.replace,.,});
 
-    sl_send_reply("100", "checking your credentials");
-
-    if(kazoo_async_query("callmgr", $var(amqp_routing_key), $var(amqp_payload_request), "KZ_AUTHORIZATION_OK", "KZ_AUTHORIZATION_ERROR") != 1) {
+    if(kazoo_async_query("callmgr", $var(amqp_routing_key), $var(amqp_payload_request), "KZ_AUTHORIZATION_REPLY", "KZ_AUTHORIZATION_TIMEOUT") != 1) {
         xlog("L_INFO", "$ci|log|failed to send registrar query for authentication credentials for $Au $si:$sp\n");
         t_drop();
     }
 }
 
-failure_route[KZ_AUTHORIZATION_ERROR]
+failure_route[KZ_AUTHORIZATION_TIMEOUT]
 {
     xlog("L_INFO", "$ci|log|failed $T_reply_code to query Kazoo for authentication credentials for $Au $si:$sp\n");
     t_drop();
 }
 
-onreply_route[KZ_AUTHORIZATION_OK]
+onreply_route[KZ_AUTHORIZATION_REPLY]
 {
-    xlog("L_INFO", "$ci|log|received $(kzR{kz.json,Event-Category}) $(kzR{kz.json,Event-Name}) reply from $(kzR{kz.json,App-Name})-$(kzR{kz.json,App-Version})\n");
+    $var(StartRoute) = $(TV(Sn){s.replace,.,});
+    $var(delta_to_start) = $var(StartRoute) - $(kzR{kz.json,AMQP-Received});
+    $var(delta_from_query) = $(kzR{kz.json,AMQP-Received}) - $xavp(deltas=>query);
+    xlog("L_INFO", "$ci|log|received $(kzR{kz.json,Event-Category}) $(kzR{kz.json,Event-Name}) reply from $(kzR{kz.json,App-Name})-$(kzR{kz.json,App-Version}) (Δ1 $(kzR{kz.json,AMQP-Elapsed-Micro}) μs , Δ2 $var(delta_to_start) μs, Δ3 $var(delta_from_query) μs)\n");
     $var(password) = $(kzR{kz.json,Auth-Password});
     $var(nonce) = $adn;
     if( $(kzR{kz.json,Event-Name}) == "authn_err" ) {