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

Fix the emergency lua script

This commit is contained in:
FusionPBX 2024-02-10 15:35:41 -07:00 committed by GitHub
parent e753ce9175
commit 490c26ab52
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 123 additions and 140 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

263
app/switch/resources/scripts/app/emergency/index.lua
View File

@ -36,25 +36,25 @@
--convert_ext (optional) to replace the file's extension
--Example
--luarun emergency.lua to@domain.com from@domain.com 'headers' 'subject' 'body'
--luarun emergency.lua to@domain.com from@domain.com 'headers' 'subject' 'body'
--load libraries
local send_mail = require 'resources.functions.send_mail'
local Database = require "resources.functions.database"
local Settings = require "resources.functions.lazy_settings"
local Utils = require "resources.functions.channel_utils";
local send_mail = require 'resources.functions.send_mail'
local Database = require "resources.functions.database"
local Settings = require "resources.functions.lazy_settings"
local Utils = require "resources.functions.channel_utils";
--define a function to send email
local db = dbh or Database.new('system')
local settings = Settings.new(db, domain_name, domain_uuid)
local email_queue_enabled = settings:get('email_queue', 'enabled', 'boolean') or "false";
local db = dbh or Database.new('system')
local settings = Settings.new(db, domain_name, domain_uuid)
local email_queue_enabled = settings:get('email_queue', 'enabled', 'boolean') or "false";
--get the argv values
script_name = argv[0];
delete = argv[1];
script_name = argv[0];
delete = argv[1];
--prepare the api object
api = freeswitch.API();
api = freeswitch.API();
--get sessions info
if (session and session:ready()) then
@ -71,17 +71,17 @@ else
headers = {}
end
function escapeCSV(s)
function escape_csv(s)
if string.find(s, '[,"]') then
s = '"' .. string.gsub(s, '"', '""') .. '"'
end
return s
end
function toCSV(tt)
function to_csv(tt)
local s = ""
for _,p in ipairs(tt) do
s = s .. "," .. escapeCSV(p)
s = s .. "," .. escape_csv(p)
end
return string.sub(s, 2)
end
@ -100,9 +100,9 @@ local sql = "SELECT * FROM v_email_templates ";
body = row.template_body;
language = row.template_language;
end);
if (debug["sql"]) then
freeswitch.consoleLog("info", "[emergency] SQL: " .. sql .. "\n");
end
if (debug["sql"]) then
freeswitch.consoleLog("info", "[emergency] SQL: " .. sql .. "\n");
end
--freeswitch.consoleLog("info", "[template] SQL: " .. sql .. "body: " .. body .. "\n");
--get email from
@ -110,11 +110,9 @@ local sql = "SELECT * FROM v_default_settings ";
sql = sql .. "WHERE default_setting_category = 'email' ";
sql = sql .. "AND (default_setting_subcategory = 'smtp_from' ";
sql = sql .. "OR default_setting_subcategory = 'smtp_from_name') ";
if (debug["sql"]) then
freeswitch.consoleLog("notice", "[emergency] SQL: " .. sql .. "\n");
end
if (debug["sql"]) then
freeswitch.consoleLog("notice", "[emergency] SQL: " .. sql .. "\n");
end
dbh:query(sql, function(row)
if (row.default_setting_subcategory == "smtp_from") then
from = row.default_setting_value;
@ -122,85 +120,94 @@ local sql = "SELECT * FROM v_default_settings ";
if (row.default_setting_subcategory == "smtp_from_name") then
from_name = row.default_setting_value;
end
end);
-- get vars
domain_uuid = session:getVariable("domain_uuid");
call_date = session:getVariable("call_date");
caller_id_name = session:getVariable("caller_id_name");
caller_id_number = session:getVariable("caller_id_number");
sip_from_user = session:getVariable("sip_from_user");
emergency_caller_id_name = session:getVariable("emergency_caller_id_name");
emergency_caller_id_number = session:getVariable("emergency_caller_id_number");
call_duration = session:getVariable("call_duration");
--domain level check
result = {}
local sql = "SELECT count(domain_setting_value) ";
sql = sql .. "AS total ";
sql = sql .. "FROM v_domain_settings ";
sql = sql .. "WHERE domain_uuid = :domain_uuid ";
sql = sql .. "AND domain_setting_subcategory = :emergency_email_address ";
sql = sql .. "AND domain_setting_enabled = :status ";
local params = {domain_uuid = domain_uuid, emergency_email_address = 'emergency_email_address', status = 't'}
dbh:query(sql, params, function(result)
total = result.total;
--no emergency emails found under domain, using default
if (total == 0 or total == nil) then
to = {}
local sql = "SELECT default_setting_value ";
sql = sql .. "FROM v_default_settings ";
sql = sql .. "WHERE default_setting_category = :category ";
sql = sql .. "AND default_setting_subcategory = :emergency_email_address ";
sql = sql .. "AND default_setting_enabled = :status ";
sql = sql .. "LIMIT 5 ";
local params = {category = 'dialplan', emergency_email_address = 'emergency_email_address', status = 't'}
dbh:query(sql, params, function(result)
for key,row in pairs(result) do
table.insert(to, row);
freeswitch.consoleLog("info", "[emergency] Inserted into table from default settings " .. row .. "\n");
end
--add some details
if (debug["sql"]) then
freeswitch.consoleLog("notice", "[emergency] SQL: " .. sql .. " result " .. result .. "\n");
end
end);
--domain level emails max 5
else if (tonumber(total) <= 5) then
to = {}
local sql = "SELECT domain_setting_value ";
sql = sql .. "FROM v_domain_settings ";
sql = sql .. "WHERE domain_uuid = :domain_uuid ";
sql = sql .. "AND domain_setting_subcategory = :emergency_email_address ";
sql = sql .. "AND domain_setting_enabled = :status ";
local params = {domain_uuid = domain_uuid, emergency_email_address = 'emergency_email_address', status = 't'}
dbh:query(sql, params, function(result)
for key,row in pairs(result) do
table.insert(to, row);
freeswitch.consoleLog("info", "[template] Inserted into table " .. row .. "\n");
end
end);
end
end
end);
dbh:release()
if (#to > 0) then
--set event
--get variables
if (session and session:ready()) then
domain_uuid = session:getVariable("domain_uuid");
caller_id_name = session:getVariable("caller_id_name");
caller_id_number = session:getVariable("caller_id_number");
sip_from_user = session:getVariable("sip_from_user");
emergency_caller_id_name = session:getVariable("emergency_caller_id_name");
emergency_caller_id_number = session:getVariable("emergency_caller_id_number");
call_duration = session:getVariable("call_duration");
destination_number = session:getVariable("destination_number");
if (tonumber(destination_number) == 933) then
event = '933 Emergency Address Validation Service';
else if (tonumber(destination_number) == 911) then
event = '911 Emergency Call';
end
end
--domain level check
result = {}
local sql = "SELECT count(domain_setting_value) ";
sql = sql .. "AS total ";
sql = sql .. "FROM v_domain_settings ";
sql = sql .. "WHERE domain_uuid = :domain_uuid ";
sql = sql .. "AND domain_setting_subcategory = :emergency_email_address ";
sql = sql .. "AND domain_setting_enabled = :status ";
local params = {domain_uuid = domain_uuid, emergency_email_address = 'emergency_email_address', status = 't'}
dbh:query(sql, params, function(result)
total = result.total;
--no emergency emails found under domain, using default
if (total == 0 or total == nil) then
to = {}
local sql = "SELECT default_setting_value ";
sql = sql .. "FROM v_default_settings ";
sql = sql .. "WHERE default_setting_category = :category ";
sql = sql .. "AND default_setting_subcategory = :emergency_email_address ";
sql = sql .. "AND default_setting_enabled = :status ";
sql = sql .. "LIMIT 5 ";
local params = {category = 'dialplan', emergency_email_address = 'emergency_email_address', status = 't'}
dbh:query(sql, params, function(result)
for key,row in pairs(result) do
table.insert(to, row);
freeswitch.consoleLog("info", "[emergency] Inserted into table from default settings " .. row .. "\n");
end
--add some details
if (debug["sql"]) then
freeswitch.consoleLog("notice", "[emergency] SQL: " .. sql .. " result " .. result .. "\n");
end
end);
--domain level emails max 5
else if (tonumber(total) <= 5) then
to = {}
local sql = "SELECT domain_setting_value ";
sql = sql .. "FROM v_domain_settings ";
sql = sql .. "WHERE domain_uuid = :domain_uuid ";
sql = sql .. "AND domain_setting_subcategory = :emergency_email_address ";
sql = sql .. "AND domain_setting_enabled = :status ";
local params = {domain_uuid = domain_uuid, emergency_email_address = 'emergency_email_address', status = 't'}
dbh:query(sql, params, function(result)
for key,row in pairs(result) do
table.insert(to, row);
freeswitch.consoleLog("info", "[template] Inserted into table " .. row .. "\n");
end
end);
end
end
end);
--set event
if (tonumber(destination_number) == 933) then
event = '933 Emergency Address Validation Service';
else if (tonumber(destination_number) == 911) then
event = '911 Emergency Call';
end
end
--connect to the database
local dbh = Database.new('system');
--set the call date
sql = "SELECT now() as call_date ";
if (debug["sql"]) then
freeswitch.consoleLog("NOTICE", "[event] "..sql.."\n");
end
local t = dbh:first_row(sql);
call_date = t.call_date;
--send the email
if (#to > 0) then
--prepare the body
if (body ~= nil) then
body = body:gsub("${caller_id_name}", caller_id_name);
@ -225,54 +232,30 @@ if (#to > 0) then
end
end
-- Insert into Emergency Logs
emergency_logs_uuid = api:executeString("create_uuid");
domain_uuid = session:getVariable("domain_uuid");
-- Set time and date
local delimiter = " ";
local y = 0;
local tab = {}
while true do
local endindex = call_date:find(delimiter,y);
if not endindex then
break
end
table.insert(tab,call_date:sub(y,endindex-1))
y = endindex + 1;
end
table.insert(tab,call_date:sub(y));
local time = tab[2] .. " " .. tab[3];
freeswitch.consoleLog("info", "[emergency] Getting Date " .. tab[1] .. " Time " .. tab[2] .. " Format " .. tab[3] .. "\n");
--connect to the database
local dbh = Database.new('system');
--insert into emergency logs
local sql = "INSERT INTO v_emergency_logs ( ";
sql = sql .. " log_uuid, ";
sql = sql .. " domain_uuid, ";
sql = sql .. " date, ";
sql = sql .. " time, ";
sql = sql .. " extension, ";
sql = sql .. " event ";
sql = sql .. ") ";
sql = sql .. "VALUES ( ";
sql = sql .. " :emergency_logs_uuid, ";
sql = sql .. " :domain_uuid, ";
sql = sql .. " :date, ";
sql = sql .. " :time, ";
sql = sql .. " :extension, ";
sql = sql .. " :event ";
sql = sql .. ") ";
sql = sql .. " emergency_log_uuid, ";
sql = sql .. " domain_uuid, ";
sql = sql .. " insert_date, ";
sql = sql .. " extension, ";
sql = sql .. " event ";
sql = sql .. ") ";
sql = sql .. "VALUES ( ";
sql = sql .. " :emergency_log_uuid, ";
sql = sql .. " :domain_uuid, ";
sql = sql .. " now(), ";
sql = sql .. " :extension, ";
sql = sql .. " :event ";
sql = sql .. ") ";
local params = {emergency_logs_uuid = emergency_logs_uuid,domain_uuid = domain_uuid, date = tab[1], time = time, extension = caller_id_number, event = event}
local params = {emergency_log_uuid = call_uuid, domain_uuid = domain_uuid, extension = caller_id_number, event = event}
if (debug["sql"]) then
freeswitch.consoleLog("info", "[emergency] SQL: " .. sql .. "\n");
end
if (debug["sql"]) then
freeswitch.consoleLog("info", "[emergency] SQL: " .. sql .. "\n");
end
dbh:query(sql, params);
dbh:release();
dbh:query(sql, params);
dbh:release();