summaryrefslogtreecommitdiff
path: root/misc/freeswitch/scripts/dialplan/callthrough.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/callthrough.lua
parent3e706c2025ecc5523e81ad649639ef2ff75e7bac (diff)
Start of GS5.
Diffstat (limited to 'misc/freeswitch/scripts/dialplan/callthrough.lua')
-rw-r--r--misc/freeswitch/scripts/dialplan/callthrough.lua148
1 files changed, 148 insertions, 0 deletions
diff --git a/misc/freeswitch/scripts/dialplan/callthrough.lua b/misc/freeswitch/scripts/dialplan/callthrough.lua
new file mode 100644
index 0000000..69a0611
--- /dev/null
+++ b/misc/freeswitch/scripts/dialplan/callthrough.lua
@@ -0,0 +1,148 @@
+-- CommonModule: Callthrough
+--
+module(...,package.seeall)
+
+Callthrough = {}
+
+-- Create Callthrough object
+function Callthrough.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.record = arg.record
+ self.access_authorizations = arg.access_authorizations
+ return object
+end
+
+-- Find Callthrough by ID
+function Callthrough.find_by_id(self, id)
+ local sql_query = string.format("SELECT * FROM `callthroughs` WHERE `id`=%d LIMIT 1", id)
+ local record = nil
+
+ self.database:query(sql_query, function(callthrough_entry)
+ record = callthrough_entry
+ end)
+
+ if record then
+ local callthrough = Callthrough:new(self);
+ callthrough.record = record
+
+ require 'dialplan.access_authorizations'
+ callthrough.access_authorizations = dialplan.access_authorizations.AccessAuthorization:new{ log = self.log, database = self.database }:list_by_owner(record.id, 'Callthrough');
+ return callthrough
+ end
+
+ return nil
+end
+
+function Callthrough.authenticate(self, caller)
+ local authorizations = {}
+ local logins = {}
+ local pins = {}
+
+ caller:answer();
+ caller:sleep(1000);
+
+ if not self.access_authorizations or table.getn(self.access_authorizations) == 0 then
+ self.log:debug('CALLTHROUGH_AUTHENTICATE - authorization disabled');
+ return true;
+ end
+
+ self.log:debug('CALLTHROUGH_AUTHENTICATE - access_authorizations: ', #self.access_authorizations);
+ for index, authorization in ipairs(self.access_authorizations) do
+ if authorization.phone_number then
+ if authorization.phone_number == caller.caller_phone_number then
+ if authorization.pin and authorization.pin ~= "" then
+ if caller.session:read(authorization.pin:len(), authorization.pin:len(), "ivr/ivr-please_enter_pin_followed_by_pound.wav", 3000, "#") ~= authorization.pin then
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Wrong PIN");
+ return false;
+ else
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by caller id: " .. caller.caller_phone_number .. " and PIN");
+ return authorization;
+ end
+ end
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by caller id: " .. caller.caller_phone_number);
+ return authorization;
+ end
+ else
+ self.log:debug('CALLTHROUGH_AUTHENTICATE - access_authorization=', authorization.id);
+ if authorization.id then
+ authorizations[authorization.id] = authorization;
+ if authorization.login and authorization.login ~= "" then
+ logins[authorization.login] = authorization;
+ elseif authorization.pin and authorization.pin ~= "" then
+ pins[authorization.pin] = authorization;
+ end
+ end
+ end
+ end
+
+ local login = nil;
+ local pin = nil;
+
+
+ if next(logins) ~= nil then
+
+ caller.session:streamFile('ivr/ivr-please_enter_the.wav');
+ caller.session:streamFile('ivr/ivr-id_number.wav');
+ login = caller.session:read(2, 10, 'ivr/ivr-followed_by_pound.wav', 3000, '#');
+ end
+
+ if login and logins[tostring(login)] then
+ if not logins[tostring(login)].pin or logins[tostring(login)].pin == '' then
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by login: " .. login .. " without PIN");
+ return logins[tostring(login)];
+ end
+ pin = caller.session:read(2, 10, "ivr/ivr-please_enter_pin_followed_by_pound.wav", 3000, "#");
+ if logins[tostring(login)].pin == pin then
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by login: " .. login .. " and PIN");
+ return logins[tostring(login)];
+ else
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Wrong PIN");
+ return false
+ end
+ end
+
+ if next(pins) ~= nil then
+ pin = caller.session:read(2, 10, "ivr/ivr-please_enter_pin_followed_by_pound.wav", 3000, "#");
+ end
+
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - No such login, try PIN");
+
+ if pin and pins[tostring(pin)] then
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by PIN");
+ return pins[tostring(pin)];
+ end
+
+ self.log:debug("CALLTHROUGH_AUTHENTICATE - No login, wrong PIN - giving up");
+
+ return false;
+end
+
+function Callthrough.whitelist(self, number)
+ local sql_query = 'SELECT `id` FROM `whitelists` WHERE `whitelistable_type` = "Callthrough" AND `whitelistable_id` = ' .. self.record.id;
+ local whitelist_ids = {}
+
+ self.database:query(sql_query, function(entry)
+ table.insert(whitelist_ids, entry.id);
+ end)
+
+ if next(whitelist_ids) == nil then
+ return true;
+ end
+
+ -- OPTIMIZE Make sure number contains only valid characters
+ local sql_query = 'SELECT `id` FROM `phone_numbers` WHERE \
+ `number` = "' .. number .. '" AND \
+ `phone_numberable_type` = "Whitelist" AND `phone_numberable_id` IN (' .. table.concat(whitelist_ids, ',') .. ') LIMIT 1';
+
+ local authorized = false
+ self.database:query(sql_query, function(entry)
+ authorized = true
+ end)
+
+ return authorized;
+end