mirror of
https://github.com/fusionpbx/fusionpbx.git
synced 2026-01-03 10:23:50 +00:00
9dcaddd814
This is going to sound really stupid but I have tested this extensively, submitted a Jira on it months ago (was told FS 1.6.20 was no longer supported) and it's still an issue. Please do not take my word for this and create a ring group to test the delay settings with a stopwatch and you should see the real vs set delay discrepancy. In FreeSWITCH (both on 1.6.20 and 1.8.5) when sending leg_delay_start values, for whatever reason the actual time is double the value sent. The result of this is that if you send 1000ms as leg_delay_start the actual time the call will be delayed is 2000ms. Because of this bad behavior, ring group delay settings end up being exactly double what is set. e.g. if you set 10s, you will have to wait 20s for the call to be initiated on leg b. The easiest way to fix this behavior is to simply multiply leg_delay_start by half as much to get the right "real" delay time. Ugly, I know... I'm not sure if leg_delay_start value is passed elsewhere, I'm thinking this behavior may also be present in find me/follow me. If this gets accepted I will look for other locations where this behavior occurs and submit separate PRs if I find any other instances of this.
876 lines
34 KiB
Lua
876 lines
34 KiB
Lua
-- Part of FusionPBX
|
|
-- Copyright (C) 2010-2019 Mark J Crane <markjcrane@fusionpbx.com>
|
|
-- All rights reserved.
|
|
--
|
|
-- Redistribution and use in source and binary forms, with or without
|
|
-- modification, are permitted provided that the following conditions are met:
|
|
--
|
|
-- 1. Redistributions of source code must retain the above copyright notice,
|
|
-- this list of conditions and the following disclaimer.
|
|
--
|
|
-- 2. Redistributions in binary form must reproduce the above copyright
|
|
-- notice, this list of conditions and the following disclaimer in the
|
|
-- documentation and/or other materials provided with the distribution.
|
|
--
|
|
-- THIS SOFTWARE IS PROVIDED ''AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
|
|
-- INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
|
|
-- AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
|
|
-- AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
|
|
-- OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
-- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
-- INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
|
-- CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
|
-- ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
|
-- POSSIBILITY OF SUCH DAMAGE.
|
|
--
|
|
-- Contributor(s):
|
|
-- Mark J Crane <markjcrane@fusionpbx.com>
|
|
|
|
--include the log
|
|
log = require "resources.functions.log".ring_group
|
|
|
|
--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
|
|
|
|
--include functions
|
|
require "resources.functions.trim";
|
|
require "resources.functions.explode";
|
|
require "resources.functions.base64";
|
|
require "resources.functions.file_exists";
|
|
require "resources.functions.channel_utils"
|
|
require "resources.functions.format_ringback"
|
|
|
|
--- include libs
|
|
local route_to_bridge = require "resources.functions.route_to_bridge"
|
|
local play_file = require "resources.functions.play_file"
|
|
|
|
--define the session hangup
|
|
function session_hangup_hook()
|
|
|
|
--send info to the log
|
|
--freeswitch.consoleLog("notice","[ring_groups] originate_disposition: " .. session:getVariable("originate_disposition") .. "\n");
|
|
|
|
--status
|
|
status = 'answered'
|
|
|
|
--run the missed called function
|
|
if (
|
|
session:getVariable("originate_disposition") == "ALLOTTED_TIMEOUT"
|
|
or session:getVariable("originate_disposition") == "NO_ANSWER"
|
|
or session:getVariable("originate_disposition") == "NO_USER_RESPONSE"
|
|
or session:getVariable("originate_disposition") == "USER_NOT_REGISTERED"
|
|
or session:getVariable("originate_disposition") == "NORMAL_TEMPORARY_FAILURE"
|
|
or session:getVariable("originate_disposition") == "NO_ROUTE_DESTINATION"
|
|
or session:getVariable("originate_disposition") == "USER_BUSY"
|
|
or session:getVariable("originate_disposition") == "RECOVERY_ON_TIMER_EXPIRE"
|
|
or session:getVariable("originate_disposition") == "failure"
|
|
or session:getVariable("originate_disposition") == "ORIGINATOR_CANCEL"
|
|
) then
|
|
--set the status
|
|
status = 'missed'
|
|
--send missed call notification
|
|
missed();
|
|
end
|
|
|
|
--send the ring group event
|
|
event = freeswitch.Event("CUSTOM", "RING_GROUPS");
|
|
event:addHeader("domain_uuid", domain_uuid);
|
|
event:addHeader("domain_name", domain_name);
|
|
event:addHeader("ring_group_uuid", ring_group_uuid);
|
|
event:addHeader("user_uuid", user_uuid);
|
|
event:addHeader("ring_group_name", ring_group_name);
|
|
event:addHeader("ring_group_extension", ring_group_extension);
|
|
event:addHeader("status", status);
|
|
event:addHeader("call_uuid", uuid);
|
|
event:addHeader("caller_id_name", caller_id_name);
|
|
event:addHeader("caller_id_number", caller_id_number);
|
|
event:fire();
|
|
|
|
end
|
|
|
|
--define iterator function to iterate over key/value pairs in string
|
|
local function split_vars_pairs(str)
|
|
local last_pos = 1
|
|
return function()
|
|
-- end of string
|
|
if not str then return end
|
|
|
|
-- handle case when there exists comma after kv pair
|
|
local action, next_pos = string.match(str, "([^=]+=%b''),()", last_pos)
|
|
if not action then
|
|
action, next_pos = string.match(str, "([^=]+=[^'][^,]-),()", last_pos)
|
|
if not action then
|
|
action, next_pos = string.match(str, "([^=]+=),()", last_pos)
|
|
end
|
|
end
|
|
if action then
|
|
last_pos = next_pos
|
|
return action
|
|
end
|
|
|
|
-- last kv pair may not have comma after it
|
|
if last_pos < #str then
|
|
action = string.match(str, "([^=]+=%b'')$", last_pos)
|
|
if not action then
|
|
action = string.match(str, "([^=]+=[^,]-)$", last_pos)
|
|
end
|
|
str = nil -- end of iteration
|
|
end
|
|
|
|
return action
|
|
end
|
|
end
|
|
|
|
--set the hangup hook function
|
|
if (session:ready()) then
|
|
session:setHangupHook("session_hangup_hook");
|
|
end
|
|
|
|
--get the variables
|
|
if (session:ready()) then
|
|
session:setAutoHangup(false);
|
|
ring_group_uuid = session:getVariable("ring_group_uuid");
|
|
recordings_dir = session:getVariable("recordings_dir");
|
|
sounds_dir = session:getVariable("sounds_dir");
|
|
username = session:getVariable("username");
|
|
dialplan = session:getVariable("dialplan");
|
|
caller_id_name = session:getVariable("caller_id_name");
|
|
caller_id_number = session:getVariable("caller_id_number");
|
|
effective_caller_id_name = session:getVariable("effective_caller_id_name");
|
|
effective_caller_id_number = session:getVariable("effective_caller_id_number");
|
|
network_addr = session:getVariable("network_addr");
|
|
ani = session:getVariable("ani");
|
|
aniii = session:getVariable("aniii");
|
|
rdnis = session:getVariable("rdnis");
|
|
destination_number = session:getVariable("destination_number");
|
|
source = session:getVariable("source");
|
|
uuid = session:getVariable("uuid");
|
|
context = session:getVariable("context");
|
|
call_direction = session:getVariable("call_direction");
|
|
accountcode = session:getVariable("accountcode");
|
|
local_ip_v4 = session:getVariable("local_ip_v4")
|
|
end
|
|
|
|
--set caller id
|
|
if (effective_caller_id_name ~= nil) then
|
|
caller_id_name = effective_caller_id_name;
|
|
end
|
|
if (effective_caller_id_number ~= nil) then
|
|
caller_id_number = effective_caller_id_number;
|
|
end
|
|
|
|
--default to local if nil
|
|
if (call_direction == nil) then
|
|
call_direction = "local";
|
|
end
|
|
|
|
--set ring ready
|
|
if (session:ready()) then
|
|
session:execute("ring_ready", "");
|
|
end
|
|
|
|
--define additional variables
|
|
uuids = "";
|
|
external = "false";
|
|
|
|
--set the sounds path for the language, dialect and voice
|
|
if (session:ready()) then
|
|
default_language = session:getVariable("default_language");
|
|
default_dialect = session:getVariable("default_dialect");
|
|
default_voice = session:getVariable("default_voice");
|
|
if (not default_language) then default_language = 'en'; end
|
|
if (not default_dialect) then default_dialect = 'us'; end
|
|
if (not default_voice) then default_voice = 'callie'; end
|
|
end
|
|
|
|
--get record_ext
|
|
record_ext = session:getVariable("record_ext");
|
|
if (not record_ext) then
|
|
record_ext = "wav";
|
|
end
|
|
|
|
--prepare the api object
|
|
api = freeswitch.API();
|
|
|
|
--define the session hangup
|
|
--function on_hangup(s,status)
|
|
-- freeswitch.consoleLog("NOTICE","---- on_hangup: "..status.."\n");
|
|
-- error();
|
|
--end
|
|
|
|
--get current switchname
|
|
hostname = trim(api:execute("switchname", ""))
|
|
|
|
--get the ring group
|
|
ring_group_forward_enabled = '';
|
|
ring_group_forward_destination = '';
|
|
sql = "SELECT d.domain_name, r.* FROM v_ring_groups as r, v_domains as d ";
|
|
sql = sql .. "where r.ring_group_uuid = :ring_group_uuid ";
|
|
sql = sql .. "and r.domain_uuid = d.domain_uuid ";
|
|
local params = {ring_group_uuid = ring_group_uuid};
|
|
status = dbh:query(sql, params, function(row)
|
|
domain_uuid = row["domain_uuid"];
|
|
domain_name = row["domain_name"];
|
|
ring_group_name = row["ring_group_name"];
|
|
ring_group_extension = row["ring_group_extension"];
|
|
ring_group_greeting = row["ring_group_greeting"];
|
|
ring_group_forward_enabled = row["ring_group_forward_enabled"];
|
|
ring_group_forward_destination = row["ring_group_forward_destination"];
|
|
ring_group_forward_toll_allow = row["ring_group_forward_toll_allow"];
|
|
ring_group_call_timeout = row["ring_group_call_timeout"];
|
|
ring_group_caller_id_name = row["ring_group_caller_id_name"];
|
|
ring_group_caller_id_number = row["ring_group_caller_id_number"];
|
|
ring_group_cid_name_prefix = row["ring_group_cid_name_prefix"];
|
|
ring_group_cid_number_prefix = row["ring_group_cid_number_prefix"];
|
|
missed_call_app = row["ring_group_missed_call_app"];
|
|
missed_call_data = row["ring_group_missed_call_data"];
|
|
end);
|
|
|
|
--set the recording path
|
|
record_path = recordings_dir .. "/" .. domain_name .. "/archive/" .. os.date("%Y/%b/%d");
|
|
record_path = record_path:gsub("\\", "/");
|
|
|
|
--set the recording file name
|
|
if (session:ready()) then
|
|
record_name = session:getVariable("record_name");
|
|
if (not record_name) then
|
|
record_name = uuid .. "." .. record_ext;
|
|
end
|
|
end
|
|
|
|
---set the call_timeout to a higher value to prevent the early timeout of the ring group
|
|
if (session:ready()) then
|
|
if (ring_group_call_timeout and #ring_group_call_timeout == 0) then
|
|
ring_group_call_timeout = '300';
|
|
end
|
|
session:setVariable("call_timeout", ring_group_call_timeout);
|
|
end
|
|
|
|
--play the greeting
|
|
if (session:ready()) then
|
|
if (ring_group_greeting and #ring_group_greeting > 0) then
|
|
session:answer();
|
|
session:sleep(1000);
|
|
play_file(dbh, domain_name, domain_uuid, ring_group_greeting)
|
|
session:sleep(1000);
|
|
end
|
|
end
|
|
|
|
--get the ring group user
|
|
sql = "SELECT r.*, u.user_uuid FROM v_ring_groups as r, v_ring_group_users as u ";
|
|
sql = sql .. "where r.ring_group_uuid = :ring_group_uuid ";
|
|
sql = sql .. "and r.ring_group_uuid = u.ring_group_uuid ";
|
|
local params = {ring_group_uuid = ring_group_uuid};
|
|
status = dbh:query(sql, params, function(row)
|
|
user_uuid = row["user_uuid"];
|
|
end);
|
|
|
|
--set the caller id
|
|
if (session:ready()) then
|
|
if (ring_group_cid_name_prefix ~= nil and string.len(ring_group_cid_name_prefix) > 0) then
|
|
session:execute("export", "effective_caller_id_name="..ring_group_cid_name_prefix.."#"..caller_id_name);
|
|
end
|
|
if (ring_group_cid_number_prefix ~= nil and string.len(ring_group_cid_number_prefix) > 0) then
|
|
session:execute("export", "effective_caller_id_number="..ring_group_cid_number_prefix..caller_id_number);
|
|
end
|
|
end
|
|
|
|
--check the missed calls
|
|
function missed()
|
|
|
|
--send missed call email
|
|
if (missed_call_app ~= nil and missed_call_data ~= nil) then
|
|
if (missed_call_app == "email") then
|
|
--set the sounds path for the language, dialect and voice
|
|
default_language = session:getVariable("default_language");
|
|
default_dialect = session:getVariable("default_dialect");
|
|
default_voice = session:getVariable("default_voice");
|
|
if (not default_language) then default_language = 'en'; end
|
|
if (not default_dialect) then default_dialect = 'us'; end
|
|
if (not default_voice) then default_voice = 'callie'; end
|
|
|
|
--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 = 'missed' "
|
|
sql = sql .. "AND template_enabled = 'true' "
|
|
sql = sql .. "ORDER BY domain_uuid DESC "
|
|
local params = {domain_uuid = domain_uuid, template_language = default_language.."-"..default_dialect};
|
|
if (debug["sql"]) then
|
|
freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "; params:" .. json.encode(params) .. "\n");
|
|
end
|
|
dbh:query(sql, params, function(row)
|
|
subject = row["template_subject"];
|
|
body = row["template_body"];
|
|
end);
|
|
|
|
--prepare the headers
|
|
headers = '{"X-FusionPBX-Domain-UUID":"'..domain_uuid..'",';
|
|
headers = headers..'"X-FusionPBX-Domain-Name":"'..domain_name..'",';
|
|
headers = headers..'"X-FusionPBX-Call-UUID":"'..uuid..'",';
|
|
headers = headers..'"X-FusionPBX-Email-Type":"missed"}';
|
|
|
|
--prepare the subject
|
|
subject = subject:gsub("${caller_id_name}", caller_id_name);
|
|
subject = subject:gsub("${caller_id_number}", caller_id_number);
|
|
subject = subject:gsub("${ring_group_name}", ring_group_name);
|
|
subject = subject:gsub("${ring_group_extension}", ring_group_extension);
|
|
subject = subject:gsub("${sip_to_user}", ring_group_name);
|
|
subject = subject:gsub("${dialed_user}", ring_group_extension);
|
|
subject = trim(subject);
|
|
subject = '=?utf-8?B?'..base64.encode(subject)..'?=';
|
|
|
|
--prepare the body
|
|
body = body:gsub("${caller_id_name}", caller_id_name);
|
|
body = body:gsub("${caller_id_number}", caller_id_number);
|
|
body = body:gsub("${ring_group_name}", ring_group_name);
|
|
body = body:gsub("${ring_group_extension}", ring_group_extension);
|
|
body = body:gsub("${sip_to_user}", ring_group_name);
|
|
body = body:gsub("${dialed_user}", ring_group_extension);
|
|
body = body:gsub(" ", " ");
|
|
body = body:gsub("%s+", "");
|
|
body = body:gsub(" ", " ");
|
|
body = body:gsub("\n", "");
|
|
body = body:gsub("\n", "");
|
|
body = body:gsub("'", "'");
|
|
body = body:gsub([["]], """);
|
|
body = trim(body);
|
|
|
|
--send the email
|
|
cmd = "luarun email.lua "..missed_call_data.." "..missed_call_data.." "..headers.." '"..subject.."' '"..body.."'";
|
|
if (debug["info"]) then
|
|
freeswitch.consoleLog("notice", "[missed call] cmd: " .. cmd .. "\n");
|
|
end
|
|
api = freeswitch.API();
|
|
result = api:executeString(cmd);
|
|
end
|
|
end
|
|
end
|
|
|
|
--get the destination and follow the forward
|
|
function get_forward_all(count, destination_number, domain_name)
|
|
cmd = "user_exists id ".. destination_number .." "..domain_name;
|
|
--freeswitch.consoleLog("notice", "[ring groups][call forward all] " .. cmd .. "\n");
|
|
user_exists = api:executeString(cmd);
|
|
if (user_exists == "true") then
|
|
---check to see if the new destination is forwarded - third forward
|
|
cmd = "user_data ".. destination_number .."@" ..domain_name.." var forward_all_enabled";
|
|
if (api:executeString(cmd) == "true") then
|
|
--get the toll_allow var
|
|
cmd = "user_data ".. destination_number .."@" ..leg_domain_name.." var toll_allow";
|
|
toll_allow = api:executeString(cmd);
|
|
--freeswitch.consoleLog("notice", "[ring groups][call forward all] " .. destination_number .. " toll_allow is ".. toll_allow .."\n");
|
|
|
|
--get the new destination - third foward
|
|
cmd = "user_data ".. destination_number .."@" ..domain_name.." var forward_all_destination";
|
|
destination_number = api:executeString(cmd);
|
|
--freeswitch.consoleLog("notice", "[ring groups][call forward all] " .. count .. " " .. cmd .. " ".. destination_number .."\n");
|
|
count = count + 1;
|
|
if (count < 5) then
|
|
count, destination_number = get_forward_all(count, destination_number, domain_name);
|
|
end
|
|
end
|
|
end
|
|
return count, destination_number, toll_allow;
|
|
end
|
|
|
|
--process the ring group
|
|
if (ring_group_forward_enabled == "true" and string.len(ring_group_forward_destination) > 0) then
|
|
--forward the ring group
|
|
session:setVariable("toll_allow", ring_group_forward_toll_allow);
|
|
session:execute("transfer", ring_group_forward_destination.." XML "..context);
|
|
else
|
|
--get the strategy of the ring group, if random, we use random() to order the destinations
|
|
local sql = [[
|
|
SELECT
|
|
r.ring_group_strategy
|
|
FROM
|
|
v_ring_groups as r
|
|
WHERE
|
|
ring_group_uuid = :ring_group_uuid
|
|
AND r.domain_uuid = :domain_uuid
|
|
AND r.ring_group_enabled = 'true'
|
|
]];
|
|
|
|
local params = {ring_group_uuid = ring_group_uuid, domain_uuid = domain_uuid};
|
|
|
|
assert(dbh:query(sql, params, function(row)
|
|
if (row.ring_group_strategy == "random") then
|
|
if (database["type"] == "mysql") then
|
|
sql_order = 'rand()'
|
|
else
|
|
sql_order = 'random()' --both postgresql and sqlite uses random() instead of rand()
|
|
end
|
|
else
|
|
sql_order='d.destination_delay, d.destination_number asc'
|
|
end
|
|
end));
|
|
|
|
--get the ring group destinations
|
|
sql = [[
|
|
SELECT
|
|
r.ring_group_strategy, r.ring_group_timeout_app, r.ring_group_distinctive_ring,
|
|
d.destination_number, d.destination_delay, d.destination_timeout, d.destination_prompt,
|
|
r.ring_group_caller_id_name, r.ring_group_caller_id_number,
|
|
r.ring_group_cid_name_prefix, r.ring_group_cid_number_prefix,
|
|
r.ring_group_timeout_data, r.ring_group_ringback
|
|
FROM
|
|
v_ring_groups as r, v_ring_group_destinations as d
|
|
WHERE
|
|
d.ring_group_uuid = r.ring_group_uuid
|
|
AND d.ring_group_uuid = :ring_group_uuid
|
|
AND r.domain_uuid = :domain_uuid
|
|
AND r.ring_group_enabled = 'true'
|
|
ORDER BY
|
|
]]..sql_order..[[
|
|
]];
|
|
if debug["sql"] then
|
|
freeswitch.consoleLog("notice", "[ring group] SQL:" .. sql .. "; params:" .. json.encode(params) .. "\n");
|
|
end
|
|
destinations = {};
|
|
destination_count = 0;
|
|
x = 1;
|
|
assert(dbh:query(sql, params, function(row)
|
|
if (row.destination_prompt == "1" or row.destination_prompt == "2") then
|
|
prompt = "true";
|
|
end
|
|
|
|
local array = explode("@",row.destination_number);
|
|
if (array[2] == nil) then
|
|
-- no @
|
|
leg_domain_name = domain_name;
|
|
else
|
|
leg_domain_name = array[2];
|
|
end
|
|
|
|
--follow the forwards
|
|
count, destination_number, toll_allow = get_forward_all(0, row.destination_number, leg_domain_name);
|
|
|
|
--update values
|
|
row['destination_number'] = destination_number
|
|
row['toll_allow'] = toll_allow;
|
|
|
|
--check if the user exists
|
|
cmd = "user_exists id ".. destination_number .." "..domain_name;
|
|
user_exists = api:executeString(cmd);
|
|
|
|
--cmd = "user_exists id ".. destination_number .." "..leg_domain_name;
|
|
if (user_exists == "true") then
|
|
--add user_exists true or false to the row array
|
|
row['user_exists'] = "true";
|
|
--handle do_not_disturb
|
|
cmd = "user_data ".. destination_number .."@" ..leg_domain_name.." var do_not_disturb";
|
|
if (api:executeString(cmd) ~= "true") then
|
|
--add the row to the destinations array
|
|
destinations[x] = row;
|
|
end
|
|
else
|
|
--set the values
|
|
external = "true";
|
|
row['user_exists'] = "false";
|
|
--add the row to the destinations array
|
|
destinations[x] = row;
|
|
end
|
|
row['domain_name'] = leg_domain_name;
|
|
destination_count = destination_count + 1;
|
|
x = x + 1;
|
|
end));
|
|
--freeswitch.consoleLog("NOTICE", "[ring_group] external "..external.."\n");
|
|
|
|
--get the dialplan data and save it to a table
|
|
if (external == "true") then
|
|
dialplans = route_to_bridge.preload_dialplan(
|
|
dbh, domain_uuid, {hostname = hostname, context = context}
|
|
)
|
|
end
|
|
|
|
--prepare the array of destinations
|
|
x = 1;
|
|
for key, row in pairs(destinations) do
|
|
--set the values from the database as variables
|
|
user_exists = row.user_exists;
|
|
ring_group_strategy = row.ring_group_strategy;
|
|
ring_group_timeout_app = row.ring_group_timeout_app;
|
|
ring_group_timeout_data = row.ring_group_timeout_data;
|
|
ring_group_caller_id_name = row.ring_group_caller_id_name;
|
|
ring_group_caller_id_number = row.ring_group_caller_id_number;
|
|
ring_group_cid_name_prefix = row.ring_group_cid_name_prefix;
|
|
ring_group_cid_number_prefix = row.ring_group_cid_number_prefix;
|
|
ring_group_distinctive_ring = row.ring_group_distinctive_ring;
|
|
ring_group_ringback = row.ring_group_ringback;
|
|
destination_number = row.destination_number;
|
|
destination_delay = row.destination_delay;
|
|
destination_timeout = row.destination_timeout;
|
|
destination_prompt = row.destination_prompt;
|
|
toll_allow = row.toll_allow;
|
|
|
|
--determine if the user is registered if not registered then lookup
|
|
cmd = "sofia_contact */".. destination_number .."@" ..domain_name;
|
|
if (api:executeString(cmd) == "error/user_not_registered") then
|
|
freeswitch.consoleLog("NOTICE", "[ring_group] "..cmd.."\n");
|
|
cmd = "user_data ".. destination_number .."@" ..domain_name.." var forward_user_not_registered_enabled";
|
|
freeswitch.consoleLog("NOTICE", "[ring_group] "..cmd.."\n");
|
|
if (api:executeString(cmd) == "true") then
|
|
--get the new destination number
|
|
cmd = "user_data ".. destination_number .."@" ..domain_name.." var forward_user_not_registered_destination";
|
|
freeswitch.consoleLog("NOTICE", "[ring_group] "..cmd.."\n");
|
|
not_registered_destination_number = api:executeString(cmd);
|
|
freeswitch.consoleLog("NOTICE", "[ring_group] "..not_registered_destination_number.."\n");
|
|
if (not_registered_destination_number ~= nil) then
|
|
destination_number = not_registered_destination_number;
|
|
destinations[key]['destination_number'] = destination_number;
|
|
end
|
|
|
|
--check the new destination number for user_exists
|
|
cmd = "user_exists id ".. destination_number .." "..domain_name;
|
|
user_exists = api:executeString(cmd);
|
|
if (user_exists == "true") then
|
|
destinations[key]['user_exists'] = "true";
|
|
else
|
|
destinations[key]['user_exists'] = "false";
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
--process the destinations
|
|
--x = 1;
|
|
--for key, row in pairs(destinations) do
|
|
-- freeswitch.consoleLog("NOTICE", "[ring group] destination_number: "..row.destination_number.."\n");
|
|
--end
|
|
|
|
--process the destinations
|
|
x = 1;
|
|
for key, row in pairs(destinations) do
|
|
--set the values from the database as variables
|
|
user_exists = row.user_exists;
|
|
ring_group_strategy = row.ring_group_strategy;
|
|
ring_group_timeout_app = row.ring_group_timeout_app;
|
|
ring_group_timeout_data = row.ring_group_timeout_data;
|
|
ring_group_caller_id_name = row.ring_group_caller_id_name;
|
|
ring_group_caller_id_number = row.ring_group_caller_id_number;
|
|
ring_group_cid_name_prefix = row.ring_group_cid_name_prefix;
|
|
ring_group_cid_number_prefix = row.ring_group_cid_number_prefix;
|
|
ring_group_distinctive_ring = row.ring_group_distinctive_ring;
|
|
ring_group_ringback = row.ring_group_ringback;
|
|
destination_number = row.destination_number;
|
|
destination_delay = row.destination_delay;
|
|
destination_timeout = row.destination_timeout;
|
|
destination_prompt = row.destination_prompt;
|
|
group_confirm_key = row.group_confirm_key;
|
|
group_confirm_file = row.group_confirm_file;
|
|
toll_allow = row.toll_allow;
|
|
user_exists = row.user_exists;
|
|
|
|
--follow the forwards
|
|
count, destination_number = get_forward_all(0, destination_number, leg_domain_name);
|
|
|
|
--check if the user exists
|
|
cmd = "user_exists id ".. destination_number .." "..domain_name;
|
|
user_exists = api:executeString(cmd);
|
|
|
|
--set ringback
|
|
ring_group_ringback = format_ringback(ring_group_ringback);
|
|
session:setVariable("ringback", ring_group_ringback);
|
|
session:setVariable("transfer_ringback", ring_group_ringback);
|
|
|
|
--set the timeout if there is only one destination
|
|
if (destination_count == 1) then
|
|
session:execute("set", "call_timeout="..row.destination_timeout);
|
|
end
|
|
|
|
--setup the delimiter
|
|
delimiter = ",";
|
|
if (ring_group_strategy == "rollover") then
|
|
delimiter = "|";
|
|
end
|
|
if (ring_group_strategy == "sequence") then
|
|
delimiter = "|";
|
|
end
|
|
if (ring_group_strategy == "random") then
|
|
delimiter = "|";
|
|
end
|
|
if (ring_group_strategy == "simultaneous") then
|
|
delimiter = ",";
|
|
end
|
|
if (ring_group_strategy == "enterprise") then
|
|
delimiter = ":_:";
|
|
end
|
|
|
|
--leg delay settings
|
|
if (ring_group_strategy == "enterprise") then
|
|
delay_name = "originate_delay_start";
|
|
destination_delay = destination_delay * 500;
|
|
else
|
|
delay_name = "leg_delay_start";
|
|
end
|
|
|
|
--create a new uuid and add it to the uuid list
|
|
new_uuid = api:executeString("create_uuid");
|
|
if (string.len(uuids) == 0) then
|
|
uuids = new_uuid;
|
|
else
|
|
uuids = uuids ..",".. new_uuid;
|
|
end
|
|
session:execute("set", "uuids="..uuids);
|
|
|
|
--export the ringback
|
|
if (ring_group_distinctive_ring ~= nil) then
|
|
if (local_ip_v4 ~= nil) then
|
|
ring_group_distinctive_ring = ring_group_distinctive_ring:gsub("${local_ip_v4}", local_ip_v4);
|
|
end
|
|
if (domain_name ~= nil) then
|
|
ring_group_distinctive_ring = ring_group_distinctive_ring:gsub("${domain_name}", domain_name);
|
|
end
|
|
session:execute("export", "sip_h_Alert-Info="..ring_group_distinctive_ring);
|
|
end
|
|
|
|
--set confirm
|
|
if (ring_group_strategy == "simultaneous"
|
|
or ring_group_strategy == "sequence"
|
|
or ring_group_strategy == "rollover") then
|
|
session:execute("set", "group_confirm_key=exec");
|
|
session:execute("set", "group_confirm_file=lua ".. scripts_dir:gsub('\\','/') .."/confirm.lua");
|
|
end
|
|
|
|
--determine confirm prompt
|
|
if (destination_prompt == nil) then
|
|
group_confirm = "confirm=false,";
|
|
elseif (destination_prompt == "1") then
|
|
group_confirm = "group_confirm_key=exec,group_confirm_file=lua ".. scripts_dir:gsub('\\','/') .."/confirm.lua,confirm=true,";
|
|
elseif (destination_prompt == "2") then
|
|
group_confirm = "group_confirm_key=exec,group_confirm_file=lua ".. scripts_dir:gsub('\\','/') .."/confirm.lua,confirm=true,";
|
|
else
|
|
group_confirm = "confirm=false,";
|
|
end
|
|
|
|
--get user_record value and determine whether to record the session
|
|
cmd = "user_data ".. destination_number .."@"..domain_name.." var user_record";
|
|
user_record = trim(api:executeString(cmd));
|
|
--set the record_session variable
|
|
record_session = false;
|
|
if (user_record == "all") then
|
|
record_session = true;
|
|
end
|
|
if (user_record == "inbound" and call_direction == "inbound") then
|
|
record_session = true;
|
|
end
|
|
if (user_record == "outbound" and call_direction == "outbound") then
|
|
record_session = true;
|
|
end
|
|
if (user_record == "local" and call_direction == "local") then
|
|
record_session = true;
|
|
end
|
|
|
|
--record the session
|
|
if (record_session) then
|
|
record_session = ",api_on_answer='uuid_record "..uuid.." start ".. record_path .. "/" .. record_name .. "',record_path='".. record_path .."',record_name="..record_name;
|
|
else
|
|
record_session = ""
|
|
end
|
|
row.record_session = record_session
|
|
|
|
--process according to user_exists, sip_uri, external number
|
|
if (user_exists == "true") then
|
|
--get the extension_uuid
|
|
cmd = "user_data ".. destination_number .."@"..domain_name.." var extension_uuid";
|
|
extension_uuid = trim(api:executeString(cmd));
|
|
--send to user
|
|
local dial_string_to_user = "[sip_invite_domain="..domain_name..",call_direction="..call_direction..","..group_confirm.."leg_timeout="..destination_timeout..","..delay_name.."="..destination_delay..",dialed_extension=" .. row.destination_number .. ",extension_uuid="..extension_uuid .. row.record_session .. "]user/" .. row.destination_number .. "@" .. domain_name;
|
|
dial_string = dial_string_to_user;
|
|
elseif (tonumber(destination_number) == nil) then
|
|
--sip uri
|
|
dial_string = "[sip_invite_domain="..domain_name..",call_direction="..call_direction..","..group_confirm.."leg_timeout="..destination_timeout..","..delay_name.."="..destination_delay.."]" .. row.destination_number;
|
|
else
|
|
--external number
|
|
route_bridge = 'loopback/'..destination_number;
|
|
|
|
--set the toll allow to an empty string
|
|
if (toll_allow == nil) then
|
|
toll_allow = '';
|
|
end
|
|
|
|
--set the caller id
|
|
caller_id = '';
|
|
if (ring_group_caller_id_name ~= nil) then
|
|
caller_id = "origination_caller_id_name='"..ring_group_caller_id_name.."'"
|
|
end
|
|
if (ring_group_caller_id_number ~= nil) then
|
|
caller_id = caller_id .. ",origination_caller_id_number="..ring_group_caller_id_number..",";
|
|
end
|
|
|
|
--set the destination dial string
|
|
dial_string = "[ignore_early_media=true,toll_allow=".. toll_allow ..",".. caller_id .."sip_invite_domain="..domain_name..",call_direction="..call_direction..","..group_confirm.."leg_timeout="..destination_timeout..","..delay_name.."="..destination_delay.."]"..route_bridge
|
|
end
|
|
|
|
--add a delimiter between destinations
|
|
if (dial_string ~= nil) then
|
|
--freeswitch.consoleLog("notice", "[ring group] dial_string: " .. dial_string .. "\n");
|
|
if (x == 1) then
|
|
if (ring_group_strategy == "enterprise") then
|
|
app_data = dial_string;
|
|
else
|
|
app_data = "{ignore_early_media=true}"..dial_string;
|
|
end
|
|
else
|
|
if (app_data == nil) then
|
|
if (ring_group_strategy == "enterprise") then
|
|
app_data = dial_string;
|
|
else
|
|
app_data = "{ignore_early_media=true}"..dial_string;
|
|
end
|
|
else
|
|
app_data = app_data .. delimiter .. dial_string;
|
|
end
|
|
end
|
|
end
|
|
|
|
--increment the value of x
|
|
x = x + 1;
|
|
end
|
|
|
|
--session execute
|
|
if (session:ready()) then
|
|
--set the variables
|
|
session:execute("set", "hangup_after_bridge=true");
|
|
session:execute("set", "continue_on_fail=true");
|
|
|
|
-- support conf-xfer feature
|
|
-- do
|
|
-- local uuid = api:executeString("create_uuid")
|
|
-- session:execute("export", "conf_xfer_number=xfer-" .. uuid .. "-" .. domain_name)
|
|
-- end
|
|
|
|
--set bind digit action
|
|
local bind_target = 'peer'
|
|
if session:getVariable("sip_authorized") == "true" then
|
|
bind_target = 'both';
|
|
end
|
|
local bindings = {
|
|
"local,*2,exec:record_session," .. record_path .. "/" .. record_name,
|
|
-- "local,*0,exec:execute_extension,conf_xfer_from_dialplan XML conf-xfer@" .. context
|
|
}
|
|
for _, str in ipairs(bindings) do
|
|
session:execute("bind_digit_action", str .. "," .. bind_target)
|
|
end
|
|
session:execute("digit_action_set_realm", "local");
|
|
|
|
--if the user is busy rollover to the next destination
|
|
if (ring_group_strategy == "rollover") then
|
|
timeout = 0;
|
|
x = 0;
|
|
for key, row in pairs(destinations) do
|
|
|
|
--set the app data
|
|
app_data = '{ignore_early_media=true}';
|
|
|
|
--set the values from the database as variables
|
|
user_exists = row.user_exists;
|
|
destination_number = row.destination_number;
|
|
domain_name = row.domain_name;
|
|
|
|
--get the extension_uuid
|
|
if (user_exists == "true") then
|
|
cmd = "user_data ".. destination_number .."@"..domain_name.." var extension_uuid";
|
|
extension_uuid = trim(api:executeString(cmd));
|
|
end
|
|
|
|
--if the timeout was reached exit the loop and go to the timeout action
|
|
if (tonumber(ring_group_call_timeout) == timeout) then
|
|
break;
|
|
end
|
|
timeout = timeout + destination_timeout;
|
|
|
|
--send the call to the destination
|
|
if (user_exists == "true") then
|
|
dial_string = "["..group_confirm.."sip_invite_domain="..domain_name..",originate_timeout="..destination_timeout..",call_direction="..call_direction..",dialed_extension=" .. destination_number .. ",extension_uuid="..extension_uuid..",domain_name="..domain_name..",domain_uuid="..domain_uuid..row.record_session.."]user/" .. destination_number .. "@" .. domain_name;
|
|
elseif (tonumber(destination_number) == nil) then
|
|
dial_string = "["..group_confirm.."sip_invite_domain="..domain_name..",originate_timeout="..destination_timeout..",call_direction=outbound,domain_name="..domain_name..",domain_uuid="..domain_uuid.."]" .. destination_number;
|
|
else
|
|
dial_string = "["..group_confirm.."sip_invite_domain="..domain_name..",originate_timeout="..destination_timeout..",domain_name="..domain_name..",domain_uuid="..domain_uuid..",call_direction=outbound]loopback/" .. destination_number;
|
|
end
|
|
|
|
--add the delimiter
|
|
app_data = app_data .. dial_string;
|
|
freeswitch.consoleLog("NOTICE", "[ring group] app_data: "..app_data.."\n");
|
|
session:execute("bridge", app_data);
|
|
|
|
--increment the value of x
|
|
x = x + 1;
|
|
end
|
|
end
|
|
|
|
--execute the bridge
|
|
if (app_data ~= nil) then
|
|
if (ring_group_strategy == "enterprise") then
|
|
app_data = app_data:gsub("%[", "{");
|
|
app_data = app_data:gsub("%]", "}");
|
|
end
|
|
freeswitch.consoleLog("NOTICE", "[ring group] app_data: "..app_data.."\n");
|
|
-- log.noticef("bridge begin: originate_disposition:%s answered:%s ready:%s bridged:%s", session:getVariable("originate_disposition"), session:answered() and "true" or "false", session:ready() and "true" or "false", session:bridged() and "true" or "false")
|
|
if (ring_group_strategy ~= "rollover") then
|
|
session:execute("bridge", app_data);
|
|
end
|
|
-- log.noticef("bridge done: originate_disposition:%s answered:%s ready:%s bridged:%s", session:getVariable("originate_disposition"), session:answered() and "true" or "false", session:ready() and "true" or "false", session:bridged() and "true" or "false")
|
|
end
|
|
|
|
--timeout destination
|
|
if (app_data ~= nil) then
|
|
if session:ready() and (
|
|
session:getVariable("originate_disposition") == "ALLOTTED_TIMEOUT"
|
|
or session:getVariable("originate_disposition") == "NO_ANSWER"
|
|
or session:getVariable("originate_disposition") == "NO_USER_RESPONSE"
|
|
or session:getVariable("originate_disposition") == "USER_NOT_REGISTERED"
|
|
or session:getVariable("originate_disposition") == "NORMAL_TEMPORARY_FAILURE"
|
|
or session:getVariable("originate_disposition") == "NO_ROUTE_DESTINATION"
|
|
or session:getVariable("originate_disposition") == "USER_BUSY"
|
|
or session:getVariable("originate_disposition") == "RECOVERY_ON_TIMER_EXPIRE"
|
|
or session:getVariable("originate_disposition") == "failure"
|
|
) then
|
|
--execute the time out action
|
|
if ring_group_timeout_app and #ring_group_timeout_app > 0 then
|
|
session:execute(ring_group_timeout_app, ring_group_timeout_data);
|
|
end
|
|
--check and report missed call
|
|
missed();
|
|
end
|
|
else
|
|
if (ring_group_timeout_app ~= nil) then
|
|
--execute the time out action
|
|
if ring_group_timeout_app and #ring_group_timeout_app > 0 then
|
|
session:execute(ring_group_timeout_app, ring_group_timeout_data);
|
|
end
|
|
else
|
|
local sql = "SELECT ring_group_timeout_app, ring_group_timeout_data FROM v_ring_groups ";
|
|
sql = sql .. "where ring_group_uuid = :ring_group_uuid";
|
|
local params = {ring_group_uuid = ring_group_uuid};
|
|
if debug["sql"] then
|
|
freeswitch.consoleLog("notice", "[ring group] SQL:" .. sql .. "; params:" .. json.encode(params) .. "\n");
|
|
end
|
|
dbh:query(sql, params, function(row)
|
|
--execute the time out action
|
|
if row.ring_group_timeout_app and #row.ring_group_timeout_app > 0 then
|
|
session:execute(row.ring_group_timeout_app, row.ring_group_timeout_data);
|
|
end
|
|
end);
|
|
end
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
--actions
|
|
--ACTIONS = {}
|
|
--table.insert(ACTIONS, {"set", "hangup_after_bridge=true"});
|
|
--table.insert(ACTIONS, {"set", "continue_on_fail=true"});
|
|
--table.insert(ACTIONS, {"bridge", app_data});
|
|
--table.insert(ACTIONS, {ring_group_timeout_app, ring_group_timeout_data});
|