summaryrefslogtreecommitdiff
path: root/misc/freeswitch/scripts/configuration.lua
diff options
context:
space:
mode:
authorStefan Wintermeyer <stefan.wintermeyer@amooma.de>2013-01-22 15:33:06 +0100
committerStefan Wintermeyer <stefan.wintermeyer@amooma.de>2013-01-22 15:33:06 +0100
commit39aa7132ceed3d4beab3a9b828e571bbfc67c07e (patch)
tree6c88289c9f99be0af8635636fcdf64102090e5ec /misc/freeswitch/scripts/configuration.lua
parent5ad8203ce4f1bfea997960d0b52c626dea24b944 (diff)
parent6f69c1a85055ec7c2515719d79d2a7a4e60cec50 (diff)
Merge branch 'develop'5.1-beta1
Diffstat (limited to 'misc/freeswitch/scripts/configuration.lua')
-rw-r--r--misc/freeswitch/scripts/configuration.lua399
1 files changed, 341 insertions, 58 deletions
diff --git a/misc/freeswitch/scripts/configuration.lua b/misc/freeswitch/scripts/configuration.lua
index 906d3f8..9e62bb6 100644
--- a/misc/freeswitch/scripts/configuration.lua
+++ b/misc/freeswitch/scripts/configuration.lua
@@ -1,8 +1,11 @@
-- Gemeinschaft 5 dynamic freeswitch configuration
--- (c) AMOOMA GmbH 2012
+-- (c) AMOOMA GmbH 2012-2013
--
function nodes(database, local_node_id)
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
local gateways_xml = '';
require 'common.node'
@@ -14,86 +17,162 @@ function nodes(database, local_node_id)
node_parameters['proxy'] = node_record.ip_address;
node_parameters['register'] = 'false';
log:debug('NODE_GATEWAY ', node_record.id, ' - name: ', node_record.name, ', address: ', node_record.ip_address);
- gateways_xml = gateways_xml .. xml:gateway(node_record.name, node_parameters);
+ gateways_xml = gateways_xml .. xml:element{
+ 'gateway',
+ name = node_record.name,
+ xml:from_hash('param', node_parameters, 'name', 'value'),
+ };
end
end
return gateways_xml;
end
-function gateways(profile_name)
- local gateways_xml = '';
- local gateways = common.configuration_file.get('/opt/freeswitch/scripts/ini/gateways.ini', false);
- if not gateways then
- return '';
- end
+function gateways(database, profile_name)
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
+ require 'common.str'
- for sofia_gateway, gateway_parameters in pairs(gateways) do
- if tostring(gateway_parameters.profile) == profile_name then
- log:debug('GATEWAY - name: ', sofia_gateway, ', address: ', gateway_parameters.proxy);
- gateways_xml = gateways_xml .. xml:gateway(sofia_gateway, gateway_parameters);
+ require 'common.gateway'
+ local gateway_class = common.gateway.Gateway:new{ log = log, database = database};
+ local gateways = gateway_class:list('sip');
+
+ local gateways_xml = '';
+ for index=1, #gateways do
+ local gateway = gateways[index];
+ local gateway_profile = gateway_class:profile_get(gateway.id);
+ if tostring(gateway_profile) == profile_name or (profile_name == 'gemeinschaft' and common.str.blank(gateway_profile)) then
+ log:debug('GATEWAY - name: ', gateway.name);
+ local parameters = gateway_class:parameters_build(gateway.id);
+
+ gateways_xml = gateways_xml .. xml:element{
+ 'gateway',
+ name = gateway_class.GATEWAY_PREFIX .. gateway.id,
+ xml:from_hash('param', parameters, 'name', 'value'),
+ };
end
end
return gateways_xml;
end
+
function profile(database, sofia_ini, profile_name, index, domains, node_id)
- local profile_parameters = sofia_ini['profile:' .. profile_name];
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
+ local parameters = sofia_ini['profile:' .. profile_name];
- if not profile_parameters then
+ if not parameters then
log:error('SOFIA_PROFILE ', index,' - name: ', profile_name, ' - no parameters');
return '';
end
+
+ if tostring(parameters['odbc-dsn']) == 'default' then
+ parameters['odbc-dsn'] = 'gemeinschaft:' .. tostring(database.user_name) .. ':' .. tostring(database.password);
+ end
+
-- set local bind address
if domains[index] then
- profile_parameters['sip-ip'] = domains[index]['host'];
- profile_parameters['rtp-ip'] = domains[index]['host'];
- profile_parameters['force-register-domain'] = domains[index]['host'];
- profile_parameters['force-subscription-domain'] = domains[index]['host'];
- profile_parameters['force-register-db-domain'] = domains[index]['host'];
- log:debug('SOFIA_PROFILE ', index,' - name: ', profile_name, ', domain: ', domains[index]['host'], ', sip_bind: ', profile_parameters['sip-ip'], ':', profile_parameters['sip-port']);
+ parameters['sip-ip'] = domains[index]['host'];
+ parameters['rtp-ip'] = domains[index]['host'];
+ parameters['force-register-domain'] = domains[index]['host'];
+ parameters['force-subscription-domain'] = domains[index]['host'];
+ parameters['force-register-db-domain'] = domains[index]['host'];
+ log:debug('SOFIA_PROFILE ', index,' - name: ', profile_name, ', domain: ', domains[index]['host'], ', sip_bind: ', parameters['sip-ip'], ':', parameters['sip-port']);
else
- log:error('SOFIA_PROFILE ', index,' - name: ', profile_name, ' - no domains');
+ log:debug('SOFIA_PROFILE ', index,' - name: ', profile_name, ' - no domains');
end
- local gateways_xml = gateways(profile_name);
+ local gateways_xml = gateways(database, profile_name);
if index == 1 then
gateways_xml = gateways_xml .. nodes(database, node_id);
end
- return xml:sofia_profile(profile_name, profile_parameters, gateways_xml);
+ local profile_xml = xml:element{
+ 'profile',
+ name = profile_name,
+ xml:element{
+ 'gateways',
+ gateways_xml,
+ },
+ xml:element{
+ 'domains',
+ xml:element{
+ 'domain',
+ name = 'all',
+ alias = 'true',
+ parse = 'false',
+ },
+ },
+ xml:element{
+ 'settings',
+ xml:from_hash('param', parameters, 'name', 'value'),
+ },
+ };
+
+ return profile_xml;
end
+
-- generate sofia.conf
function conf_sofia(database)
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
+ require 'common.configuration_table'
local sofia_profile = "gemeinschaft";
- require 'common.configuration_file'
- local sofia_ini = common.configuration_file.get('/opt/freeswitch/scripts/ini/sofia.ini');
- local dialplan_parameters = common.configuration_file.get('/opt/freeswitch/scripts/ini/dialplan.ini', 'parameters');
+ local sofia_ini = common.configuration_table.get(database, 'sofia');
+ local dialplan_parameters = common.configuration_table.get(database, 'dialplan', 'parameters');
- local local_node_id = tonumber(dialplan_parameters['node_id']) or 1;
+ local local_node_id = tonumber(dialplan_parameters.node_id) or 1;
require 'configuration.sip'
local domains = configuration.sip.Sip:new{ log = log, database = database}:domains();
sofia_profiles_xml = '';
- for index, profile_name in ipairs(sofia_ini.profiles) do
- sofia_profiles_xml = sofia_profiles_xml .. profile(database, sofia_ini, profile_name, index, domains, local_node_id);
+ for profile_name, index in pairs(sofia_ini.profiles) do
+ if tonumber(index) and tonumber(index) > 0 then
+ sofia_profiles_xml = sofia_profiles_xml .. profile(database, sofia_ini, profile_name, tonumber(index), domains, local_node_id);
+ end
end
- XML_STRING = xml:document(xml:sofia(sofia_ini.parameters, sofia_profiles_xml))
+ XML_STRING = xml:element{
+ 'document',
+ ['type'] = 'freeswitch/xml',
+ xml:element{
+ 'section',
+ name = 'configuration',
+ description = 'Gemeinschaft 5 FreeSWITCH configuration',
+ xml:element{
+ 'configuration',
+ name = 'sofia.conf',
+ description = 'Sofia configuration',
+ xml:element{
+ 'global_settings',
+ xml:from_hash('param', sofia_ini.parameters, 'name', 'value'),
+ },
+ xml:element{
+ 'profiles',
+ sofia_profiles_xml,
+ },
+ },
+ },
+ };
+
end
function conf_conference(database)
- XML_STRING = xml:document(xml:conference());
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
- require 'common.configuration_file'
- local conference_ini = common.configuration_file.get('/opt/freeswitch/scripts/ini/conferences.ini');
- local conference_parameters = conference_ini.parameters;
+ require 'common.configuration_table'
+ local config = common.configuration_table.get(database, 'conferences');
+ local profiles = nil;
local event_name = params:getHeader("Event-Name")
if event_name == 'COMMAND' then
@@ -105,8 +184,15 @@ function conf_conference(database)
conference = common.conference.Conference:new{log=log, database=database}:find_by_id(conf_name);
if conference then
log:debug('CONFIG_CONFERENCE ', conf_name, ' name: ', conference.record.name, ', profile: ', profile_name);
- conference_parameters['caller-id-name'] = conference.record.name or '';
- XML_STRING = xml:document(xml:conference(xml:conference_profile(profile_name, conference_parameters)));
+ config.parameters['caller-id-name'] = conference.record.name or '';
+ profiles = xml:element{
+ 'profiles',
+ xml:element{
+ 'profile',
+ name = profile_name,
+ xml:from_hash('param', config.parameters, 'name', 'value'),
+ },
+ };
else
log:error('CONFIG_CONFERENCE ', conf_name, ' - conference not found');
end
@@ -116,61 +202,251 @@ function conf_conference(database)
else
log:debug('CONFIG_CONFERENCE ', conf_name, ' - event: ', event_name);
end
+
+ XML_STRING = xml:element{
+ 'document',
+ ['type'] = 'freeswitch/xml',
+ xml:element{
+ 'section',
+ name = 'configuration',
+ description = 'Gemeinschaft 5 FreeSWITCH configuration',
+ xml:element{
+ 'configuration',
+ name = 'conference.conf',
+ description = 'Conference configuration',
+ xml:element{
+ 'caller-controls',
+ xml:element{
+ 'group',
+ name = 'speaker',
+ xml:from_hash('control', config.controls_speaker, 'action', 'digits'),
+ },
+ xml:element{
+ 'group',
+ name = 'moderator',
+ xml:from_hash('control', config.controls_moderator, 'action', 'digits'),
+ },
+ },
+ profiles,
+ },
+ },
+ };
+end
+
+function conf_voicemail(database)
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
+ require 'common.configuration_table';
+ local parameters = common.configuration_table.get(database, 'voicemail', 'parameters');
+
+ if tostring(parameters['odbc-dsn']) == 'default' then
+ parameters['odbc-dsn'] = 'gemeinschaft:' .. tostring(database.user_name) .. ':' .. tostring(database.password);
+ end
+
+ XML_STRING = xml:element{
+ 'document',
+ ['type'] = 'freeswitch/xml',
+ xml:element{
+ 'section',
+ name = 'configuration',
+ description = 'Gemeinschaft 5 FreeSWITCH configuration',
+ xml:element{
+ 'configuration',
+ name = 'voicemail.conf',
+ description = 'Voicemail configuration',
+ xml:element{
+ 'profiles',
+ xml:element{
+ 'profile',
+ name = 'default',
+ xml:from_hash('param', parameters, 'name', 'value'),
+ },
+ },
+ },
+ },
+ };
+end
+
+function conf_post_switch(database)
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
+ require 'common.configuration_table';
+ local parameters = common.configuration_table.get(database, 'post_load_switch', 'settings');
+
+ XML_STRING = xml:element{
+ 'document',
+ ['type'] = 'freeswitch/xml',
+ xml:element{
+ 'section',
+ name = 'configuration',
+ description = 'Gemeinschaft 5 FreeSWITCH configuration',
+ xml:element{
+ 'configuration',
+ name = 'post_load_switch.conf',
+ description = 'Switch configuration',
+ xml:element{
+ 'settings',
+ xml:from_hash('param', parameters, 'name', 'value'),
+ },
+ },
+ },
+ };
end
function directory_sip_account(database)
+ require 'configuration.simple_xml'
+ local xml = configuration.simple_xml.SimpleXml:new();
+
local key = params:getHeader('key');
local auth_name = params:getHeader('user');
local domain = params:getHeader('domain');
local purpose = params:getHeader('purpose');
+ local user_xml = nil;
+
if auth_name and auth_name ~= '' then
-- sip account or gateway
if string.len(auth_name) > 3 and auth_name:sub(1, 3) == 'gw+' then
local gateway_name = auth_name:sub(4);
domain = domain or freeswitch.API():execute('global_getvar', 'domain');
- require 'configuration.sip'
- log:notice('DATABASE: ', database);
- local sip_gateway = configuration.sip.Sip:new{ log = log, database = database}:find_gateway_by_name(gateway_name);
- if sip_gateway ~= nil and next(sip_gateway) ~= nil then
+ require 'common.gateway'
+ local sip_gateway = common.gateway.Gateway:new{ log = self.log, database = self.database }:find_by_name(gateway_name);
+ if sip_gateway then
log:debug('DIRECTORY_GATEWAY - name: ', gateway_name, ', auth_name: ', auth_name);
- XML_STRING = xml:document(xml:directory(xml:gateway_user(sip_gateway, gateway_name, auth_name), domain));
+
+ local user_variables = {
+ user_context = "default",
+ gs_from_gateway = "true",
+ gs_gateway_name = gateway_name,
+ gs_gateway_id = sip_gateway.id,
+ }
+
+ user_xml = xml:element{
+ 'user',
+ id = auth_name,
+ xml:element{
+ 'params',
+ xml:element{
+ 'param',
+ password = sip_gateway.record.password,
+ }
+ },
+ xml:element{
+ 'variables',
+ xml:from_hash('variable', user_variables, 'name', 'value'),
+ },
+ };
else
log:debug('DIRECTORY_GATEWAY - gateway not found - name: ', gateway_name, ', auth_name: ', auth_name);
end
else
require 'common.sip_account'
local sip_account = common.sip_account.SipAccount:new{ log = log, database = database}:find_by_auth_name(auth_name, domain);
+
+ require 'common.configuration_table'
+ local user_parameters = common.configuration_table.get(database, 'sip_accounts', 'parameters');
+
if sip_account ~= nil then
+ user_parameters['password'] = sip_account.record.password;
+ user_parameters['vm-password'] = sip_account.record.voicemail_pin;
+
+ local user_variables = {
+ user_context = "default",
+ gs_from_gateway = "false",
+ gs_account_id = sip_account.record.id,
+ gs_account_uuid = sip_account.record.uuid,
+ gs_account_type = "SipAccount",
+ gs_account_state = sip_account.record.state,
+ gs_account_caller_name = sip_account.record.caller_name,
+ gs_account_owner_type = sip_account.record.sip_accountable_type,
+ gs_account_owner_id = sip_account.record.sip_accountable_id
+ }
+
if tostring(purpose) == 'publish-vm' then
log:debug('DIRECTORY_SIP_ACCOUNT - purpose: VoiceMail, auth_name: ', sip_account.record.auth_name, ', caller_name: ', sip_account.record.caller_name, ', domain: ', domain);
- XML_STRING = xml:document(xml:directory(xml:group_default(xml:user(sip_account.record)), domain));
+ user_xml = xml:element{
+ 'groups',
+ xml:element{
+ 'group',
+ name = 'default',
+ xml:element{
+ 'users',
+ xml:element{
+ 'user',
+ id = sip_account.record.auth_name,
+ xml:element{
+ 'params',
+ xml:from_hash('param', user_parameters, 'name', 'value'),
+ },
+ xml:element{
+ 'variables',
+ xml:from_hash('variable', user_variables, 'name', 'value'),
+ },
+ },
+ },
+ },
+ };
else
log:debug('DIRECTORY_SIP_ACCOUNT - auth_name: ', sip_account.record.auth_name, ', caller_name: ', sip_account.record.caller_name, ', domain: ', domain);
- XML_STRING = xml:document(xml:directory(xml:user(sip_account.record), domain));
+
+ user_xml = xml:element{
+ 'user',
+ id = sip_account.record.auth_name,
+ xml:element{
+ 'params',
+ xml:from_hash('param', user_parameters, 'name', 'value'),
+ },
+ xml:element{
+ 'variables',
+ xml:from_hash('variable', user_variables, 'name', 'value'),
+ },
+ };
end
else
log:debug('DIRECTORY_SIP_ACCOUNT - sip account not found - auth_name: ', auth_name, ', domain: ', domain);
-- fake sip_account configuration
- sip_account = {
- auth_name = auth_name,
- id = 0,
- uuid = '',
- password = tostring(math.random(0, 65534)),
- voicemail_pin = '',
- state = 'inactive',
- caller_name = '',
- sip_accountable_type = 'none',
- sip_accountable_id = 0,
- }
- XML_STRING = xml:document(xml:directory(xml:user(sip_account), domain))
+ user_parameters['password'] = tostring(math.random(0, 65534));
+ user_parameters['vm-password'] = '';
+
+ user_xml = xml:element{
+ 'user',
+ id = auth_name,
+ xml:element{
+ 'params',
+ xml:from_hash('param', user_parameters, 'name', 'value'),
+ },
+ };
end
end
elseif tostring(XML_REQUEST.key_name) == 'name' and tostring(XML_REQUEST.key_value) ~= '' then
log:debug('DOMAIN_DIRECTORY - domain: ', XML_REQUEST.key_value);
XML_STRING = xml:document(xml:directory(nil, XML_REQUEST.key_value));
end
+
+ XML_STRING = xml:element{
+ 'document',
+ ['type'] = 'freeswitch/xml',
+ xml:element{
+ 'section',
+ name = 'directory',
+ xml:element{
+ 'domain',
+ name = domain,
+ xml:element{
+ 'params',
+ xml:element{
+ 'param',
+ name = 'dial-string',
+ value = '${sofia_contact(${dialed_user}@${dialed_domain})}',
+ },
+ },
+ user_xml,
+ },
+ },
+ };
end
@@ -182,9 +458,12 @@ log = common.log.Log:new();
log.prefix = '#C# [' .. log_identifier .. '] ';
-- return a valid xml document
-require 'configuration.freeswitch_xml'
-xml = configuration.freeswitch_xml.FreeSwitchXml:new();
-XML_STRING = xml:document();
+require 'configuration.simple_xml'
+local xml = configuration.simple_xml.SimpleXml:new();
+XML_STRING = xml:element{
+ 'document',
+ ['type'] = 'freeswitch/xml',
+};
local database = nil;
@@ -203,6 +482,10 @@ if XML_REQUEST.section == 'configuration' and XML_REQUEST.tag_name == 'configura
conf_sofia(database);
elseif XML_REQUEST.key_value == "conference.conf" then
conf_conference(database);
+ elseif XML_REQUEST.key_value == "voicemail.conf" then
+ conf_voicemail(database);
+ elseif XML_REQUEST.key_value == "post_load_switch.conf" then
+ conf_post_switch(database);
end
elseif XML_REQUEST.section == 'directory' and XML_REQUEST.tag_name == '' then
log:debug('SIP_ACCOUNT_DIRECTORY - initialization phase');