mirror of
https://github.com/fusionpbx/fusionpbx.git
synced 2026-01-09 18:18:22 +00:00
064b999fef
Small change that attaches a pdf copy of the sent fax rather than the tif by replacing the extension in the file path. PDF files are dramatically smaller and more user friendly than TIF files.
660 lines
27 KiB
Lua
660 lines
27 KiB
Lua
--
|
|
-- FusionPBX
|
|
-- Version: MPL 1.1
|
|
--
|
|
-- The contents of this file are subject to the Mozilla Public License Version
|
|
-- 1.1 (the "License"); you may not use this file except in compliance with
|
|
-- the License. You may obtain a copy of the License at
|
|
-- http://www.mozilla.org/MPL/
|
|
--
|
|
-- Software distributed under the License is distributed on an "AS IS" basis,
|
|
-- WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
|
-- for the specific language governing rights and limitations under the
|
|
-- License.
|
|
--
|
|
-- The Original Code is FusionPBX
|
|
--
|
|
-- The Initial Developer of the Original Code is
|
|
-- Mark J Crane <markjcrane@fusionpbx.com>
|
|
-- Copyright (C) 2010 - 2019
|
|
-- the Initial Developer. All Rights Reserved.
|
|
--
|
|
-- Contributor(s):
|
|
-- Mark J. Crane
|
|
-- James O. Rose
|
|
-- Luis Daniel Lucio Quiroz
|
|
|
|
--set default variables
|
|
fax_retry_sleep = 30;
|
|
fax_retry_limit = 4;
|
|
fax_busy_limit = 5;
|
|
api = freeswitch.API();
|
|
|
|
--include config.lua
|
|
require "resources.functions.config";
|
|
|
|
--connect to the database
|
|
local Database = require "resources.functions.database";
|
|
dbh = Database.new('system');
|
|
|
|
--include json library
|
|
local json
|
|
if (debug["sql"]) then
|
|
json = require "resources.functions.lunajson"
|
|
end
|
|
|
|
--define the explode function
|
|
require "resources.functions.explode";
|
|
|
|
--array count
|
|
require "resources.functions.count";
|
|
|
|
-- show all channel variables
|
|
--dat = env:serialize()
|
|
--freeswitch.consoleLog("INFO","[FAX] info:\n" .. dat .. "\n")
|
|
|
|
-- example channel variables relating to fax
|
|
--variable_fax_success: 0
|
|
--variable_fax_result_code: 49
|
|
--variable_fax_result_text: The%20call%20dropped%20prematurely
|
|
--variable_fax_ecm_used: off
|
|
--variable_fax_local_station_id: SpanDSP%20Fax%20Ident
|
|
--variable_fax_document_transferred_pages: 0
|
|
--variable_fax_document_total_pages: 0
|
|
--variable_fax_image_resolution: 0x0
|
|
--variable_fax_image_size: 0
|
|
--variable_fax_bad_rows: 0
|
|
--variable_fax_transfer_rate: 14400
|
|
|
|
-- set channel variables to lua variables
|
|
uuid = env:getHeader("uuid");
|
|
domain_uuid = env:getHeader("domain_uuid");
|
|
domain_name = env:getHeader("domain_name");
|
|
fax_success = env:getHeader("fax_success");
|
|
fax_result_text = env:getHeader("fax_result_text");
|
|
fax_local_station_id = env:getHeader("fax_local_station_id");
|
|
fax_ecm_used = env:getHeader("fax_ecm_used");
|
|
fax_retry_attempts = tonumber(env:getHeader("fax_retry_attempts"));
|
|
fax_retry_limit = tonumber(env:getHeader("fax_retry_limit"));
|
|
--fax_retry_sleep = tonumber(env:getHeader("fax_retry_sleep"));
|
|
fax_uri = env:getHeader("fax_uri");
|
|
fax_file = env:getHeader("fax_file");
|
|
fax_extension_number = env:getHeader("fax_extension_number");
|
|
origination_caller_id_name = env:getHeader("origination_caller_id_name");
|
|
origination_caller_id_number = env:getHeader("origination_caller_id_number");
|
|
fax_bad_rows = env:getHeader("fax_bad_rows");
|
|
fax_transfer_rate = env:getHeader("fax_transfer_rate");
|
|
accountcode = env:getHeader("accountcode");
|
|
sip_to_user = env:getHeader("sip_to_user");
|
|
bridge_hangup_cause = env:getHeader("bridge_hangup_cause");
|
|
fax_result_code = env:getHeader("fax_result_code");
|
|
fax_busy_attempts = tonumber(env:getHeader("fax_busy_attempts"));
|
|
hangup_cause_q850 = tonumber(env:getHeader("hangup_cause_q850"));
|
|
|
|
--set default values
|
|
default_language = 'en';
|
|
default_dialect = 'us';
|
|
if (not origination_caller_id_name) then
|
|
origination_caller_id_name = '000000000000000';
|
|
end
|
|
if (not origination_caller_id_number) then
|
|
origination_caller_id_number = '000000000000000';
|
|
end
|
|
if (not fax_busy_attempts) then
|
|
fax_busy_attempts = 0;
|
|
end
|
|
--we got a busy signal.... may want to check the sip_term_cause
|
|
if (not fax_success) then
|
|
fax_success = "0";
|
|
fax_result_code = 2;
|
|
end
|
|
if (hangup_cause_q850 == "17") then
|
|
fax_success = "0";
|
|
fax_result_code = 2;
|
|
end
|
|
if (not fax_result_text) then
|
|
fax_result_text = "FS_NOT_SET";
|
|
end
|
|
|
|
--get the values from the fax file
|
|
array = explode("/", fax_file);
|
|
domain_name = array[count(array)-3];
|
|
fax_extension = array[count(array)-2];
|
|
file_name = array[count(array)];
|
|
|
|
--get the domain_uuid using the domain name required for multi-tenant
|
|
if (domain_uuid == nil and domain_name ~= nil) then
|
|
local sql = "SELECT domain_uuid FROM v_domains ";
|
|
sql = sql .. "WHERE domain_name = :domain_name ";
|
|
dbh:query(sql, {domain_name = domain_name}, function(rows)
|
|
domain_uuid = rows["domain_uuid"];
|
|
end);
|
|
end
|
|
|
|
--settings
|
|
require "resources.functions.settings";
|
|
settings = settings(domain_uuid);
|
|
storage_type = "";
|
|
storage_path = "";
|
|
if (settings['fax'] ~= nil) then
|
|
if (settings['fax']['storage_type'] ~= nil) then
|
|
if (settings['fax']['storage_type']['text'] ~= nil) then
|
|
storage_type = settings['fax']['storage_type']['text'];
|
|
end
|
|
end
|
|
if (settings['fax']['storage_path'] ~= nil) then
|
|
if (settings['fax']['storage_path']['text'] ~= nil) then
|
|
storage_path = settings['fax']['storage_path']['text'];
|
|
storage_path = storage_path:gsub("${domain_name}", domain_name);
|
|
storage_path = storage_path:gsub("${voicemail_id}", voicemail_id);
|
|
storage_path = storage_path:gsub("${voicemail_dir}", voicemail_dir);
|
|
end
|
|
end
|
|
ignore_early_media = "false";
|
|
if (settings['fax']['variable'] ~= nil) then
|
|
for i, var in ipairs(settings.fax.variable) do
|
|
--freeswitch.consoleLog("notice", "variable #" .. i .. ": " .. var .. "\n");
|
|
if (var == "ignore_early_media=true") then
|
|
ignore_early_media = "true";
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
--be sure accountcode is not empty
|
|
if (accountcode == nil) then
|
|
accountcode = domain_name;
|
|
end
|
|
|
|
--get the domain_uuid using the domain name required for multi-tenant
|
|
if (domain_uuid ~= nil and fax_extension ~= nil) then
|
|
local sql = "SELECT fax_uuid FROM v_fax ";
|
|
sql = sql .. "WHERE domain_uuid = :domain_uuid ";
|
|
sql = sql .. "AND fax_extension = :fax_extension ";
|
|
local params = {domain_uuid = domain_uuid, fax_extension = fax_extension}
|
|
dbh:query(sql, params, function(rows)
|
|
fax_uuid = rows["fax_uuid"];
|
|
end);
|
|
end
|
|
|
|
--add to fax logs
|
|
sql = "insert into v_fax_logs ";
|
|
sql = sql .. "(";
|
|
sql = sql .. "fax_log_uuid, ";
|
|
sql = sql .. "domain_uuid, ";
|
|
if (fax_uuid ~= nil) then
|
|
sql = sql .. "fax_uuid, ";
|
|
end
|
|
sql = sql .. "fax_success, ";
|
|
sql = sql .. "fax_result_code, ";
|
|
sql = sql .. "fax_result_text, ";
|
|
sql = sql .. "fax_file, ";
|
|
if (fax_ecm_used ~= nil) then
|
|
sql = sql .. "fax_ecm_used, ";
|
|
end
|
|
if (fax_local_station_id ~= nil) then
|
|
sql = sql .. "fax_local_station_id, ";
|
|
end
|
|
sql = sql .. "fax_document_transferred_pages, ";
|
|
sql = sql .. "fax_document_total_pages, ";
|
|
if (fax_image_resolution ~= nil) then
|
|
sql = sql .. "fax_image_resolution, ";
|
|
end
|
|
if (fax_image_size ~= nil) then
|
|
sql = sql .. "fax_image_size, ";
|
|
end
|
|
if (fax_bad_rows ~= nil) then
|
|
sql = sql .. "fax_bad_rows, ";
|
|
end
|
|
if (fax_transfer_rate ~= nil) then
|
|
sql = sql .. "fax_transfer_rate, ";
|
|
end
|
|
if (fax_retry_attempts ~= nil) then
|
|
sql = sql .. "fax_retry_attempts, ";
|
|
end
|
|
if (fax_retry_limit ~= nil) then
|
|
sql = sql .. "fax_retry_limit, ";
|
|
end
|
|
if (fax_retry_sleep ~= nil) then
|
|
sql = sql .. "fax_retry_sleep, ";
|
|
end
|
|
sql = sql .. "fax_uri, ";
|
|
sql = sql .. "fax_date, ";
|
|
sql = sql .. "fax_epoch ";
|
|
sql = sql .. ") ";
|
|
sql = sql .. "values ";
|
|
sql = sql .. "(";
|
|
sql = sql .. ":uuid, ";
|
|
sql = sql .. ":domain_uuid, ";
|
|
if (fax_uuid ~= nil) then
|
|
sql = sql .. ":fax_uuid, ";
|
|
end
|
|
sql = sql .. ":fax_success, ";
|
|
sql = sql .. ":fax_result_code, ";
|
|
sql = sql .. ":fax_result_text, ";
|
|
sql = sql .. ":fax_file, ";
|
|
if (fax_ecm_used ~= nil) then
|
|
sql = sql .. ":fax_ecm_used, ";
|
|
end
|
|
if (fax_local_station_id ~= nil) then
|
|
sql = sql .. ":fax_local_station_id, ";
|
|
end
|
|
sql = sql .. ":fax_document_transferred_pages, ";
|
|
sql = sql .. ":fax_document_total_pages, ";
|
|
if (fax_image_resolution ~= nil) then
|
|
sql = sql .. ":fax_image_resolution, ";
|
|
end
|
|
if (fax_image_size ~= nil) then
|
|
sql = sql .. ":fax_image_size, ";
|
|
end
|
|
if (fax_bad_rows ~= nil) then
|
|
sql = sql .. ":fax_bad_rows, ";
|
|
end
|
|
if (fax_transfer_rate ~= nil) then
|
|
sql = sql .. ":fax_transfer_rate, ";
|
|
end
|
|
if (fax_retry_attempts ~= nil) then
|
|
sql = sql .. ":fax_retry_attempts, ";
|
|
end
|
|
if (fax_retry_limit ~= nil) then
|
|
sql = sql .. ":fax_retry_limit, ";
|
|
end
|
|
if (fax_retry_sleep ~= nil) then
|
|
sql = sql .. ":fax_retry_sleep, ";
|
|
end
|
|
sql = sql .. ":fax_uri, ";
|
|
if (database["type"] == "sqlite") then
|
|
sql = sql .. ":fax_date, ";
|
|
else
|
|
sql = sql .. "now(), ";
|
|
end
|
|
sql = sql .. ":fax_time ";
|
|
sql = sql .. ")";
|
|
|
|
local params = {
|
|
uuid = uuid;
|
|
domain_uuid = domain_uuid;
|
|
fax_uuid = fax_uuid;
|
|
fax_success = fax_success;
|
|
fax_result_code = fax_result_code;
|
|
fax_result_text = fax_result_text;
|
|
fax_file = fax_file;
|
|
fax_ecm_used = fax_ecm_used;
|
|
fax_local_station_id = fax_local_station_id;
|
|
fax_document_transferred_pages = fax_document_transferred_pages or '0';
|
|
fax_document_total_pages = fax_document_total_pages or '0';
|
|
fax_image_resolution = fax_image_resolution;
|
|
fax_image_size = fax_image_size;
|
|
fax_bad_rows = fax_bad_rows;
|
|
fax_transfer_rate = fax_transfer_rate;
|
|
fax_retry_attempts = fax_retry_attempts;
|
|
fax_retry_limit = fax_retry_limit;
|
|
fax_retry_sleep = fax_retry_sleep;
|
|
fax_uri = fax_uri;
|
|
fax_date = os.date("%Y-%m-%d %X");
|
|
fax_time = os.time();
|
|
};
|
|
|
|
if (debug["sql"]) then
|
|
freeswitch.consoleLog("notice", "[FAX] retry: " .. sql .. "; params:" .. json.encode(params) .. "\n");
|
|
end
|
|
dbh:query(sql, params);
|
|
|
|
--for email
|
|
email_address = env:getHeader("mailto_address");
|
|
--email_address = api:execute("system", "/bin/echo -n "..email_address.." | /bin/sed -e s/\,/\\\\,/g");
|
|
if (email_address == nil) then
|
|
email_address = '';
|
|
else
|
|
email_address = email_address:gsub(",", "\\,");
|
|
end
|
|
from_address = env:getHeader("mailfrom_address");
|
|
if (from_address == nil) then
|
|
from_address = email_address;
|
|
end
|
|
uri_array = explode("/",fax_uri);
|
|
number_dialed = uri_array[4];
|
|
if (number_dialed == nil) then
|
|
number_dialed = uri_array[3];
|
|
if (number_dialed == nil) then
|
|
number_dialed = '0';
|
|
end
|
|
end
|
|
--do not use apostrophies in message, they are not escaped and the mail will fail.
|
|
|
|
--get the templates
|
|
local sql = "SELECT * FROM v_email_templates ";
|
|
sql = sql .. "WHERE (domain_uuid = :domain_uuid or domain_uuid is null) ";
|
|
sql = sql .. "AND template_language = :template_language ";
|
|
sql = sql .. "AND template_category = 'fax' "
|
|
sql = sql .. "AND ( ";
|
|
sql = sql .. " template_subcategory = 'success_default' ";
|
|
sql = sql .. " OR template_subcategory = 'fail_default' ";
|
|
sql = sql .. " OR template_subcategory = 'fail_busy' ";
|
|
sql = sql .. " OR template_subcategory = 'fail_invalid' ";
|
|
sql = sql .. ") "
|
|
sql = sql .. "AND template_enabled = 'true' "
|
|
local params = {domain_uuid = domain_uuid, template_language = default_language.."-"..default_dialect};
|
|
if (debug["sql"]) then
|
|
freeswitch.consoleLog("notice", "[fax] SQL: " .. sql .. "; params:" .. json.encode(params) .. "\n");
|
|
end
|
|
dbh:query(sql, params, function(row)
|
|
if (row["template_subcategory"] == 'success_default') then
|
|
email_subject_success_default = row["template_subject"];
|
|
email_body_success_default = row["template_body"];
|
|
|
|
email_subject_success_default = email_subject_success_default:gsub("${number_dialed}", number_dialed);
|
|
email_subject_success_default = email_subject_success_default:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
email_body_success_default = email_body_success_default:gsub("${number_dialed}", number_dialed);
|
|
email_body_success_default = email_body_success_default:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
end
|
|
if (row["template_subcategory"] == 'fail_default') then
|
|
email_subject_fail_default = row["template_subject"];
|
|
email_body_fail_default = row["template_body"];
|
|
|
|
email_subject_fail_default = email_subject_fail_default:gsub("${number_dialed}", number_dialed);
|
|
email_subject_fail_default = email_subject_fail_default:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
email_body_fail_default = email_body_fail_default:gsub("${number_dialed}", number_dialed);
|
|
email_body_fail_default = email_body_fail_default:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
end
|
|
if (row["template_subcategory"] == 'fail_busy') then
|
|
email_subject_fail_busy = row["template_subject"];
|
|
email_body_fail_busy = row["template_body"];
|
|
|
|
email_subject_fail_busy = email_subject_fail_busy:gsub("${number_dialed}", number_dialed);
|
|
email_subject_fail_busy = email_subject_fail_busy:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
email_body_fail_busy = email_body_fail_busy:gsub("${number_dialed}", number_dialed);
|
|
email_body_fail_busy = email_body_fail_busy:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
end
|
|
if (row["template_subcategory"] == 'fail_invalid') then
|
|
email_subject_fail_invalid = row["template_subject"];
|
|
email_body_fail_invalid = row["template_body"];
|
|
|
|
email_subject_fail_invalid = email_subject_fail_invalid:gsub("${number_dialed}", number_dialed);
|
|
email_subject_fail_invalid = email_subject_fail_invalid:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
email_body_fail_invalid = email_body_fail_invalid:gsub("${number_dialed}", number_dialed);
|
|
email_body_fail_invalid = email_body_fail_invalid:gsub("${fax_busy_attempts}", fax_busy_attempts);
|
|
end
|
|
end);
|
|
|
|
--add the fax files
|
|
if (fax_success ~= nil) then
|
|
if (fax_success =="1") then
|
|
if (settings['fax']['keep_local']['boolean'] ~= "nil") then
|
|
if (settings['fax']['keep_local']['boolean'] == "false") then
|
|
storage_type = "";
|
|
end
|
|
end
|
|
|
|
local fax_base64
|
|
if (storage_type == "base64") then
|
|
--include the file io
|
|
local file = require "resources.functions.file"
|
|
|
|
--read file content as base64 string
|
|
fax_base64 = assert(file.read_base64(fax_file));
|
|
end
|
|
|
|
local sql = {}
|
|
table.insert(sql, "insert into v_fax_files ");
|
|
table.insert(sql, "(");
|
|
table.insert(sql, "fax_file_uuid, ");
|
|
table.insert(sql, "fax_uuid, ");
|
|
table.insert(sql, "fax_mode, ");
|
|
if (sip_to_user ~= nil) then
|
|
table.insert(sql, "fax_destination, ");
|
|
end
|
|
table.insert(sql, "fax_file_type, ");
|
|
table.insert(sql, "fax_file_path, ");
|
|
table.insert(sql, "fax_caller_id_name, ");
|
|
table.insert(sql, "fax_caller_id_number, ");
|
|
table.insert(sql, "fax_date, ");
|
|
table.insert(sql, "fax_epoch, ");
|
|
if (storage_type == "base64") then
|
|
table.insert(sql, "fax_base64, ");
|
|
end
|
|
table.insert(sql, "domain_uuid");
|
|
table.insert(sql, ") ");
|
|
table.insert(sql, "values ");
|
|
table.insert(sql, "(");
|
|
table.insert(sql, ":uuid, ");
|
|
table.insert(sql, ":fax_uuid, ");
|
|
table.insert(sql, "'tx', ");
|
|
if (sip_to_user ~= nil) then
|
|
table.insert(sql, ":sip_to_user, ");
|
|
end
|
|
table.insert(sql, "'tif', ");
|
|
table.insert(sql, ":fax_file, ");
|
|
table.insert(sql, ":origination_caller_id_name, ");
|
|
table.insert(sql, ":origination_caller_id_number, ");
|
|
if (database["type"] == "sqlite") then
|
|
table.insert(sql, ":fax_date, ");
|
|
else
|
|
table.insert(sql, "now(), ");
|
|
end
|
|
table.insert(sql, ":fax_time, ");
|
|
if (storage_type == "base64") then
|
|
table.insert(sql, ":fax_base64, ");
|
|
end
|
|
table.insert(sql, ":domain_uuid ");
|
|
table.insert(sql, ")");
|
|
|
|
sql = table.concat(sql, "\n");
|
|
|
|
local params = {
|
|
uuid = uuid;
|
|
fax_uuid = fax_uuid;
|
|
sip_to_user = sip_to_user;
|
|
fax_file = string.gsub(fax_file, '/temp/', '/sent/');
|
|
origination_caller_id_name = origination_caller_id_name;
|
|
origination_caller_id_number = origination_caller_id_number;
|
|
fax_date = os.date("%Y-%m-%d %X");
|
|
fax_time = os.time();
|
|
fax_base64 = fax_base64;
|
|
domain_uuid = domain_uuid;
|
|
}
|
|
|
|
if (debug["sql"]) then
|
|
freeswitch.consoleLog("notice", "[FAX] SQL: " .. sql .. "; params:" .. json.encode(params) .. "\n");
|
|
end
|
|
if (storage_type == "base64") then
|
|
local dbh = Database.new('system', 'base64');
|
|
dbh:query(sql, params);
|
|
dbh:release();
|
|
else
|
|
dbh:query(sql, params);
|
|
end
|
|
end
|
|
end
|
|
|
|
-- send the selected variables to the console
|
|
if (fax_success ~= nil) then
|
|
freeswitch.consoleLog("INFO","[FAX] Success: '" .. fax_success .. "'\n");
|
|
end
|
|
freeswitch.consoleLog("INFO","[FAX] fax_result_text: '" .. fax_result_text .. "'\n");
|
|
freeswitch.consoleLog("INFO","[FAX] fax_file: '" .. fax_file .. "'\n");
|
|
freeswitch.consoleLog("INFO","[FAX] uuid: '" .. uuid .. "'\n");
|
|
--freeswitch.consoleLog("INFO","fax_ecm_used: '" .. fax_ecm_used .. "'\n");
|
|
freeswitch.consoleLog("INFO","[FAX] fax_retry_attempts: " .. fax_retry_attempts.. "\n");
|
|
freeswitch.consoleLog("INFO","[FAX] fax_retry_limit: " .. fax_retry_limit.. "\n");
|
|
freeswitch.consoleLog("INFO","[FAX] fax_retry_sleep: " .. fax_retry_sleep.. "\n");
|
|
freeswitch.consoleLog("INFO","[FAX] fax_uri: '" .. fax_uri.. "'\n");
|
|
freeswitch.consoleLog("INFO","[FAX] accountcode: '" .. accountcode .. "'\n");
|
|
freeswitch.consoleLog("INFO","[FAX] origination_caller_id_name: " .. origination_caller_id_name .. "\n");
|
|
freeswitch.consoleLog("INFO","[FAX] origination_caller_id_number: " .. origination_caller_id_number .. "\n");
|
|
freeswitch.consoleLog("INFO","[FAX] fax_result_code: ".. fax_result_code .."\n");
|
|
freeswitch.consoleLog("INFO","[FAX] mailfrom_address: ".. from_address .."\n");
|
|
freeswitch.consoleLog("INFO","[FAX] mailto_address: ".. email_address .."\n");
|
|
freeswitch.consoleLog("INFO","[FAX] hangup_cause_q850: '" .. hangup_cause_q850 .. "'\n");
|
|
|
|
-- build headers
|
|
email_type = "email2fax";
|
|
x_headers = 'X-Headers: {"X-FusionPBX-Email-Type":"'..email_type..'",';
|
|
x_headers = x_headers..'"X-FusionPBX-Domain-UUID":"'..domain_uuid..'"}';
|
|
|
|
-- if the fax failed then try again
|
|
if (fax_success == "0") then
|
|
--DEBUG
|
|
--email_cmd = "/bin/echo '"..email_subject_fail.."' | /usr/bin/mail -s 'Fax to: "..number_dialed.." FAILED' -r "..from_address.." -a '"..fax_file.."' "..email_address;
|
|
|
|
--to keep the originate command shorter these are things we always send. One place to adjust for all.
|
|
--originate_same = "for_fax=1,accountcode='"..accountcode.."',domain_uuid="..domain_uuid..",domain_name="..domain_name..",mailto_address='"..email_address.."',mailfrom_address='"..from_address.."',origination_caller_id_name='"..origination_caller_id_name.. "',origination_caller_id_number="..origination_caller_id_number..",fax_uri="..fax_uri..",fax_retry_limit="..fax_retry_limit..",fax_retry_sleep="..fax_retry_sleep..",fax_verbose=true,fax_file='"..fax_file.."'";
|
|
originate_same = "for_fax=1,accountcode='"..accountcode.."',domain_uuid="..domain_uuid..",domain_name="..domain_name..",mailto_address='"..email_address.."',mailfrom_address='"..from_address.."',origination_caller_id_name='"..origination_caller_id_name.. "',origination_caller_id_number="..origination_caller_id_number..",fax_uri="..fax_uri..",fax_retry_limit="..fax_retry_limit..",fax_retry_sleep="..fax_retry_sleep..",fax_verbose=true,fax_file='"..fax_file.."',fax_ident='"..origination_caller_id_number.."',fax_header='"..origination_caller_id_name.."'";
|
|
|
|
if (fax_retry_attempts < fax_retry_limit) then
|
|
|
|
--timed out waitng for comm or on first message, or busy code
|
|
if (fax_result_code == "2" or fax_result_code == "3" or hangup_cause_q850 == 17) then
|
|
--do nothing. don't want to increment
|
|
freeswitch.consoleLog("INFO","[FAX] Last Fax was probably Busy, don't increment retry_attempts. \n");
|
|
fax_busy_attempts = fax_busy_attempts + 1;
|
|
if (fax_busy_attempts > fax_busy_limit) then
|
|
fax_retry_attempts = 17;
|
|
else
|
|
freeswitch.msleep(fax_retry_sleep * 1000);
|
|
end
|
|
--unallocated number
|
|
elseif (hangup_cause_q850 == 1 ) then
|
|
fax_retry_attempts = 10;
|
|
elseif (fax_retry_attempts < 5 ) then
|
|
freeswitch.consoleLog("INFO","[FAX] Last Fax Failed, try a different way. Wait first.\n");
|
|
freeswitch.msleep(fax_retry_sleep * 500);
|
|
else
|
|
freeswitch.consoleLog("INFO","[FAX] All attempts to send fax to "..number_dialed.."FAILED\n");
|
|
end
|
|
|
|
if (fax_retry_attempts == 1) then
|
|
--send t38 on ECM on
|
|
freeswitch.consoleLog("INFO","[FAX] TRYING ["..fax_retry_attempts.."] of [4] to: "..number_dialed.." with: t38 ON ECM ON, Fast\n");
|
|
if (hangup_cause_q850 ~= 17) then
|
|
fax_retry_attempts = fax_retry_attempts + 1;
|
|
end
|
|
if (ignore_early_media == "true") then
|
|
cmd = "originate {fax_retry_attempts="..fax_retry_attempts..","..originate_same..",fax_use_ecm=true,fax_enable_t38=true,fax_enable_t38_request=true,ignore_early_media=true,fax_disable_v17=false,fax_busy_attempts='"..fax_busy_attempts.."',api_hangup_hook='lua fax_retry.lua'}"..fax_uri.." &txfax('"..fax_file.."')";
|
|
else
|
|
cmd = "originate {fax_retry_attempts="..fax_retry_attempts..","..originate_same..",fax_use_ecm=true,fax_enable_t38=true,fax_enable_t38_request=true,fax_disable_v17=false,fax_busy_attempts='"..fax_busy_attempts.."',api_hangup_hook='lua fax_retry.lua'}"..fax_uri.." &txfax('"..fax_file.."')";
|
|
end
|
|
|
|
elseif (fax_retry_attempts == 2) then
|
|
--send t38 off, ECM on
|
|
freeswitch.consoleLog("INFO","[FAX] TRYING ["..fax_retry_attempts.."] of [4] to: "..number_dialed.." with: t38 OFF ECM ON, Fast\n");
|
|
if (hangup_cause_q850 ~= 17) then
|
|
fax_retry_attempts = fax_retry_attempts + 1;
|
|
end
|
|
cmd = "originate {fax_retry_attempts="..fax_retry_attempts..","..originate_same..",fax_use_ecm=true,fax_enable_t38=false,fax_enable_t38_request=false,fax_disable_v17=false,fax_busy_attempts='"..fax_busy_attempts.."',api_hangup_hook='lua fax_retry.lua'}"..fax_uri.." &txfax('"..fax_file.."')";
|
|
|
|
elseif (fax_retry_attempts == 3) then
|
|
--send t38 on v17 [slow] on ECM off
|
|
freeswitch.consoleLog("INFO","[FAX] TRYING ["..fax_retry_attempts.."] of [4] to: "..number_dialed.." with: t38 ON ECM OFF, SLOW\n");
|
|
if (hangup_cause_q850 ~= 17) then
|
|
fax_retry_attempts = fax_retry_attempts + 1;
|
|
end
|
|
if (ignore_early_media == "true") then
|
|
cmd = "originate {fax_retry_attempts="..fax_retry_attempts..","..originate_same..",fax_use_ecm=false,fax_enable_t38=true,fax_enable_t38_request=true,ignore_early_media=true,fax_disable_v17=true,fax_busy_attempts='"..fax_busy_attempts.."',api_hangup_hook='lua fax_retry.lua'}"..fax_uri.." &txfax('"..fax_file.."')";
|
|
else
|
|
cmd = "originate {fax_retry_attempts="..fax_retry_attempts..","..originate_same..",fax_use_ecm=false,fax_enable_t38=true,fax_enable_t38_request=true,fax_disable_v17=true,fax_busy_attempts='"..fax_busy_attempts.."',api_hangup_hook='lua fax_retry.lua'}"..fax_uri.." &txfax('"..fax_file.."')";
|
|
end
|
|
|
|
elseif (fax_retry_attempts == 4) then
|
|
--send t38 off v17 [slow] on ECM off
|
|
freeswitch.consoleLog("INFO","[FAX] TRYING ["..fax_retry_attempts.."] of [4] to: "..number_dialed.." with: t38 OFF ECM OFF, SLOW\n");
|
|
if (hangup_cause_q850 ~= 17) then
|
|
fax_retry_attempts = fax_retry_attempts + 1;
|
|
end
|
|
|
|
cmd = "originate {fax_retry_attempts="..fax_retry_attempts..","..originate_same..",fax_use_ecm=false,fax_enable_t38=false,fax_enable_t38_request=false,fax_disable_v17=true,fax_busy_attempts='"..fax_busy_attempts.."',api_hangup_hook='lua fax_retry.lua'}"..fax_uri.." &txfax('"..fax_file.."')";
|
|
|
|
--bad number
|
|
elseif (fax_retry_attempts == 10) then
|
|
freeswitch.consoleLog("INFO","[FAX] RETRY FAILED: BAD NUMBER\n");
|
|
freeswitch.consoleLog("INFO", "[FAX] RETRY_STATS FAILURE BAD NUMBER: GATEWAY[".. fax_uri .."]");
|
|
|
|
email_address = email_address:gsub("\\,", ",");
|
|
freeswitch.email(email_address,
|
|
email_address,
|
|
"To: "..email_address.."\nFrom: "..from_address.."\nSubject: "..email_subject_fail_invalid.."\n"..x_headers,
|
|
email_body_fail_invalid,
|
|
fax_file
|
|
);
|
|
|
|
--busy number
|
|
elseif (fax_retry_attempts == 17) then
|
|
freeswitch.consoleLog("INFO","[FAX] RETRY FAILED: TRIED ["..fax_busy_attempts.."] of [4]: BUSY NUMBER\n");
|
|
freeswitch.consoleLog("INFO", "[FAX] RETRY STATS FAILURE BUSY: GATEWAY[".. fax_uri .."], BUSY NUMBER");
|
|
|
|
email_address = email_address:gsub("\\,", ",");
|
|
freeswitch.email(email_address,
|
|
email_address,
|
|
"To: "..email_address.."\nFrom: "..from_address.."\nSubject: "..email_subject_fail_busy.."\n"..x_headers,
|
|
email_body_fail_busy,
|
|
fax_file
|
|
);
|
|
|
|
else
|
|
--the fax failed completely. send a message
|
|
freeswitch.consoleLog("INFO","[FAX] RETRY FAILED: tried ["..fax_retry_attempts.."] of [4]: GIVING UP\n");
|
|
freeswitch.consoleLog("INFO", "[FAX] RETRY STATS FAILURE: GATEWAY[".. fax_uri .."], tried 5 combinations without success");
|
|
|
|
email_address = email_address:gsub("\\,", ",");
|
|
freeswitch.email(email_address,
|
|
email_address,
|
|
"To: "..email_address.."\nFrom: "..from_address.."\nSubject: "..email_subject_fail_default.."\n"..x_headers,
|
|
email_body_fail_default,
|
|
fax_file
|
|
);
|
|
|
|
fax_retry_attempts = fax_retry_attempts + 1;
|
|
|
|
end
|
|
api = freeswitch.API();
|
|
if ( not cmd ) then
|
|
freeswitch.consoleLog("INFO","[FAX] Last Attempt (5th) of fax_retry.lua: \n");
|
|
else
|
|
freeswitch.consoleLog("INFO","[FAX] Retry Command: " .. cmd .. "\n");
|
|
reply = api:executeString(cmd);
|
|
end
|
|
end
|
|
else
|
|
--Success
|
|
if (fax_retry_attempts == 0) then
|
|
if (ignore_early_media == "true") then
|
|
fax_trial = "fax_use_ecm=false,fax_enable_t38=true,fax_enable_t38_request=true,ignore_early_media=true,fax_disable_v17=default";
|
|
else
|
|
fax_trial = "fax_use_ecm=false,fax_enable_t38=true,fax_enable_t38_request=true,fax_disable_v17=default";
|
|
end
|
|
elseif (fax_retry_attempts == 1) then
|
|
if (ignore_early_media == "true") then
|
|
fax_trial = "fax_use_ecm=true,fax_enable_t38=true,fax_enable_t38_request=true,ignore_early_media=true,fax_disable_v17=false";
|
|
else
|
|
fax_trial = "fax_use_ecm=true,fax_enable_t38=true,fax_enable_t38_request=true,fax_disable_v17=false";
|
|
end
|
|
elseif (fax_retry_attempts == 2) then
|
|
fax_trial = "fax_use_ecm=true,fax_enable_t38=false,fax_enable_t38_request=false,fax_disable_v17=false";
|
|
elseif (fax_retry_attempts == 3) then
|
|
if (ignore_early_media == "true") then
|
|
fax_trial = "fax_use_ecm=true,fax_enable_t38=true,fax_enable_t38_request=true,ignore_early_media=true,fax_disable_v17=true";
|
|
else
|
|
fax_trial = "fax_use_ecm=true,fax_enable_t38=true,fax_enable_t38_request=true,fax_disable_v17=true";
|
|
end
|
|
elseif (fax_retry_attempts == 4) then
|
|
fax_trial = "fax_use_ecm=false,fax_enable_t38=false,fax_enable_t38_request=false,fax_disable_v17=false";
|
|
else
|
|
fax_trial = "fax_retry had an issue and tried more than 5 times"
|
|
end
|
|
freeswitch.consoleLog("INFO", "[FAX] RETRY STATS SUCCESS: GATEWAY[".. fax_uri .."] VARS[" .. fax_trial .. "]");
|
|
email_address = email_address:gsub("\\,", ",");
|
|
|
|
freeswitch.email(email_address,
|
|
email_address,
|
|
"To: "..email_address.."\nFrom: "..from_address.."\nSubject: "..email_subject_success_default.."\n"..x_headers,
|
|
email_body_success_default,
|
|
fax_file:gsub(".tif",".pdf",x)
|
|
);
|
|
|
|
if (settings['fax']['keep_local']['boolean'] ~= "nil") then
|
|
if (settings['fax']['keep_local']['boolean'] == "false") then
|
|
os.remove(fax_file);
|
|
end
|
|
end
|
|
end
|