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

MT#12025 move NGCPConfig to new config.lua file

Browse Source 
Change-Id: I5ce296dd8cd77317b642e0b5988487bf8922d3b3
(cherry picked from commit 9afb7095d7)
changes/31/2531/1
Victor Seva 10 years ago
parent 44a1342c1e
commit d12267b1c2
6 changed files with 125 additions and 100 deletions
Show Stats Download Patch File Download Diff File

119
ngcp/config.lua
Unescape View File

@ -0,0 +1,119 @@
--
-- Copyright 2015 SipWise Team <development@sipwise.com>
--
-- This program is free software: you can redistribute it and/or modify
-- it under the terms of the GNU General Public License as published by
-- the Free Software Foundation, either version 3 of the License, or
-- (at your option) any later version.
--
-- This package is distributed in the hope that it will be useful,
-- but WITHOUT ANY WARRANTY; without even the implied warranty of
-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-- GNU General Public License for more details.
--
-- You should have received a copy of the GNU General Public License
-- along with this program. If not, see <http://www.gnu.org/licenses/>.
-- .
-- On Debian systems, the complete text of the GNU General
-- Public License version 3 can be found in "/usr/share/common-licenses/GPL-3".
--
-- load drivers
local driver = require "luasql.mysql"
if not luasql then
luasql = driver
end
-- class NGCPConfig
NGCPConfig = {
__class__ = 'NGCPConfig'
}
NGCPConfig_MT = { __index = NGCPConfig }
function NGCPConfig:new()
local t = {
db_host = "127.0.0.1",
db_port = 3306,
db_username = "kamailio",
db_pass = "somepasswd",
db_database = "kamailio",
default = {
contract = {
},
peer = {
sst_enable = "yes",
sst_expires = 300,
sst_min_timer = 90,
sst_max_timer = 7200,
sst_refresh_method = "UPDATE_FALLBACK_INVITE",
outbound_from_user = "npn",
inbound_upn = "from_user",
inbound_npn = "from_user",
inbound_uprn = "from_user",
ip_header = "P-NGCP-Src-Ip",
},
dom = {
sst_enable = "yes",
sst_expires = 300,
sst_min_timer = 90,
sst_max_timer = 7200,
sst_refresh_method = "UPDATE_FALLBACK_INVITE",
outbound_from_user = "npn",
inbound_upn = "from_user",
inbound_uprn = "from_user",
ip_header = "P-NGCP-Src-Ip",
},
-- just for prefs that are only on usr level
usr = {
account_id = 0,
ext_subscriber_id = "",
ext_contract_id = "",
ringtimeout = 180,
}
}
}
setmetatable( t, NGCPConfig_MT )
return t
end
local function check_connection(c)
local cur = c:execute("SELECT 1")
local row = cur:fetch()
local result = false
if cur:numrows() == 1 then
result = true
end
cur:close()
return result
end
function NGCPConfig:getDBConnection()
if not self.env then
self.env = assert (luasql.mysql())
end
if self.con then
local ok,err = pcall(check_connection, self.con)
if not ok then
self.con = nil
sr.log("dbg", "lost database connection. Reconnecting")
end
end
if not self.con then
sr.log("dbg","connecting to mysql")
self.con = self.env:connect( self.db_database,
self.db_username, self.db_pass, self.db_host, self.db_port)
end
return self.con
end
function NGCPConfig:get_defaults(vtype)
local k,v
local defs = {}
if self.default[vtype] then
for k,v in pairs(self.default[vtype]) do
defs[k] = v
end
end
return defs
end
-- class

100
ngcp/ngcp.lua
Unescape View File

@ -23,105 +23,7 @@ require 'ngcp.pp'
require 'ngcp.dp'
require 'ngcp.up'
require 'ngcp.rp'
-- load drivers
local driver = require "luasql.mysql"
if not luasql then
luasql = driver
end
-- class NGCPConfig
NGCPConfig = {
__class__ = 'NGCPConfig'
}
NGCPConfig_MT = { __index = NGCPConfig }
function NGCPConfig:new()
local t = {
db_host = "127.0.0.1",
db_port = 3306,
db_username = "kamailio",
db_pass = "somepasswd",
db_database = "kamailio",
default = {
contract = {
},
peer = {
sst_enable = "yes",
sst_expires = 300,
sst_min_timer = 90,
sst_max_timer = 7200,
sst_refresh_method = "UPDATE_FALLBACK_INVITE",
outbound_from_user = "npn",
inbound_upn = "from_user",
inbound_npn = "from_user",
inbound_uprn = "from_user",
ip_header = "P-NGCP-Src-Ip",
},
dom = {
sst_enable = "yes",
sst_expires = 300,
sst_min_timer = 90,
sst_max_timer = 7200,
sst_refresh_method = "UPDATE_FALLBACK_INVITE",
outbound_from_user = "npn",
inbound_upn = "from_user",
inbound_uprn = "from_user",
ip_header = "P-NGCP-Src-Ip",
},
-- just for prefs that are only on usr level
usr = {
account_id = 0,
ext_subscriber_id = "",
ext_contract_id = "",
ringtimeout = 180,
}
}
}
setmetatable( t, NGCPConfig_MT )
return t
end
local function check_connection(c)
local cur = c:execute("SELECT 1")
local row = cur:fetch()
local result = false
if cur:numrows() == 1 then
result = true
end
cur:close()
return result
end
function NGCPConfig:getDBConnection()
if not self.env then
self.env = assert (luasql.mysql())
end
if self.con then
local ok,err = pcall(check_connection, self.con)
if not ok then
self.con = nil
sr.log("dbg", "lost database connection. Reconnecting")
end
end
if not self.con then
sr.log("dbg","connecting to mysql")
self.con = self.env:connect( self.db_database,
self.db_username, self.db_pass, self.db_host, self.db_port)
end
return self.con
end
function NGCPConfig:get_defaults(vtype)
local k,v
local defs = {}
if self.default[vtype] then
for k,v in pairs(self.default[vtype]) do
defs[k] = v
end
end
return defs
end
-- class
require 'ngcp.config'
-- class NGCP
NGCP = {

1
tests/ngcp_dp.lua
Unescape View File

@ -39,6 +39,7 @@ package.preload['luasql.mysql'] = function ()
return env
end
end
require 'ngcp.config'
require 'ngcp.dp'
TestNGCPDomainPrefs = {} --class

3
tests/ngcp_pp.lua
Unescape View File

@ -39,7 +39,8 @@ package.preload['luasql.mysql'] = function ()
return env
end
end
require 'ngcp.dp'
require 'ngcp.config'
require 'ngcp.rp'
TestNGCPPeerPrefs = {} --class

1
tests/ngcp_pprof.lua
Unescape View File

@ -39,6 +39,7 @@ package.preload['luasql.mysql'] = function ()
return env
end
end
require 'ngcp.config'
require 'ngcp.pprof'
TestNGCPProfilePrefs = {} --class

1
tests/ngcp_up.lua
Unescape View File

@ -40,6 +40,7 @@ package.preload['luasql.mysql'] = function ()
end
end
require 'ngcp.config'
require 'ngcp.up'
TestNGCPUserPrefs = {} --class

Write Preview
Loading…
Cancel
Save