Merge branch 'develop'5.1-beta1

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');