sipwise
/
lua-ngcp-kamailio
mirror of https://github.com/sipwise/lua-ngcp-kamailio.git
1
0
Fork 0
Code Issues Releases Wiki Activity

MT#12707 - recentcalls: add source field

Browse Source 
Change-Id: I061a292546e16974fde39e59f72e097be6bca2ee
changes/49/2649/2
Kirill Solomko 10 years ago
parent 9a28c0496c
commit fd5d1e9c1d
2 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File

9
ngcp/recentcalls.lua
Unescape View File

@ -69,7 +69,8 @@ end
end end
function NGCPRecentCalls:set_by_uuid(uuid, callid, start_time, function NGCPRecentCalls:set_by_uuid(uuid, callid, start_time,
duration, caller, callee) duration, caller, callee,
source)
if not self._test_connection(self.central) then if not self._test_connection(self.central) then
self.central = self._connect(self.config.central) self.central = self._connect(self.config.central)
end end
@ -77,15 +78,17 @@ end
"start_time", start_time, "start_time", start_time,
"duration", duration, "duration", duration,
"caller", caller, "caller", caller,
"callee", callee) "callee", callee,
"source", source)
if res then if res then
self.central:expire(uuid, self.config.expire) self.central:expire(uuid, self.config.expire)
end end
sr.log("info", string.format("central:hset[%s]=>[%s] callid: %s start_time: %s duration: %d caller: %s callee: %s expire: %d\n", sr.log("info", string.format("central:hset[%s]=>[%s] callid: %s start_time: %s duration: %d caller: %s callee: %s caller_id: %s callee_id: %s expire: %d\n",
uuid, tostring(res), uuid, tostring(res),
callid, callid,
start_time, duration, start_time, duration,
caller, callee, caller, callee,
source,
self.config.expire)) self.config.expire))
return res return res
end end

7
tests/ngcp_recentcalls.lua
Unescape View File

@ -79,19 +79,22 @@ TestNGCPRecentCalls = {} --class
local duration = 11 local duration = 11
local caller = "437712345" local caller = "437712345"
local callee = "437754321" local callee = "437754321"
local source = "SIPWISE_1"
self.central:ping() ;mc :returns(true) self.central:ping() ;mc :returns(true)
self.central:hmset(uuid, "callid", callid, self.central:hmset(uuid, "callid", callid,
"start_time", start_time, "start_time", start_time,
"duration", duration, "duration", duration,
"caller", caller, "caller", caller,
"callee", callee) ;mc :returns(true) "callee", callee,
"source", source) ;mc :returns(true)
self.central:expire(uuid, ttl) ;mc :returns(1) self.central:expire(uuid, ttl) ;mc :returns(1)
mc:replay() mc:replay()
local res = self.rcalls:set_by_uuid(uuid, callid, local res = self.rcalls:set_by_uuid(uuid, callid,
start_time, duration, start_time, duration,
caller, callee) caller, callee,
source)
mc:verify() mc:verify()
assertTrue(res) assertTrue(res)

Write Preview
Loading…
Cancel
Save