summaryrefslogtreecommitdiff
path: root/misc/freeswitch/scripts/dialplan/route.lua
diff options
context:
space:
mode:
authorStefan Wintermeyer <stefan.wintermeyer@amooma.de>2012-12-17 12:01:45 +0100
committerStefan Wintermeyer <stefan.wintermeyer@amooma.de>2012-12-17 12:01:45 +0100
commitb80bd744ad873f6fc43018bc4bfb90677de167bd (patch)
tree072c4b0e33d442528555b82c415f5e7a1712b2b0 /misc/freeswitch/scripts/dialplan/route.lua
parent3e706c2025ecc5523e81ad649639ef2ff75e7bac (diff)
Start of GS5.
Diffstat (limited to 'misc/freeswitch/scripts/dialplan/route.lua')
-rw-r--r--misc/freeswitch/scripts/dialplan/route.lua265
1 files changed, 265 insertions, 0 deletions
diff --git a/misc/freeswitch/scripts/dialplan/route.lua b/misc/freeswitch/scripts/dialplan/route.lua
new file mode 100644
index 0000000..2243cbe
--- /dev/null
+++ b/misc/freeswitch/scripts/dialplan/route.lua
@@ -0,0 +1,265 @@
+-- Gemeinschaft 5 module: routing class
+-- (c) AMOOMA GmbH 2012
+--
+
+module(...,package.seeall)
+
+Route = {}
+
+-- create route object
+function Route.new(self, arg)
+ arg = arg or {}
+ object = arg.object or {}
+ setmetatable(object, self);
+ self.__index = self;
+ self.log = arg.log;
+ self.database = arg.database;
+ self.routing_table = arg.routing_table;
+ self.expandable = arg.expandable or {};
+ return object;
+end
+
+-- find matching routes
+function Route.prerouting(self, caller, number)
+ require 'common.routing_tables'
+
+ for index, routing_entry in pairs(self.routing_table.prerouting) do
+ local route = common.routing_tables.match_route(routing_entry, number);
+ if route.error then
+ self.log:error('PREROUTE - error: ', route.error);
+ elseif route.value then
+ self.log:info('ROUTE_PREROUTING - called number: ', number, ', value: ', route.value, ', pattern: ', route.pattern);
+ return route;
+ end
+ end
+end
+
+-- find matching routes
+function Route.outbound(self, caller, number)
+ local routes = {};
+ require 'common.routing_tables'
+ require 'common.str'
+
+ local ignore_arguments = {
+ class=true,
+ endpoint=true,
+ pattern=true,
+ value=true,
+ group=true,
+ phrase=true,
+ }
+
+ local clip_no_screening = common.str.try(caller, 'account.record.clip_no_screening');
+ local caller_id_numbers = {}
+ if not common.str.blank(clip_no_screening) then
+ for index, number in ipairs(common.str.strip_to_a(clip_no_screening, ',')) do
+ table.insert(caller_id_numbers, number);
+ end
+ end
+ for index, number in ipairs(caller.caller_phone_numbers) do
+ table.insert(caller_id_numbers, number);
+ end
+ self.log:info('CALLER_ID_NUMBER - caller_id_numbers: ', table.concat(caller_id_numbers, ','));
+
+ for index, routing_entry in pairs(self.routing_table.outbound) do
+ local route = common.routing_tables.match_route(routing_entry, number);
+ if route.error then
+ self.log:error('ROUTE_OUTBOUND - error: ', route.error);
+ elseif route.value then
+ local valid_route = true;
+
+ for argument, value in pairs(route) do
+ if not ignore_arguments[argument] then
+ local table_value = common.str.downcase(tostring(common.str.try(caller, argument)));
+ value = common.str.downcase(tostring(value));
+ if table_value:match(value) then
+ self.log:info('ROUTE_OUTBOUND_POSITIVE - ', argument, '=', value, ' ~ ', table_value, ', pattern: ', route.pattern);
+ else
+ self.log:info('ROUTE_OUTBOUND_NEGATIVE - ', argument, '=', value, ' !~ ', table_value, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+ end
+
+ if route.group then
+ if common.str.try(caller.auth_account, 'owner.groups.' .. tostring(route.group)) then
+ self.log:info('ROUTE_OUTBOUND_POSITIVE - group=', route.group, ', pattern: ', route.pattern);
+ else
+ self.log:info('ROUTE_OUTBOUND_NEGATIVE - group=', route.group, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+
+ if route.cidn then
+ if caller.caller_id_number:match(route.cidn) then
+ self.log:info('ROUTE_OUTBOUND_POSITIVE - cidn=', route.cidn, ' ~ ', caller.caller_id_number,', pattern: ', route.pattern);
+ else
+ self.log:info('ROUTE_OUTBOUND_NEGATIVE - cidn=', route.cidn, ' !~ ', caller.caller_id_number, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+
+ if valid_route then
+ if route.class ~= 'hangup' then
+ route.caller_id_number = self:outbound_cid_number(caller, caller_id_numbers, route.endpoint, route.class);
+ self.expandable.caller_id_number = route.caller_id_number;
+ route.caller_id_name = self:outbound_cid_name(caller, route.endpoint, route.class);
+ end
+ table.insert(routes, route);
+ self.log:info('ROUTE_OUTBOUND ', #routes,' - ', route.class, '=', route.endpoint, ', value: ', route.value, ', caller_id_number: ', route.caller_id_number, ', caller_id_name: ', route.caller_id_name);
+ end
+ end
+ end
+
+ return routes;
+end
+
+
+function Route.inbound(self, caller, number)
+ require 'common.routing_tables'
+
+ local ignore_arguments = {
+ class=true,
+ endpoint=true,
+ pattern=true,
+ value=true,
+ group=true,
+ phrase=true,
+ }
+
+ for index, routing_entry in pairs(self.routing_table.inbound) do
+ local route = common.routing_tables.match_route(routing_entry, number);
+ if route.error then
+ self.log:error('ROUTE_INBOUND - error: ', route.error);
+ elseif route.value then
+ local valid_route = true;
+
+ for argument, value in pairs(route) do
+ if not ignore_arguments[argument] then
+ local table_value = common.str.downcase(tostring(common.str.try(caller, argument)));
+ value = common.str.downcase(tostring(value));
+ if table_value:match(value) then
+ self.log:info('ROUTE_INBOUND_POSITIVE - ', argument, '=', value, ' ~ ', table_value, ', pattern: ', route.pattern);
+ else
+ self.log:info('ROUTE_INBOUND_NEGATIVE - ', argument, '=', value, ' !~ ', table_value, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+ end
+
+ if route.class and route.endpoint then
+ if route.class == 'gateway' and caller.gateway_name:match(route.endpoint) then
+ self.log:info('ROUTE_INBOUND_POSITIVE - ', route.class, '=', route.endpoint, ' ~ ', caller.gateway_name, ', pattern: ', route.pattern);
+ else
+ self.log:info('ROUTE_INBOUND_NEGATIVE - ', route.class, '=', route.endpoint, ' !~ ', caller.gateway_name, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+
+ if valid_route then
+ self.log:info('ROUTE_INBOUND - called number: ', number, ', value: ', route.value, ', pattern: ', route.pattern);
+ return route;
+ end
+ end
+ end
+end
+
+-- find caller id
+function Route.caller_id(self, caller, cid_entry, search_str, endpoint, class)
+ local ignore_arguments = {
+ class=true,
+ endpoint=true,
+ pattern=true,
+ value=true,
+ group=true,
+ phrase=true,
+ }
+
+ local route = common.routing_tables.match_route(cid_entry, search_str, self.expandable);
+ if route.error then
+ self.log:error('CALLER_ID - error: ', route.error);
+ elseif route.value then
+ local valid_route = true;
+
+ for argument, value in pairs(route) do
+ if not ignore_arguments[argument] then
+ local table_value = common.str.downcase(tostring(common.str.try(caller, argument)));
+ value = common.str.downcase(tostring(value));
+ if table_value:match(value) then
+ self.log:debug('CALLER_ID_POSITIVE - ', argument, '=', value, ' ~ ', table_value, ', pattern: ', route.pattern);
+ else
+ self.log:debug('CALLER_ID_NEGATIVE - ', argument, '=', value, ' !~ ', table_value, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+ end
+
+ if route.group then
+ if common.str.try(caller.auth_account, 'owner.groups.' .. tostring(route.group)) then
+ self.log:debug('CALLER_ID_POSITIVE - group=', route.group, ', pattern: ', route.pattern);
+ else
+ self.log:debug('CALLER_ID_NEGATIVE - group=', route.group, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+
+ endpoint = tostring(endpoint);
+ if route.class and route.endpoint then
+ if route.class == 'gateway' and endpoint:match(route.endpoint) then
+ self.log:debug('CALLER_ID_POSITIVE - ', route.class, '=', route.endpoint, ' ~ ', endpoint, ', pattern: ', route.pattern);
+ else
+ self.log:debug('CALLER_ID_NEGATIVE - ', route.class, '=', route.endpoint, ' !~ ', endpoint, ', pattern: ', route.pattern);
+ valid_route = false;
+ end
+ end
+
+ if valid_route then
+ self.log:debug('CALLER_ID ', route.class, '=', route.endpoint, ', value: ', route.value);
+ return route.value;
+ end
+ end
+
+ return nil;
+end
+
+-- find matching caller id number
+function Route.outbound_cid_number(self, caller, caller_id_numbers, endpoint, class)
+ for route_index, cid_entry in pairs(self.routing_table.outbound_cid_number) do
+ for index, number in ipairs(caller_id_numbers) do
+ local route = self:caller_id(caller, cid_entry, number, endpoint, class);
+ if route then
+ return route;
+ end
+ end
+ end
+end
+
+-- find matching caller id name
+function Route.outbound_cid_name(self, caller, endpoint, class)
+ for route_index, cid_entry in pairs(self.routing_table.outbound_cid_name) do
+ local route = self:caller_id(caller, cid_entry, caller.caller_id_name, endpoint, class);
+ if route then
+ return route;
+ end
+ end
+end
+
+-- find matching caller id number
+function Route.inbound_cid_number(self, caller, endpoint, class)
+ for route_index, cid_entry in pairs(self.routing_table.inbound_cid_number) do
+ local route = self:caller_id(caller, cid_entry, caller.caller_id_number, endpoint, class);
+ if route then
+ return route;
+ end
+ end
+end
+
+-- find matching caller id name
+function Route.inbound_cid_name(self, caller, endpoint, class)
+ for route_index, cid_entry in pairs(self.routing_table.inbound_cid_name) do
+ local route = self:caller_id(caller, cid_entry, caller.caller_id_name, endpoint, class);
+ if route then
+ return route;
+ end
+ end
+end