summaryrefslogtreecommitdiff
path: root/misc/freeswitch/scripts/send_fax.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/send_fax.lua
parent3e706c2025ecc5523e81ad649639ef2ff75e7bac (diff)
Start of GS5.
Diffstat (limited to 'misc/freeswitch/scripts/send_fax.lua')
-rw-r--r--misc/freeswitch/scripts/send_fax.lua170
1 files changed, 170 insertions, 0 deletions
diff --git a/misc/freeswitch/scripts/send_fax.lua b/misc/freeswitch/scripts/send_fax.lua
new file mode 100644
index 0000000..321a5b1
--- /dev/null
+++ b/misc/freeswitch/scripts/send_fax.lua
@@ -0,0 +1,170 @@
+-- Gemeinschaft 5.0
+-- (c) AMOOMA GmbH 2012
+--
+
+local FAX_FILE_PATH = "/opt/GS5/public/uploads/fax_document/tiff/";
+local FAX_ANSWERING_TIMEOUT = 20;
+
+-- Set logger
+require "common.log"
+local log = common.log.Log:new()
+log.prefix = "### [sendfax] "
+
+local document_id = argv[1];
+
+require 'common.database'
+local database = common.database.Database:new{ log = log }:connect();
+
+if not database:connected() then
+ log:error('cannot connect to Gemeinschaft database');
+ return
+end
+
+if not tonumber(document_id) then
+ log:error('document id not specified');
+ return
+end
+
+local defaults = {log=log, database=database}
+require "dialplan.fax"
+local fax_class = dialplan.fax.Fax:new(defaults);
+
+local fax_document = fax_class:find_document_by_id(document_id);
+
+if not fax_document then
+ log:error('document ' .. document_id .. ' not found');
+ return
+end
+
+if tonumber(fax_document.retry_counter) > 0 then
+ fax_class:document_update(document_id, {state = 'sending', retry_counter = fax_document.retry_counter - 1});
+else
+ fax_class:document_update(document_id, {state = 'sending'});
+end
+
+local fax_account = fax_class:find_by_id(fax_document.fax_account_id);
+
+if not fax_account then
+ log:error('fax account ' .. fax_document.fax_account_id .. ' not found');
+ return
+end
+
+local destination_number = fax_class:destination_number(document_id);
+
+if not destination_number or tostring(destination_number) == '' then
+ log:error('destination number not found');
+ return
+end
+
+require 'common.str'
+destination_number = common.str.strip(destination_number);
+
+log:info('FAX_SEND - fax_document=' .. document_id .. ', destination number: ' .. destination_number .. ', retries: ' .. fax_document.retry_counter);
+
+require "common.phone_number"
+local phone_number_class = common.phone_number.PhoneNumber:new(defaults);
+
+phone_number = phone_number_class:find_by_number(destination_number);
+
+local origination_variables = {
+ 'gs_account_id=' .. fax_account.record.id,
+ 'gs_account_uuid=' .. fax_account.record.uuid,
+ 'gs_account_type=' .. 'faxaccount',
+ 'gs_auth_account_id=' .. fax_account.record.id,
+ 'gs_auth_account_uuid=' .. fax_account.record.uuid,
+ 'gs_auth_account_type=' .. 'faxaccount',
+}
+
+local session = nil
+
+if phone_number then
+ session = freeswitch.Session("[" .. table.concat(origination_variables, ",") .. "]loopback/" .. destination_number .. "/default");
+else
+ local owner_class = common.str.downcase(fax_account.record.fax_accountable_type);
+
+ local caller = {}
+ caller.caller_phone_numbers = phone_number_class:list_by_owner(fax_account.record.id, 'FaxAccount');
+ caller.account = fax_account;
+ caller.auth_account = fax_account;
+ caller.caller_id_name = fax_account.record.station_id;
+
+ if owner_class == 'user' then
+ require 'dialplan.user'
+ caller.auth_account.owner = dialplan.user.User:new{ log = log, database = database }:find_by_id(fax_account.record.fax_accountable_id);
+ if caller.auth_account.owner then
+ caller.auth_account.owner.groups = caller.auth_account.owner:list_groups();
+ end
+ elseif owner_class == 'tenant' then
+ require 'dialplan.tenant'
+ caller.auth_account.owner = dialplan.tenant.Tenant:new{ log = log, database = database }:find_by_id(fax_account.record.fax_accountable_id);
+ end
+
+ require 'common.configuration_file'
+ local routing_table = common.configuration_file.get('/opt/freeswitch/scripts/ini/routes.ini');
+ require 'dialplan.route'
+ local routes = dialplan.route.Route:new{ log = log, database = database, routing_table = routing_table }:outbound(caller, destination_number);
+
+ for index, route in ipairs(routes) do
+ log:info('FAX_SEND - ', route.class, '=', route.endpoint, ', number: ', route.value);
+ if route.class == 'gateway' then
+ table.insert(origination_variables, "origination_caller_id_number='" .. (route.caller_id_number or caller.caller_phone_numbers[1]) .. "'");
+ table.insert(origination_variables, "origination_caller_id_name='" .. (route.caller_id_name or fax_account.record.station_id) .. "'");
+ session = freeswitch.Session('[' .. table.concat(origination_variables, ',') .. ']sofia/gateway/' .. route.endpoint .. '/' .. route.value);
+ break;
+ end
+ end
+end
+
+local loop_count = FAX_ANSWERING_TIMEOUT;
+local cause = "UNSPECIFIED"
+
+while session and session:ready() and not session:answered() and loop_count >= 0 do
+ log:debug('waiting for answer: ' .. loop_count)
+ loop_count = loop_count - 1;
+ freeswitch.msleep(1000);
+end
+
+if session and session:answered() then
+ log:info('FAX_SEND - sending fax_document=' .. fax_document.id .. ' (' .. fax_document.tiff .. ')');
+
+ local file_name = FAX_FILE_PATH .. fax_document.id .. "/" .. fax_document.tiff;
+
+ session:setVariable('fax_ident', fax_account.record.station_id)
+ session:setVariable('fax_header', fax_account.record.name)
+ session:setVariable('fax_verbose', 'false')
+ local start_time = os.time();
+ session:execute('txfax', file_name);
+
+ fax_state = {
+ state = nil,
+ transmission_time = os.time() - start_time,
+ document_total_pages = common.str.to_i(session:getVariable('fax_document_total_pages')),
+ document_transferred_pages = common.str.to_i(session:getVariable('fax_document_transferred_pages')),
+ ecm_requested = common.str.to_b(session:getVariable('fax_ecm_requested')),
+ ecm_used = common.str.to_b(session:getVariable('fax_ecm_used')),
+ image_resolution = common.str.to_s(session:getVariable('fax_image_resolution')),
+ image_size = common.str.to_i(session:getVariable('fax_image_size')),
+ local_station_id = common.str.to_s(session:getVariable('fax_local_station_id')),
+ result_code = common.str.to_i(session:getVariable('fax_result_code')),
+ remote_station_id = common.str.to_s(session:getVariable('fax_remote_station_id')),
+ success = common.str.to_b(session:getVariable('fax_success')),
+ transfer_rate = common.str.to_i(session:getVariable('fax_transfer_rate')),
+ }
+
+ if fax_state.success then
+ fax_state.state = 'successful';
+ else
+ fax_state.state = 'unsuccessful';
+ end
+
+ fax_account:document_update(fax_document.id, fax_state)
+
+ cause = session:hangupCause();
+ log:info('FAX_SEND - end - fax_document=', fax_document.id, ', success: ', fax_state.state, ', cause: ', cause, ', result: ', fax_state.result_code, ' ', session:getVariable('fax_result_text'));
+else
+ if session then
+ cause = session:hangupCause();
+ end
+ log:debug('Destination "', destination_number, '" could not be reached, cause: ', cause)
+ fax_account:document_update(fax_document.id, {state = 'unsuccessful', result_code = "129"})
+end