dbxe
/
fusionpbx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add global intercept capability to intercept.lua, fix a problem with ivr_menu.lua, and white space problem in wakeup.lua.

This commit is contained in:
Mark Crane 2012-12-02 08:38:24 +00:00
parent bbe3759a68
commit 997b63ac85
3 changed files with 47 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
includes/install/scripts/intercept.lua
View File

@ -22,24 +22,39 @@
-- Contributor(s): -- Contributor(s):
-- Mark J Crane <markjcrane@fusionpbx.com> -- Mark J Crane <markjcrane@fusionpbx.com>
max_tries = "3"; --user defined variables
digit_timeout = "5000"; max_tries = "3";
digit_timeout = "5000";
extension = argv[1];
extension = argv[1]; --set the debug options
debug["sql"] = false;
--database --include the lua script
--connect to the database scripts_dir = string.sub(debug.getinfo(1).source,2,string.len(debug.getinfo(1).source)-(string.len(argv[0])+1));
--local dbh = freeswitch.Dbh("dsn","user","pass"); -- when using ODBC include = assert(loadfile(scripts_dir .. "/resources/config.lua")); include();
local dbh = freeswitch.Dbh("core:core"); -- when using sqlite include = loadfile(scripts_dir .. "/resources/local.lua"); if (include ~= nil) then include(); end
--exits the script if we didn't connect properly --connect to the database
--ODBC - data source name
if (switch_dsn_name) then
dbh = freeswitch.Dbh(switch_dsn_name,switch_dsn_username,switch_dsn_password);
end
--FreeSWITCH core db handler
if (db_type == "sqlite") then
dbh = freeswitch.Dbh("core:"..db_path.."/"..db_name);
end
--exit the script if we didn't connect properly
assert(dbh:connected()); assert(dbh:connected());
if ( session:ready() ) then if ( session:ready() ) then
session:answer( ); --answer the session
pin_number = session:getVariable("pin_number"); session:answer();
sounds_dir = session:getVariable("sounds_dir");
domain_name = session:getVariable("domain_name"); --get session variables
pin_number = session:getVariable("pin_number");
sounds_dir = session:getVariable("sounds_dir");
domain_name = session:getVariable("domain_name");
--set the sounds path for the language, dialect and voice --set the sounds path for the language, dialect and voice
default_language = session:getVariable("default_language"); default_language = session:getVariable("default_language");
@ -66,23 +81,31 @@ if ( session:ready() ) then
if (pin_number) then if (pin_number) then
min_digits = string.len(pin_number); min_digits = string.len(pin_number);
max_digits = string.len(pin_number)+1; max_digits = string.len(pin_number)+1;
digits = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/custom/please_enter_the_pin_number.wav", "", "\\d+"); --digits = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/custom/please_enter_the_pin_number.wav", "", "\\d+");
digits = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", "phrase:voicemail_enter_pass:#", "", "\\d+");
if (digits == pin_number) then if (digits == pin_number) then
--pin is correct --pin is correct
else else
session:streamFile(sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/custom/your_pin_number_is_incorect_goodbye.wav"); --session:streamFile(sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/custom/your_pin_number_is_incorect_goodbye.wav");
session:streamFile("phrase:voicemail_fail_auth:#");
session:hangup("NORMAL_CLEARING"); session:hangup("NORMAL_CLEARING");
return; return;
end end
end end
--check the database to get the uuid --check the database to get the uuid of a ringing call
--intercept sql = "select call_uuid as uuid from channels ";
sql = "select call_uuid as uuid from channels where presence_id = '"..extension.."@"..domain_name.."' and callstate = 'RINGING' "; sql = sql .. "where callstate = 'RINGING' ";
if (extension) then
sql = sql .. "and presence_id = '"..extension.."@"..domain_name.."' ";
end
if (debug["sql"]) then
freeswitch.consoleLog("NOTICE", "sql "..sql.."\n");
end
dbh:query(sql, function(result) dbh:query(sql, function(result)
for key, val in pairs(result) do --for key, val in pairs(result) do
freeswitch.consoleLog("NOTICE", "result "..key.." "..val.."\n"); -- freeswitch.consoleLog("NOTICE", "result "..key.." "..val.."\n");
end --end
uuid = result.uuid; uuid = result.uuid;
end); end);

6
includes/install/scripts/ivr_menu.lua
View File

@ -33,8 +33,8 @@
--include the lua script --include the lua script
scripts_dir = string.sub(debug.getinfo(1).source,2,string.len(debug.getinfo(1).source)-(string.len(argv[0])+1)); scripts_dir = string.sub(debug.getinfo(1).source,2,string.len(debug.getinfo(1).source)-(string.len(argv[0])+1));
include = assert(loadfile(scripts_dir .. "/resources/config.lua")); include = assert(loadfile(scripts_dir .. "/resources/config.lua")); include();
include(); include = loadfile(scripts_dir .. "/resources/local.lua"); if (include ~= nil) then include(); end
--connect to the database --connect to the database
--ODBC - data source name --ODBC - data source name
@ -179,7 +179,7 @@
end end
status = dbh:query(sql, function(row) status = dbh:query(sql, function(row)
--check for matching options --check for matching options
if (api:execute("regex", row.ivr_menu_option_digits.."|"..digits)) then if (api:execute("regex", digits.."|"..row.ivr_menu_option_digits)) then
if (row.ivr_menu_option_action == "menu-exec-app") then if (row.ivr_menu_option_action == "menu-exec-app") then
--get the action and data --get the action and data
pos = string.find(row.ivr_menu_option_param, " ", 0, true); pos = string.find(row.ivr_menu_option_param, " ", 0, true);